protobuf

May 24, 2022

Changes in this version

type EncoderDecoder

+ func (ed *EncoderDecoder) IsBinary() bool

Feb 8, 2022

Changes in this version

+ type EncoderDecoder struct

+ func NewMessageEncoderDecoder(protoMessages []proto.Message) (*EncoderDecoder, error)

+ func NewMessageEncoderDecoderFromMessageTypes(protoMessages map[hedwig.MessageTypeMajorVersion]protoreflect.Message) (*EncoderDecoder, error)

+ func (ed *EncoderDecoder) DecodeData(messageType string, version *semver.Version, data interface{}) (interface{}, error)

+ func (ed *EncoderDecoder) DecodeMessageType(schema string) (string, *semver.Version, error)

+ func (ed *EncoderDecoder) EncodeData(data interface{}, useMessageTransport bool, metaAttrs hedwig.MetaAttributes) ([]byte, error)

+ func (ed *EncoderDecoder) EncodeMessageType(messageType string, version *semver.Version) string

+ func (ed *EncoderDecoder) ExtractData(messagePayload []byte, attributes map[string]string) (hedwig.MetaAttributes, interface{}, error)

+ func (ed *EncoderDecoder) VerifyKnownMinorVersion(messageType string, version *semver.Version) error

Aug 16, 2021

Changes in this version

+ var File_hedwig_protobuf_container_proto protoreflect.FileDescriptor

+ var File_hedwig_protobuf_options_proto protoreflect.FileDescriptor

Jun 17, 2021

Changes in this version

+ var E_MessageOptions = &file_cloudchacho_hedwig_protobuf_options_proto_extTypes[0]

+ var File_cloudchacho_hedwig_protobuf_options_proto protoreflect.FileDescriptor

+ var File_container_proto protoreflect.FileDescriptor

+ func NewMessageEncoder(protoMessages []protoreflect.Message) (hedwig.IEncoder, error)

+ func NewMessageEncoderFromMessageTypes(protoMessages map[hedwig.MessageTypeMajorVersion]protoreflect.Message) (hedwig.IEncoder, error)

+ type MessageOptions struct

+ MajorVersion *uint32

+ MessageType *string

+ MinorVersion *uint32

+ func (*MessageOptions) Descriptor() ([]byte, []int)

+ func (*MessageOptions) ProtoMessage()

+ func (x *MessageOptions) GetMajorVersion() uint32

+ func (x *MessageOptions) GetMessageType() string

+ func (x *MessageOptions) GetMinorVersion() uint32

+ func (x *MessageOptions) ProtoReflect() protoreflect.Message

+ func (x *MessageOptions) Reset()

+ func (x *MessageOptions) String() string

+ type MetadataV1 struct

+ Headers map[string]string

+ Publisher string

+ Timestamp *timestamp.Timestamp

+ func (*MetadataV1) Descriptor() ([]byte, []int)

+ func (*MetadataV1) ProtoMessage()

+ func (x *MetadataV1) GetHeaders() map[string]string

+ func (x *MetadataV1) GetPublisher() string

+ func (x *MetadataV1) GetTimestamp() *timestamp.Timestamp

+ func (x *MetadataV1) ProtoReflect() protoreflect.Message

+ func (x *MetadataV1) Reset()

+ func (x *MetadataV1) String() string

+ type PayloadV1 struct

+ Data *any.Any

+ FormatVersion string

+ Id string

+ Metadata *MetadataV1

+ Schema string

+ func (*PayloadV1) Descriptor() ([]byte, []int)

+ func (*PayloadV1) ProtoMessage()

+ func (x *PayloadV1) GetData() *any.Any

+ func (x *PayloadV1) GetFormatVersion() string

+ func (x *PayloadV1) GetId() string

+ func (x *PayloadV1) GetMetadata() *MetadataV1

+ func (x *PayloadV1) GetSchema() string

+ func (x *PayloadV1) ProtoReflect() protoreflect.Message

+ func (x *PayloadV1) Reset()

+ func (x *PayloadV1) String() string