Atlas › Test

nil_message_body

Exact test identity: go.temporal.io/server/common/protocol/TestNilSafety/nil_message_body

Package: go.temporal.io/server/common/protocol
Suite / test hierarchy: TestNilSafety/nil_message_body
Test: nil_message_body
Introduced at: naming.go ×1 Frontier kind: Joint frontier
Covered ranges: 4
Covered lines: 9
Covered files: 1

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/common/protocol/naming.go 9 covered LOC · 4 ranges

  42
  
  // message type of the body and the type of the protocol to which this message
  
  43
  
  // belongs.
  
  44
  >
  func Identify(msg *protocolpb.Message) (Type, MessageType, error) {
  
naming.go

  45
  >
  	if msg == nil {
  
  46
  
  		return TypeUnknown, MessageTypeUnknown, errNilMsg
  
  47
  >
  	} else if msg.Body == nil {
  
naming.go

  48
  >
  		return TypeUnknown, MessageTypeUnknown, errNilBody
  
naming.go

  49
  >
  	}
  
  50
  
  51
  
  	bodyTypeName := string(msg.Body.MessageName())

  66
  
  // MessageTypeUnknown in the case where either one cannot be determined due to
  
  67
  
  // an error.
  
  68
  >
  func IdentifyOrUnknown(msg *protocolpb.Message) (Type, MessageType) {
  
naming.go

  69
  >
  	pt, mt, _ := Identify(msg)
  
  70
  >
  	return pt, mt
  
  71
  >
  }
  
  72
  
  73
  
  func (cerr constErr) Error() string {