func ValidateBatchMessage()

in runtime/core/protocol/grpc/validator/validator.go [131:153]

• 23 lines of code
• 8 McCabe index (conditional complexity)

func ValidateBatchMessage(msg *pb.BatchMessage) error {
	if msg.Topic == "" {
		return ErrBatchMsgNoTopic
	}
	if msg.ProducerGroup == "" {
		return ErrBatchMsgNoProducerGroup
	}
	for _, item := range msg.MessageItem {
		if item.Content == "" {
			return ErrBatchMsgNoContent
		}
		if item.SeqNum == "" {
			return ErrBatchMsgNoSeqNUM
		}
		if item.Ttl == "" {
			return ErrBatchMsgNoTTL
		}
		if item.UniqueId == "" {
			return ErrBatchMsgNoUID
		}
	}
	return nil
}