serialization

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2020 License: MIT Imports: 7 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ActivityInfoFromBlob 

func ActivityInfoFromBlob(b []byte, proto string) (*persistenceblobs.ActivityInfo, error)

func ChecksumFromBlob 

func ChecksumFromBlob(b []byte, proto string) (*persistenceblobs.Checksum, error)

func ChildExecutionInfoFromBlob 

func ChildExecutionInfoFromBlob(b []byte, proto string) (*persistenceblobs.ChildExecutionInfo, error)

func HistoryBranchFromBlob 

func HistoryBranchFromBlob(b []byte, proto string) (*persistenceblobs.HistoryBranch, error)

func HistoryTreeInfoFromBlob 

func HistoryTreeInfoFromBlob(b []byte, proto string) (*persistenceblobs.HistoryTreeInfo, error)

func NamespaceDetailFromBlob 

func NamespaceDetailFromBlob(b []byte, proto string) (*persistenceblobs.NamespaceDetail, error)

func ReplicationTaskInfoFromBlob 

func ReplicationTaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.ReplicationTaskInfo, error)

func ReplicationVersionsFromBlob 

func ReplicationVersionsFromBlob(b []byte, proto string) (*persistenceblobs.ReplicationVersions, error)

func RequestCancelInfoFromBlob 

func RequestCancelInfoFromBlob(b []byte, proto string) (*persistenceblobs.RequestCancelInfo, error)

func ShardInfoFromBlob 

func ShardInfoFromBlob(b []byte, proto string, clusterName string) (*persistenceblobs.ShardInfo, error)

func SignalInfoFromBlob 

func SignalInfoFromBlob(b []byte, proto string) (*persistenceblobs.SignalInfo, error)

func TaskInfoFromBlob 

func TaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.AllocatedTaskInfo, error)

func TaskQueueInfoFromBlob 

func TaskQueueInfoFromBlob(b []byte, proto string) (*persistenceblobs.TaskQueueInfo, error)

func TimerInfoFromBlob 

func TimerInfoFromBlob(b []byte, proto string) (*persistenceblobs.TimerInfo, error)

func TimerTaskInfoFromBlob 

func TimerTaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.TimerTaskInfo, error)

func TransferTaskInfoFromBlob 

func TransferTaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.TransferTaskInfo, error)

func VersionHistoriesFromBlob added in v0.28.0 

func VersionHistoriesFromBlob(b []byte, proto string) (*historyspb.VersionHistories, error)

func WorkflowExecutionInfoFromBlob 

func WorkflowExecutionInfoFromBlob(b []byte, proto string) (*persistenceblobs.WorkflowExecutionInfo, error)

func WorkflowExecutionStateFromBlob 

func WorkflowExecutionStateFromBlob(b []byte, proto string) (*persistenceblobs.WorkflowExecutionState, error)

Types

type DataBlob 

type DataBlob struct {
	Encoding enumspb.EncodingType
	Data     []byte
}

func ActivityInfoToBlob 

func ActivityInfoToBlob(info *persistenceblobs.ActivityInfo) (DataBlob, error)

func ChecksumToBlob 

func ChecksumToBlob(info *persistenceblobs.Checksum) (DataBlob, error)

func ChildExecutionInfoToBlob 

func ChildExecutionInfoToBlob(info *persistenceblobs.ChildExecutionInfo) (DataBlob, error)

func HistoryBranchToBlob 

func HistoryBranchToBlob(info *persistenceblobs.HistoryBranch) (DataBlob, error)

func HistoryTreeInfoToBlob 

func HistoryTreeInfoToBlob(info *persistenceblobs.HistoryTreeInfo) (DataBlob, error)

func NamespaceDetailToBlob 

func NamespaceDetailToBlob(info *persistenceblobs.NamespaceDetail) (DataBlob, error)

func ReplicationTaskInfoToBlob 

func ReplicationTaskInfoToBlob(info *persistenceblobs.ReplicationTaskInfo) (DataBlob, error)

func ReplicationVersionsToBlob 

func ReplicationVersionsToBlob(info *persistenceblobs.ReplicationVersions) (DataBlob, error)

func RequestCancelInfoToBlob 

func RequestCancelInfoToBlob(info *persistenceblobs.RequestCancelInfo) (DataBlob, error)

func ShardInfoToBlob 

func ShardInfoToBlob(info *persistenceblobs.ShardInfo) (DataBlob, error)

func SignalInfoToBlob 

func SignalInfoToBlob(info *persistenceblobs.SignalInfo) (DataBlob, error)

func TaskInfoToBlob 

func TaskInfoToBlob(info *persistenceblobs.AllocatedTaskInfo) (DataBlob, error)

func TaskQueueInfoToBlob 

func TaskQueueInfoToBlob(info *persistenceblobs.TaskQueueInfo) (DataBlob, error)

func TimerInfoToBlob 

func TimerInfoToBlob(info *persistenceblobs.TimerInfo) (DataBlob, error)

func TimerTaskInfoToBlob 

func TimerTaskInfoToBlob(info *persistenceblobs.TimerTaskInfo) (DataBlob, error)

func TransferTaskInfoToBlob 

func TransferTaskInfoToBlob(info *persistenceblobs.TransferTaskInfo) (DataBlob, error)

func VersionHistoriesToBlob added in v0.28.0 

func VersionHistoriesToBlob(info *historyspb.VersionHistories) (DataBlob, error)

func WorkflowExecutionInfoToBlob 

func WorkflowExecutionInfoToBlob(info *persistenceblobs.WorkflowExecutionInfo) (DataBlob, error)

func WorkflowExecutionStateToBlob 

func WorkflowExecutionStateToBlob(info *persistenceblobs.WorkflowExecutionState) (DataBlob, error)

func (*DataBlob) ToProto 

func (d *DataBlob) ToProto() *commonpb.DataBlob

ToProto convert data blob to proto representation

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.