Affected by 
Documentation
¶
Index ¶
- func ActivityInfoFromBlob(b []byte, proto string) (*persistenceblobs.ActivityInfo, error)
- func ChecksumFromBlob(b []byte, proto string) (*persistenceblobs.Checksum, error)
- func ChildExecutionInfoFromBlob(b []byte, proto string) (*persistenceblobs.ChildExecutionInfo, error)
- func HistoryBranchFromBlob(b []byte, proto string) (*persistenceblobs.HistoryBranch, error)
- func HistoryTreeInfoFromBlob(b []byte, proto string) (*persistenceblobs.HistoryTreeInfo, error)
- func NamespaceDetailFromBlob(b []byte, proto string) (*persistenceblobs.NamespaceDetail, error)
- func ReplicationTaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.ReplicationTaskInfo, error)
- func ReplicationVersionsFromBlob(b []byte, proto string) (*persistenceblobs.ReplicationVersions, error)
- func RequestCancelInfoFromBlob(b []byte, proto string) (*persistenceblobs.RequestCancelInfo, error)
- func ShardInfoFromBlob(b []byte, proto string, clusterName string) (*persistenceblobs.ShardInfo, error)
- func SignalInfoFromBlob(b []byte, proto string) (*persistenceblobs.SignalInfo, error)
- func TaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.AllocatedTaskInfo, error)
- func TaskQueueInfoFromBlob(b []byte, proto string) (*persistenceblobs.TaskQueueInfo, error)
- func TimerInfoFromBlob(b []byte, proto string) (*persistenceblobs.TimerInfo, error)
- func TimerTaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.TimerTaskInfo, error)
- func TransferTaskInfoFromBlob(b []byte, proto string) (*persistenceblobs.TransferTaskInfo, error)
- func VersionHistoriesFromBlob(b []byte, proto string) (*historyspb.VersionHistories, error)
- func WorkflowExecutionInfoFromBlob(b []byte, proto string) (*persistenceblobs.WorkflowExecutionInfo, error)
- func WorkflowExecutionStateFromBlob(b []byte, proto string) (*persistenceblobs.WorkflowExecutionState, error)
- type DataBlob
- func ActivityInfoToBlob(info *persistenceblobs.ActivityInfo) (DataBlob, error)
- func ChecksumToBlob(info *persistenceblobs.Checksum) (DataBlob, error)
- func ChildExecutionInfoToBlob(info *persistenceblobs.ChildExecutionInfo) (DataBlob, error)
- func HistoryBranchToBlob(info *persistenceblobs.HistoryBranch) (DataBlob, error)
- func HistoryTreeInfoToBlob(info *persistenceblobs.HistoryTreeInfo) (DataBlob, error)
- func NamespaceDetailToBlob(info *persistenceblobs.NamespaceDetail) (DataBlob, error)
- func ReplicationTaskInfoToBlob(info *persistenceblobs.ReplicationTaskInfo) (DataBlob, error)
- func ReplicationVersionsToBlob(info *persistenceblobs.ReplicationVersions) (DataBlob, error)
- func RequestCancelInfoToBlob(info *persistenceblobs.RequestCancelInfo) (DataBlob, error)
- func ShardInfoToBlob(info *persistenceblobs.ShardInfo) (DataBlob, error)
- func SignalInfoToBlob(info *persistenceblobs.SignalInfo) (DataBlob, error)
- func TaskInfoToBlob(info *persistenceblobs.AllocatedTaskInfo) (DataBlob, error)
- func TaskQueueInfoToBlob(info *persistenceblobs.TaskQueueInfo) (DataBlob, error)
- func TimerInfoToBlob(info *persistenceblobs.TimerInfo) (DataBlob, error)
- func TimerTaskInfoToBlob(info *persistenceblobs.TimerTaskInfo) (DataBlob, error)
- func TransferTaskInfoToBlob(info *persistenceblobs.TransferTaskInfo) (DataBlob, error)
- func VersionHistoriesToBlob(info *historyspb.VersionHistories) (DataBlob, error)
- func WorkflowExecutionInfoToBlob(info *persistenceblobs.WorkflowExecutionInfo) (DataBlob, error)
- func WorkflowExecutionStateToBlob(info *persistenceblobs.WorkflowExecutionState) (DataBlob, error)
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 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)
Source Files
Click to show internal directories.
Click to hide internal directories.