Versions in this module Expand all Collapse all v0 v0.1.1 Mar 28, 2022 v0.1.0 Mar 28, 2022 Changes in this version + var File_api_proto_contracts_cmessage_proto protoreflect.FileDescriptor + var File_api_proto_contracts_pmessage_proto protoreflect.FileDescriptor + type CMessage struct + Data []byte + Id string + PartitionKey string + func (*CMessage) Descriptor() ([]byte, []int) + func (*CMessage) ProtoMessage() + func (x *CMessage) GetData() []byte + func (x *CMessage) GetId() string + func (x *CMessage) GetPartitionKey() string + func (x *CMessage) ProtoReflect() protoreflect.Message + func (x *CMessage) Reset() + func (x *CMessage) String() string + type PMessage struct + Data []byte + Metadata map[string]string + PartitionKey string + func (*PMessage) Descriptor() ([]byte, []int) + func (*PMessage) ProtoMessage() + func (x *PMessage) GetData() []byte + func (x *PMessage) GetMetadata() map[string]string + func (x *PMessage) GetPartitionKey() string + func (x *PMessage) ProtoReflect() protoreflect.Message + func (x *PMessage) Reset() + func (x *PMessage) String() string