Documentation
¶
Index ¶
Constants ¶
View Source
const ( MetadataEncodingKey = "encoding" MetadataEncodingType = "nuon/signal" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PayloadConverter ¶
type PayloadConverter struct{}
func NewPayloadConverter ¶
func NewPayloadConverter() *PayloadConverter
func (*PayloadConverter) Encoding ¶
func (c *PayloadConverter) Encoding() string
func (*PayloadConverter) FromPayload ¶
func (c *PayloadConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error
type SignalData ¶
func (SignalData) GormDataType ¶
func (SignalData) GormDataType() string
func (SignalData) MarshalJSON ¶ added in v0.19.850
func (s SignalData) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler so that standard JSON serialization (used by temporaljson and Temporal data converters) includes the type discriminator.
func (*SignalData) Scan ¶
func (s *SignalData) Scan(value interface{}) error
func (*SignalData) UnmarshalJSON ¶ added in v0.19.850
func (s *SignalData) UnmarshalJSON(data []byte) error
UnmarshalJSON implements json.Unmarshaler so that standard JSON deserialization (used by temporaljson and Temporal data converters) can reconstruct the typed signal from the {type, data} wire format using the catalog.
type WorkflowRef ¶
type WorkflowRef struct {
IDTemplate string `json:"-"`
Namespace string `json:"namespace"`
ID string `json:"id"`
}
func (WorkflowRef) GormDataType ¶
func (WorkflowRef) GormDataType() string
func (*WorkflowRef) Scan ¶
func (s *WorkflowRef) Scan(value interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.