Documentation ¶
Index ¶
- func ActivityInfoFromBlob(blob []byte, encoding string) (*persistencespb.ActivityInfo, error)
- func ActivityInfoToBlob(info *persistencespb.ActivityInfo) (commonpb.DataBlob, error)
- func ChecksumFromBlob(blob []byte, encoding string) (*persistencespb.Checksum, error)
- func ChecksumToBlob(checksum *persistencespb.Checksum) (commonpb.DataBlob, error)
- func ChildExecutionInfoFromBlob(blob []byte, encoding string) (*persistencespb.ChildExecutionInfo, error)
- func ChildExecutionInfoToBlob(info *persistencespb.ChildExecutionInfo) (commonpb.DataBlob, error)
- func HistoryBranchFromBlob(blob []byte, encoding string) (*persistencespb.HistoryBranch, error)
- func HistoryBranchToBlob(info *persistencespb.HistoryBranch) (commonpb.DataBlob, error)
- func HistoryTreeInfoFromBlob(blob []byte, encoding string) (*persistencespb.HistoryTreeInfo, error)
- func HistoryTreeInfoToBlob(info *persistencespb.HistoryTreeInfo) (commonpb.DataBlob, error)
- func NamespaceDetailFromBlob(blob []byte, encoding string) (*persistencespb.NamespaceDetail, error)
- func NamespaceDetailToBlob(info *persistencespb.NamespaceDetail) (commonpb.DataBlob, error)
- func QueueMetadataFromBlob(blob []byte, encoding string) (*persistencespb.QueueMetadata, error)
- func QueueMetadataToBlob(metadata *persistencespb.QueueMetadata) (commonpb.DataBlob, error)
- func ReplicationTaskFromBlob(blob []byte, encoding string) (*replicationspb.ReplicationTask, error)
- func ReplicationTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.ReplicationTaskInfo, error)
- func ReplicationTaskInfoToBlob(info *persistencespb.ReplicationTaskInfo) (commonpb.DataBlob, error)
- func ReplicationTaskToBlob(replicationTask *replicationspb.ReplicationTask) (commonpb.DataBlob, error)
- func RequestCancelInfoFromBlob(blob []byte, encoding string) (*persistencespb.RequestCancelInfo, error)
- func RequestCancelInfoToBlob(info *persistencespb.RequestCancelInfo) (commonpb.DataBlob, error)
- func ShardInfoFromBlob(blob []byte, encoding string, clusterName string) (*persistencespb.ShardInfo, error)
- func ShardInfoToBlob(info *persistencespb.ShardInfo) (commonpb.DataBlob, error)
- func SignalInfoFromBlob(blob []byte, encoding string) (*persistencespb.SignalInfo, error)
- func SignalInfoToBlob(info *persistencespb.SignalInfo) (commonpb.DataBlob, error)
- func TaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.AllocatedTaskInfo, error)
- func TaskInfoToBlob(info *persistencespb.AllocatedTaskInfo) (commonpb.DataBlob, error)
- func TaskQueueInfoFromBlob(blob []byte, encoding string) (*persistencespb.TaskQueueInfo, error)
- func TaskQueueInfoToBlob(info *persistencespb.TaskQueueInfo) (commonpb.DataBlob, error)
- func TimerInfoFromBlob(blob []byte, encoding string) (*persistencespb.TimerInfo, error)
- func TimerInfoToBlob(info *persistencespb.TimerInfo) (commonpb.DataBlob, error)
- func TimerTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.TimerTaskInfo, error)
- func TimerTaskInfoToBlob(info *persistencespb.TimerTaskInfo) (commonpb.DataBlob, error)
- func TransferTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.TransferTaskInfo, error)
- func TransferTaskInfoToBlob(info *persistencespb.TransferTaskInfo) (commonpb.DataBlob, error)
- func VisibilityTaskInfoFromBlob(blob []byte, encoding string) (*persistencespb.VisibilityTaskInfo, error)
- func VisibilityTaskInfoToBlob(info *persistencespb.VisibilityTaskInfo) (commonpb.DataBlob, error)
- func WorkflowExecutionInfoFromBlob(blob []byte, encoding string) (*persistencespb.WorkflowExecutionInfo, error)
- func WorkflowExecutionInfoToBlob(info *persistencespb.WorkflowExecutionInfo) (commonpb.DataBlob, error)
- func WorkflowExecutionStateFromBlob(blob []byte, encoding string) (*persistencespb.WorkflowExecutionState, error)
- func WorkflowExecutionStateToBlob(info *persistencespb.WorkflowExecutionState) (commonpb.DataBlob, error)
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 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)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.