serialization

package
v1.9.0 Latest Latest
Warning

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

Go to latest
Published: Apr 27, 2021 License: MIT Imports: 9 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ActivityInfoFromBlob

func ActivityInfoFromBlob(blob []byte, encoding string) (*persistencespb.ActivityInfo, error)

func ActivityInfoToBlob

func ActivityInfoToBlob(info *persistencespb.ActivityInfo) (commonpb.DataBlob, error)

func ChecksumFromBlob

func ChecksumFromBlob(blob []byte, encoding string) (*persistencespb.Checksum, error)

func ChecksumToBlob

func ChecksumToBlob(checksum *persistencespb.Checksum) (commonpb.DataBlob, error)

func ChildExecutionInfoFromBlob

func ChildExecutionInfoFromBlob(blob []byte, encoding string) (*persistencespb.ChildExecutionInfo, error)

func ChildExecutionInfoToBlob

func ChildExecutionInfoToBlob(info *persistencespb.ChildExecutionInfo) (commonpb.DataBlob, error)

func HistoryBranchFromBlob

func HistoryBranchFromBlob(blob []byte, encoding string) (*persistencespb.HistoryBranch, error)

func HistoryBranchToBlob

func HistoryBranchToBlob(info *persistencespb.HistoryBranch) (commonpb.DataBlob, error)

func HistoryTreeInfoFromBlob

func HistoryTreeInfoFromBlob(blob []byte, encoding string) (*persistencespb.HistoryTreeInfo, error)

func HistoryTreeInfoToBlob

func HistoryTreeInfoToBlob(info *persistencespb.HistoryTreeInfo) (commonpb.DataBlob, error)

func NamespaceDetailFromBlob

func NamespaceDetailFromBlob(blob []byte, encoding string) (*persistencespb.NamespaceDetail, error)

func NamespaceDetailToBlob

func NamespaceDetailToBlob(info *persistencespb.NamespaceDetail) (commonpb.DataBlob, error)

func QueueMetadataFromBlob added in v1.4.0

func QueueMetadataFromBlob(blob []byte, encoding string) (*persistencespb.QueueMetadata, error)

func QueueMetadataToBlob added in v1.4.0

func QueueMetadataToBlob(metadata *persistencespb.QueueMetadata) (commonpb.DataBlob, error)

func ReplicationTaskFromBlob added in v1.4.0

func ReplicationTaskFromBlob(blob []byte, encoding string) (*replicationspb.ReplicationTask, error)

func ReplicationTaskInfoFromBlob

func ReplicationTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.ReplicationTaskInfo, error)

func ReplicationTaskInfoToBlob

func ReplicationTaskInfoToBlob(info *persistencespb.ReplicationTaskInfo) (commonpb.DataBlob, error)

func ReplicationTaskToBlob added in v1.4.0

func ReplicationTaskToBlob(replicationTask *replicationspb.ReplicationTask) (commonpb.DataBlob, error)

func RequestCancelInfoFromBlob

func RequestCancelInfoFromBlob(blob []byte, encoding string) (*persistencespb.RequestCancelInfo, error)

func RequestCancelInfoToBlob

func RequestCancelInfoToBlob(info *persistencespb.RequestCancelInfo) (commonpb.DataBlob, error)

func ShardInfoFromBlob

func ShardInfoFromBlob(blob []byte, encoding string, clusterName string) (*persistencespb.ShardInfo, error)

func ShardInfoToBlob

func ShardInfoToBlob(info *persistencespb.ShardInfo) (commonpb.DataBlob, error)

func SignalInfoFromBlob

func SignalInfoFromBlob(blob []byte, encoding string) (*persistencespb.SignalInfo, error)

func SignalInfoToBlob

func SignalInfoToBlob(info *persistencespb.SignalInfo) (commonpb.DataBlob, error)

func TaskInfoFromBlob

func TaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.AllocatedTaskInfo, error)

func TaskQueueInfoFromBlob

func TaskQueueInfoFromBlob(blob []byte, encoding string) (*persistencespb.TaskQueueInfo, error)

func TaskQueueInfoToBlob

func TaskQueueInfoToBlob(info *persistencespb.TaskQueueInfo) (commonpb.DataBlob, error)

func TimerInfoFromBlob

func TimerInfoFromBlob(blob []byte, encoding string) (*persistencespb.TimerInfo, error)

func TimerInfoToBlob

func TimerInfoToBlob(info *persistencespb.TimerInfo) (commonpb.DataBlob, error)

func TimerTaskInfoFromBlob

func TimerTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.TimerTaskInfo, error)

func TimerTaskInfoToBlob

func TimerTaskInfoToBlob(info *persistencespb.TimerTaskInfo) (commonpb.DataBlob, error)

func TransferTaskInfoFromBlob

func TransferTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.TransferTaskInfo, error)

func TransferTaskInfoToBlob

func TransferTaskInfoToBlob(info *persistencespb.TransferTaskInfo) (commonpb.DataBlob, error)

func VisibilityTaskInfoFromBlob added in v1.5.0

func VisibilityTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.VisibilityTaskInfo, error)

func VisibilityTaskInfoToBlob added in v1.5.0

func VisibilityTaskInfoToBlob(info *persistencespb.VisibilityTaskInfo) (commonpb.DataBlob, error)

func WorkflowExecutionInfoFromBlob

func WorkflowExecutionInfoFromBlob(blob []byte, encoding string) (*persistencespb.WorkflowExecutionInfo, error)

func WorkflowExecutionStateFromBlob

func WorkflowExecutionStateFromBlob(blob []byte, encoding string) (*persistencespb.WorkflowExecutionState, error)

Types

This section is empty.

Jump to

Keyboard shortcuts

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