signaldb

package
v0.19.786 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 13, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

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

func (*PayloadConverter) ToPayload

func (c *PayloadConverter) ToPayload(value interface{}) (*commonpb.Payload, error)

func (*PayloadConverter) ToString

func (c *PayloadConverter) ToString(payload *commonpb.Payload) string

type SignalData

type SignalData struct {
	Signal signal.Signal
}

func (SignalData) GormDataType

func (SignalData) GormDataType() string

func (*SignalData) Scan

func (s *SignalData) Scan(value interface{}) error

func (SignalData) Value

func (s SignalData) Value() (driver.Value, error)

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

func (WorkflowRef) Value

func (s WorkflowRef) Value() (driver.Value, error)

Jump to

Keyboard shortcuts

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