serialization

package
v1.7.2 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 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 TaskInfoToBlob 

func TaskInfoToBlob(info *persistencespb.AllocatedTaskInfo) (commonpb.DataBlob, 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 WorkflowExecutionInfoToBlob 

func WorkflowExecutionInfoToBlob(info *persistencespb.WorkflowExecutionInfo) (commonpb.DataBlob, error)

func WorkflowExecutionStateFromBlob 

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

func WorkflowExecutionStateToBlob 

func WorkflowExecutionStateToBlob(info *persistencespb.WorkflowExecutionState) (commonpb.DataBlob, error)

func WorkflowMutableStateFromBlob added in v1.5.8 

func WorkflowMutableStateFromBlob(blob []byte, encoding string) (*persistencespb.WorkflowMutableState, error)

func WorkflowMutableStateToBlob added in v1.5.8 

func WorkflowMutableStateToBlob(info *persistencespb.WorkflowMutableState) (commonpb.DataBlob, error)

Types

This section is empty.

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.