Documentation ¶
Index ¶
- func ConvertFromProto(data map[string]*structpb.Value) map[string]any
- func ConvertMapToStructPb(data map[string]any) *structpb.Value
- func ConvertToProto(data map[string]any) map[string]*structpb.Value
- func ResolveInputParams(flowContext *model.FlowContext, inputParams map[string]any) map[string]any
- func Shuffle(in []int)
- type Action
- type EncoderDecoder
- type JsonEncDec
- type TickWorker
- type Worker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ResolveInputParams ¶
Types ¶
type EncoderDecoder ¶
type JsonEncDec ¶
type JsonEncDec[T any] struct{}
func NewJsonEncoderDecoder ¶
func NewJsonEncoderDecoder[T any]() *JsonEncDec[T]
func (*JsonEncDec[T]) Decode ¶
func (encdec *JsonEncDec[T]) Decode(data []byte) (*T, error)
func (*JsonEncDec[T]) Encode ¶
func (encdec *JsonEncDec[T]) Encode(value T) ([]byte, error)
type TickWorker ¶
type TickWorker struct {
// contains filtered or unexported fields
}
func NewTickWorker ¶
func (*TickWorker) IsRunning ¶
func (tw *TickWorker) IsRunning() bool
func (*TickWorker) Start ¶
func (tw *TickWorker) Start()
func (*TickWorker) Stop ¶
func (tw *TickWorker) Stop()
Click to show internal directories.
Click to hide internal directories.