serialization

Documentation

Index

• type Parser
  • func NewParser(encodingType common.EncodingType, decodingTypes ...common.EncodingType) (Parser, error)

Types

type Parser

type Parser interface {
	ShardInfoToBlob(*sqlblobs.ShardInfo) (persistence.DataBlob, error)
	DomainInfoToBlob(*sqlblobs.DomainInfo) (persistence.DataBlob, error)
	HistoryTreeInfoToBlob(*sqlblobs.HistoryTreeInfo) (persistence.DataBlob, error)
	WorkflowExecutionInfoToBlob(*sqlblobs.WorkflowExecutionInfo) (persistence.DataBlob, error)
	ActivityInfoToBlob(*sqlblobs.ActivityInfo) (persistence.DataBlob, error)
	ChildExecutionInfoToBlob(*sqlblobs.ChildExecutionInfo) (persistence.DataBlob, error)
	SignalInfoToBlob(*sqlblobs.SignalInfo) (persistence.DataBlob, error)
	RequestCancelInfoToBlob(*sqlblobs.RequestCancelInfo) (persistence.DataBlob, error)
	TimerInfoToBlob(*sqlblobs.TimerInfo) (persistence.DataBlob, error)
	TaskInfoToBlob(*sqlblobs.TaskInfo) (persistence.DataBlob, error)
	TaskListInfoToBlob(*sqlblobs.TaskListInfo) (persistence.DataBlob, error)
	TransferTaskInfoToBlob(*sqlblobs.TransferTaskInfo) (persistence.DataBlob, error)
	TimerTaskInfoToBlob(*sqlblobs.TimerTaskInfo) (persistence.DataBlob, error)
	ReplicationTaskInfoToBlob(*sqlblobs.ReplicationTaskInfo) (persistence.DataBlob, error)

	ShardInfoFromBlob([]byte, string) (*sqlblobs.ShardInfo, error)
	DomainInfoFromBlob([]byte, string) (*sqlblobs.DomainInfo, error)
	HistoryTreeInfoFromBlob([]byte, string) (*sqlblobs.HistoryTreeInfo, error)
	WorkflowExecutionInfoFromBlob([]byte, string) (*sqlblobs.WorkflowExecutionInfo, error)
	ActivityInfoFromBlob([]byte, string) (*sqlblobs.ActivityInfo, error)
	ChildExecutionInfoFromBlob([]byte, string) (*sqlblobs.ChildExecutionInfo, error)
	SignalInfoFromBlob([]byte, string) (*sqlblobs.SignalInfo, error)
	RequestCancelInfoFromBlob([]byte, string) (*sqlblobs.RequestCancelInfo, error)
	TimerInfoFromBlob([]byte, string) (*sqlblobs.TimerInfo, error)
	TaskInfoFromBlob([]byte, string) (*sqlblobs.TaskInfo, error)
	TaskListInfoFromBlob([]byte, string) (*sqlblobs.TaskListInfo, error)
	TransferTaskInfoFromBlob([]byte, string) (*sqlblobs.TransferTaskInfo, error)
	TimerTaskInfoFromBlob([]byte, string) (*sqlblobs.TimerTaskInfo, error)
	ReplicationTaskInfoFromBlob([]byte, string) (*sqlblobs.ReplicationTaskInfo, error)
}

Parser is used to do serialization and deserialization. A parser is backed by a a single encoder which encodes into one format and a collection of decoders. Parser selects the appropriate decoder for the provided blob.

func NewParser

func NewParser(encodingType common.EncodingType, decodingTypes ...common.EncodingType) (Parser, error)

NewParser constructs a new parser using encoder as specified by encodingType and using decoders specified by decodingTypes