Affected by GO-2023-1879 and 1 other vulnerabilities

GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

serialization

package

v1.9.0 Latest Latest Go to latest Published: Apr 27, 2021 License: MIT Imports: 9 Imported by: 5

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/temporalio/temporal

Links

Open Source Insights

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 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)

Types ¶

This section is empty.

Source Files ¶

View all Source files

blob.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL