protobuf

Documentation

Index

• type FirehoseEncoderDecoder
  • func NewFirehoseEncodeDecoder(typeUrls map[hedwig.MessageTypeMajorVersion]string) *FirehoseEncoderDecoder
  • func (fcd FirehoseEncoderDecoder) DecodeData(messageType string, version *semver.Version, data interface{}) (interface{}, error)
  • func (fcd FirehoseEncoderDecoder) EncodeData(data interface{}, useMessageTransport bool, metaAttrs hedwig.MetaAttributes) ([]byte, error)
  • func (fcd FirehoseEncoderDecoder) EncodeMessageType(messageType string, version *semver.Version) string
  • func (fcd FirehoseEncoderDecoder) IsBinary() bool
  • func (fcd FirehoseEncoderDecoder) VerifyKnownMinorVersion(messageType string, version *semver.Version) error

Types

type FirehoseEncoderDecoder

type FirehoseEncoderDecoder struct {
	*hedwigProtobuf.EncoderDecoder
	// contains filtered or unexported fields
}

func NewFirehoseEncodeDecoder

func NewFirehoseEncodeDecoder(typeUrls map[hedwig.MessageTypeMajorVersion]string) *FirehoseEncoderDecoder

func (FirehoseEncoderDecoder) DecodeData

func (fcd FirehoseEncoderDecoder) DecodeData(messageType string, version *semver.Version, data interface{}) (interface{}, error)

func (FirehoseEncoderDecoder) EncodeData

func (fcd FirehoseEncoderDecoder) EncodeData(data interface{}, useMessageTransport bool, metaAttrs hedwig.MetaAttributes) ([]byte, error)

EncodeData encodes the message with appropriate format for firehose storage files Type of data must be proto.Message

func (FirehoseEncoderDecoder) EncodeMessageType

func (fcd FirehoseEncoderDecoder) EncodeMessageType(messageType string, version *semver.Version) string

EncodeMessageType encodes the message type with appropriate format for firehose storage files

func (FirehoseEncoderDecoder) IsBinary

func (fcd FirehoseEncoderDecoder) IsBinary() bool

func (FirehoseEncoderDecoder) VerifyKnownMinorVersion

func (fcd FirehoseEncoderDecoder) VerifyKnownMinorVersion(messageType string, version *semver.Version) error

VerifyKnownMinorVersion checks that message version is known to us