Documentation ¶
Index ¶
- func ActivityInfoFromBlob(b []byte, proto string) (*persistencespb.ActivityInfo, error)
- func ActivityInfoToBlob(info *persistencespb.ActivityInfo) (commonpb.DataBlob, error)
- func ChecksumFromBlob(b []byte, proto string) (*persistencespb.Checksum, error)
- func ChecksumToBlob(checksum *persistencespb.Checksum) (commonpb.DataBlob, error)
- func ChildExecutionInfoFromBlob(b []byte, proto string) (*persistencespb.ChildExecutionInfo, error)
- func ChildExecutionInfoToBlob(info *persistencespb.ChildExecutionInfo) (commonpb.DataBlob, error)
- func HistoryBranchFromBlob(b []byte, proto string) (*persistencespb.HistoryBranch, error)
- func HistoryBranchToBlob(info *persistencespb.HistoryBranch) (commonpb.DataBlob, error)
- func HistoryTreeInfoFromBlob(b []byte, proto string) (*persistencespb.HistoryTreeInfo, error)
- func HistoryTreeInfoToBlob(info *persistencespb.HistoryTreeInfo) (commonpb.DataBlob, error)
- func NamespaceDetailFromBlob(b []byte, proto string) (*persistencespb.NamespaceDetail, error)
- func NamespaceDetailToBlob(info *persistencespb.NamespaceDetail) (commonpb.DataBlob, error)
- func ReplicationTaskInfoFromBlob(b []byte, proto string) (*persistencespb.ReplicationTaskInfo, error)
- func ReplicationTaskInfoToBlob(info *persistencespb.ReplicationTaskInfo) (commonpb.DataBlob, error)
- func ReplicationVersionsFromBlob(b []byte, proto string) (*persistencespb.ReplicationVersions, error)
- func ReplicationVersionsToBlob(info *persistencespb.ReplicationVersions) (commonpb.DataBlob, error)
- func RequestCancelInfoFromBlob(b []byte, proto string) (*persistencespb.RequestCancelInfo, error)
- func RequestCancelInfoToBlob(info *persistencespb.RequestCancelInfo) (commonpb.DataBlob, error)
- func ShardInfoFromBlob(b []byte, proto string, clusterName string) (*persistencespb.ShardInfo, error)
- func ShardInfoToBlob(info *persistencespb.ShardInfo) (commonpb.DataBlob, error)
- func SignalInfoFromBlob(b []byte, proto string) (*persistencespb.SignalInfo, error)
- func SignalInfoToBlob(info *persistencespb.SignalInfo) (commonpb.DataBlob, error)
- func TaskInfoFromBlob(b []byte, proto string) (*persistencespb.AllocatedTaskInfo, error)
- func TaskInfoToBlob(info *persistencespb.AllocatedTaskInfo) (commonpb.DataBlob, error)
- func TaskQueueInfoFromBlob(b []byte, proto string) (*persistencespb.TaskQueueInfo, error)
- func TaskQueueInfoToBlob(info *persistencespb.TaskQueueInfo) (commonpb.DataBlob, error)
- func TimerInfoFromBlob(b []byte, proto string) (*persistencespb.TimerInfo, error)
- func TimerInfoToBlob(info *persistencespb.TimerInfo) (commonpb.DataBlob, error)
- func TimerTaskInfoFromBlob(b []byte, proto string) (*persistencespb.TimerTaskInfo, error)
- func TimerTaskInfoToBlob(info *persistencespb.TimerTaskInfo) (commonpb.DataBlob, error)
- func TransferTaskInfoFromBlob(b []byte, proto string) (*persistencespb.TransferTaskInfo, error)
- func TransferTaskInfoToBlob(info *persistencespb.TransferTaskInfo) (commonpb.DataBlob, error)
- func WorkflowExecutionInfoFromBlob(b []byte, proto string) (*persistencespb.WorkflowExecutionInfo, error)
- func WorkflowExecutionInfoToBlob(info *persistencespb.WorkflowExecutionInfo) (commonpb.DataBlob, error)
- func WorkflowExecutionStateFromBlob(b []byte, proto 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(b []byte, proto string) (*persistencespb.ActivityInfo, error)
func ActivityInfoToBlob ¶
func ActivityInfoToBlob(info *persistencespb.ActivityInfo) (commonpb.DataBlob, error)
func ChecksumFromBlob ¶
func ChecksumFromBlob(b []byte, proto string) (*persistencespb.Checksum, error)
func ChecksumToBlob ¶
func ChecksumToBlob(checksum *persistencespb.Checksum) (commonpb.DataBlob, error)
func ChildExecutionInfoFromBlob ¶
func ChildExecutionInfoFromBlob(b []byte, proto string) (*persistencespb.ChildExecutionInfo, error)
func ChildExecutionInfoToBlob ¶
func ChildExecutionInfoToBlob(info *persistencespb.ChildExecutionInfo) (commonpb.DataBlob, error)
func HistoryBranchFromBlob ¶
func HistoryBranchFromBlob(b []byte, proto string) (*persistencespb.HistoryBranch, error)
func HistoryBranchToBlob ¶
func HistoryBranchToBlob(info *persistencespb.HistoryBranch) (commonpb.DataBlob, error)
func HistoryTreeInfoFromBlob ¶
func HistoryTreeInfoFromBlob(b []byte, proto string) (*persistencespb.HistoryTreeInfo, error)
func HistoryTreeInfoToBlob ¶
func HistoryTreeInfoToBlob(info *persistencespb.HistoryTreeInfo) (commonpb.DataBlob, error)
func NamespaceDetailFromBlob ¶
func NamespaceDetailFromBlob(b []byte, proto string) (*persistencespb.NamespaceDetail, error)
func NamespaceDetailToBlob ¶
func NamespaceDetailToBlob(info *persistencespb.NamespaceDetail) (commonpb.DataBlob, error)
func ReplicationTaskInfoFromBlob ¶
func ReplicationTaskInfoFromBlob(b []byte, proto string) (*persistencespb.ReplicationTaskInfo, error)
func ReplicationTaskInfoToBlob ¶
func ReplicationTaskInfoToBlob(info *persistencespb.ReplicationTaskInfo) (commonpb.DataBlob, error)
func ReplicationVersionsFromBlob ¶
func ReplicationVersionsFromBlob(b []byte, proto string) (*persistencespb.ReplicationVersions, error)
func ReplicationVersionsToBlob ¶
func ReplicationVersionsToBlob(info *persistencespb.ReplicationVersions) (commonpb.DataBlob, error)
func RequestCancelInfoFromBlob ¶
func RequestCancelInfoFromBlob(b []byte, proto 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(b []byte, proto string) (*persistencespb.SignalInfo, error)
func SignalInfoToBlob ¶
func SignalInfoToBlob(info *persistencespb.SignalInfo) (commonpb.DataBlob, error)
func TaskInfoFromBlob ¶
func TaskInfoFromBlob(b []byte, proto string) (*persistencespb.AllocatedTaskInfo, error)
func TaskInfoToBlob ¶
func TaskInfoToBlob(info *persistencespb.AllocatedTaskInfo) (commonpb.DataBlob, error)
func TaskQueueInfoFromBlob ¶
func TaskQueueInfoFromBlob(b []byte, proto string) (*persistencespb.TaskQueueInfo, error)
func TaskQueueInfoToBlob ¶
func TaskQueueInfoToBlob(info *persistencespb.TaskQueueInfo) (commonpb.DataBlob, error)
func TimerInfoFromBlob ¶
func TimerInfoFromBlob(b []byte, proto string) (*persistencespb.TimerInfo, error)
func TimerInfoToBlob ¶
func TimerInfoToBlob(info *persistencespb.TimerInfo) (commonpb.DataBlob, error)
func TimerTaskInfoFromBlob ¶
func TimerTaskInfoFromBlob(b []byte, proto string) (*persistencespb.TimerTaskInfo, error)
func TimerTaskInfoToBlob ¶
func TimerTaskInfoToBlob(info *persistencespb.TimerTaskInfo) (commonpb.DataBlob, error)
func TransferTaskInfoFromBlob ¶
func TransferTaskInfoFromBlob(b []byte, proto string) (*persistencespb.TransferTaskInfo, error)
func TransferTaskInfoToBlob ¶
func TransferTaskInfoToBlob(info *persistencespb.TransferTaskInfo) (commonpb.DataBlob, error)
func WorkflowExecutionInfoFromBlob ¶
func WorkflowExecutionInfoFromBlob(b []byte, proto string) (*persistencespb.WorkflowExecutionInfo, error)
func WorkflowExecutionInfoToBlob ¶
func WorkflowExecutionInfoToBlob(info *persistencespb.WorkflowExecutionInfo) (commonpb.DataBlob, error)
func WorkflowExecutionStateFromBlob ¶
func WorkflowExecutionStateFromBlob(b []byte, proto 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.