serializer

package

v1.2.9 Latest Latest Go to latest Published: Mar 1, 2024 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/uber-go/cadence-client

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Decode(binary []byte, val ThriftObject) error
func DeserializeBatchEvents(data *shared.DataBlob) ([]*shared.HistoryEvent, error)
func DeserializeBlobDataToHistoryEvents(dataBlobs []*shared.DataBlob, filterType shared.HistoryEventFilterType) (*shared.History, error)
func Encode(obj ThriftObject) ([]byte, error)
func NewDataBlob(data []byte, encodingType shared.EncodingType) *shared.DataBlob
func SerializeBatchEvents(events []*shared.HistoryEvent, encodingType shared.EncodingType) (*shared.DataBlob, error)
type ThriftObject

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// MissingBinaryEncodingVersion indicate that the encoding version is missing
	MissingBinaryEncodingVersion = &shared.BadRequestError{Message: "Missing binary encoding version."}
	// InvalidBinaryEncodingVersion indicate that the encoding version is incorrect
	InvalidBinaryEncodingVersion = &shared.BadRequestError{Message: "Invalid binary encoding version."}
	// MsgPayloadNotThriftEncoded indicate message is not thrift encoded
	MsgPayloadNotThriftEncoded = &shared.BadRequestError{Message: "Message payload is not thrift encoded."}
)

Functions ¶

func Decode ¶

func Decode(binary []byte, val ThriftObject) error

Decode decode the object

func DeserializeBatchEvents ¶

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

DeserializeBatchEvents will deserialize blob data to history event data

func DeserializeBlobDataToHistoryEvents ¶

func DeserializeBlobDataToHistoryEvents(
	dataBlobs []*shared.DataBlob, filterType shared.HistoryEventFilterType,
) (*shared.History, error)

DeserializeBlobDataToHistoryEvents deserialize the blob data to history event data

func Encode ¶

func Encode(obj ThriftObject) ([]byte, error)

Encode encode the object

func NewDataBlob ¶

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

NewDataBlob creates new blob data

func SerializeBatchEvents ¶

func SerializeBatchEvents(events []*shared.HistoryEvent, encodingType shared.EncodingType) (*shared.DataBlob, error)

SerializeBatchEvents will serialize history event data to blob data

Types ¶

type ThriftObject ¶

type ThriftObject interface {
	FromWire(w wire.Value) error
	ToWire() (wire.Value, error)
}

ThriftObject represents a thrift object

Source Files ¶

View all Source files

history_serializer.go

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