protobuf

package
v0.0.0-...-2fb9ad5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 15, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL