serialization

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)
  • func (d *DataBlob) ToProto() *commonpb.DataBlob

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 ShardInfoFromBlob(b []byte, proto string, clusterName string) (*persistenceblobs.ShardInfo, error)

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

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

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)

func (*DataBlob) ToProto

func (d *DataBlob) ToProto() *commonpb.DataBlob

ToProto convert data blob to proto representation