Documentation
¶
Index ¶
- Variables
- func Decode(binary []byte, val ThriftObject) error
- func DeserializeBatchEvents(data *apiv1.DataBlob) ([]*apiv1.HistoryEvent, error)
- func DeserializeBlobDataToHistoryEvents(dataBlobs []*apiv1.DataBlob, filterType apiv1.EventFilterType) (*apiv1.History, error)
- func Encode(obj ThriftObject) ([]byte, error)
- func NewDataBlob(data []byte, encodingType apiv1.EncodingType) *apiv1.DataBlob
- func SerializeBatchEvents(events []*apiv1.HistoryEvent, encodingType apiv1.EncodingType) (*apiv1.DataBlob, error)
- type ThriftObject
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // MissingBinaryEncodingVersion indicate that the encoding version is missing MissingBinaryEncodingVersion = &api.BadRequestError{Message: "Missing binary encoding version."} // InvalidBinaryEncodingVersion indicate that the encoding version is incorrect InvalidBinaryEncodingVersion = &api.BadRequestError{Message: "Invalid binary encoding version."} // MsgPayloadNotThriftEncoded indicate message is not thrift encoded MsgPayloadNotThriftEncoded = &api.BadRequestError{Message: "Message payload is not thrift encoded."} )
Functions ¶
func DeserializeBatchEvents ¶
func DeserializeBatchEvents(data *apiv1.DataBlob) ([]*apiv1.HistoryEvent, error)
DeserializeBatchEvents will deserialize blob data to history event data
func DeserializeBlobDataToHistoryEvents ¶
func DeserializeBlobDataToHistoryEvents( dataBlobs []*apiv1.DataBlob, filterType apiv1.EventFilterType, ) (*apiv1.History, error)
DeserializeBlobDataToHistoryEvents deserialize the blob data to history event data
func NewDataBlob ¶
func NewDataBlob(data []byte, encodingType apiv1.EncodingType) *apiv1.DataBlob
NewDataBlob creates new blob data
func SerializeBatchEvents ¶
func SerializeBatchEvents(events []*apiv1.HistoryEvent, encodingType apiv1.EncodingType) (*apiv1.DataBlob, error)
SerializeBatchEvents will serialize history event data to blob data
Types ¶
Click to show internal directories.
Click to hide internal directories.