serializer

Documentation

Index

• func DeserializeBatchEvents(data *commonpb.DataBlob) ([]*historypb.HistoryEvent, error)
• func DeserializeBlobDataToHistoryEvents(dataBlobs []*commonpb.DataBlob, filterType enumspb.HistoryEventFilterType) (*historypb.History, error)
• func NewDataBlob(data []byte, encodingType enumspb.EncodingType) *commonpb.DataBlob
• func NewDeserializationError(msg string) error
• func NewSerializationError(msg string) error
• func NewUnknownEncodingTypeError(encodingType enumspb.EncodingType) error
• func SerializeBatchEvents(events []*historypb.HistoryEvent, encodingType enumspb.EncodingType) (*commonpb.DataBlob, error)
• type DeserializationError
  • func (e *DeserializationError) Error() string
• type JSONPBEncoder
  • func NewJSONPBEncoder() JSONPBEncoder
  • func NewJSONPBIndentEncoder(indent string) JSONPBEncoder
  • func (e JSONPBEncoder) Decode(data []byte, pb proto.Message) error
  • func (e JSONPBEncoder) Encode(pb proto.Message) ([]byte, error)
• type Marshaler
• type SerializationError
  • func (e *SerializationError) Error() string
• type UnknownEncodingTypeError
  • func (e *UnknownEncodingTypeError) Error() string

Functions

func DeserializeBatchEvents

func DeserializeBatchEvents(data *commonpb.DataBlob) ([]*historypb.HistoryEvent, error)

DeserializeBatchEvents deserializes batch events from a datablob proto

func DeserializeBlobDataToHistoryEvents

func DeserializeBlobDataToHistoryEvents(
	dataBlobs []*commonpb.DataBlob, filterType enumspb.HistoryEventFilterType,
) (*historypb.History, error)

DeserializeBlobDataToHistoryEvents deserialize the blob data to history event data

func NewDataBlob

func NewDataBlob(data []byte, encodingType enumspb.EncodingType) *commonpb.DataBlob

NewDataBlob creates new blob data

func NewDeserializationError

func NewDeserializationError(msg string) error

NewDeserializationError returns a DeserializationError

func NewSerializationError

func NewSerializationError(msg string) error

NewSerializationError returns a SerializationError

func NewUnknownEncodingTypeError

func NewUnknownEncodingTypeError(encodingType enumspb.EncodingType) error

NewUnknownEncodingTypeError returns a new instance of encoding type error

func SerializeBatchEvents

func SerializeBatchEvents(events []*historypb.HistoryEvent, encodingType enumspb.EncodingType) (*commonpb.DataBlob, error)

SerializeBatchEvents serializes batch events into a datablob proto

Types

type DeserializationError

type DeserializationError struct {
	// contains filtered or unexported fields
}

DeserializationError is an error type for deserialization

func (*DeserializationError) Error

func (e *DeserializationError) Error() string

type JSONPBEncoder

type JSONPBEncoder struct {
	// contains filtered or unexported fields
}

JSONPBEncoder is JSON encoder/decoder for protobuf structs and slices of protobuf structs.

func NewJSONPBEncoder

func NewJSONPBEncoder() JSONPBEncoder

NewJSONPBEncoder creates a new JSONPBEncoder.

func NewJSONPBIndentEncoder

func NewJSONPBIndentEncoder(indent string) JSONPBEncoder

NewJSONPBIndentEncoder creates a new JSONPBEncoder with indent.

func (JSONPBEncoder) Decode

func (e JSONPBEncoder) Decode(data []byte, pb proto.Message) error

Decode bytes to protobuf struct.

func (JSONPBEncoder) Encode

func (e JSONPBEncoder) Encode(pb proto.Message) ([]byte, error)

Encode protobuf struct to bytes.

type Marshaler

type Marshaler interface {
	Marshal() ([]byte, error)
}

Marshaler is implemented by objects that can marshal themselves

type SerializationError

type SerializationError struct {
	// contains filtered or unexported fields
}

SerializationError is an error type for serialization

func (*SerializationError) Error

func (e *SerializationError) Error() string

type UnknownEncodingTypeError

type UnknownEncodingTypeError struct {
	// contains filtered or unexported fields
}

UnknownEncodingTypeError is an error type for unknown or unsupported encoding type

func (*UnknownEncodingTypeError) Error

func (e *UnknownEncodingTypeError) Error() string