Documentation
¶
Index ¶
- func NewActivityTaskToken(namespaceID string, workflowID string, runID string, scheduledEventID int64, ...) *tokenspb.Task
- func NewWorkflowTaskToken(namespaceID string, workflowID string, runID string, scheduledEventID int64, ...) *tokenspb.Task
- type Serializer
- func (s *Serializer) Deserialize(data []byte) (*tokenspb.Task, error)
- func (s *Serializer) DeserializeChasmComponentRef(data []byte) (*persistencespb.ChasmComponentRef, error)
- func (s *Serializer) DeserializeNexusTaskToken(data []byte) (*tokenspb.NexusTask, error)
- func (s *Serializer) DeserializeQueryTaskToken(data []byte) (*tokenspb.QueryTask, error)
- func (s *Serializer) Serialize(taskToken *tokenspb.Task) ([]byte, error)
- func (s *Serializer) SerializeNexusTaskToken(taskToken *tokenspb.NexusTask) ([]byte, error)
- func (s *Serializer) SerializeQueryTaskToken(taskToken *tokenspb.QueryTask) ([]byte, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewActivityTaskToken ¶
func NewWorkflowTaskToken ¶
Types ¶
type Serializer ¶
type Serializer struct{}
func NewSerializer ¶
func NewSerializer() *Serializer
NewSerializer creates a new instance of Serializer
func (*Serializer) Deserialize ¶
func (s *Serializer) Deserialize(data []byte) (*tokenspb.Task, error)
func (*Serializer) DeserializeChasmComponentRef ¶
func (s *Serializer) DeserializeChasmComponentRef(data []byte) (*persistencespb.ChasmComponentRef, error)
func (*Serializer) DeserializeNexusTaskToken ¶
func (s *Serializer) DeserializeNexusTaskToken(data []byte) (*tokenspb.NexusTask, error)
func (*Serializer) DeserializeQueryTaskToken ¶
func (s *Serializer) DeserializeQueryTaskToken(data []byte) (*tokenspb.QueryTask, error)
func (*Serializer) Serialize ¶
func (s *Serializer) Serialize(taskToken *tokenspb.Task) ([]byte, error)
func (*Serializer) SerializeNexusTaskToken ¶
func (s *Serializer) SerializeNexusTaskToken(taskToken *tokenspb.NexusTask) ([]byte, error)
func (*Serializer) SerializeQueryTaskToken ¶
func (s *Serializer) SerializeQueryTaskToken(taskToken *tokenspb.QueryTask) ([]byte, error)
Source Files
Click to show internal directories.
Click to hide internal directories.