akmod

Documentation

Index

• Constants
• Variables
• func New(l L.L, stateStore statestore.Store, project *apiproject.Project, ...) *builtinplugin.BuiltinPlugin
• func NewSyntheticEvent(origEvent *apievent.Event, name string, v *apivalues.Value) *sessionEventSignal
• func WithSessionContext(ctx context.Context, s *Session) context.Context
• type Session

Constants

const SessionEventSignalName = "wait_event"

Variables

var PluginID = apiplugin.NewInternalPluginID("ak")

Functions

func New

func New(
	l L.L,
	stateStore statestore.Store,
	project *apiproject.Project,
	event *apievent.Event,
	getSecret_ func(context.Context, string) (string, error),
	getCred_ func(context.Context, string, string) ([]byte, error),
	bindingName string,
	version string,
) *builtinplugin.BuiltinPlugin

func NewSyntheticEvent

func NewSyntheticEvent(origEvent *apievent.Event, name string, v *apivalues.Value) *sessionEventSignal

func WithSessionContext

func WithSessionContext(ctx context.Context, s *Session) context.Context

Types

type Session

type Session struct {
	Context        workflow.Context
	UpdateState    func(*apievent.ProjectEventState) error
	SignalChannel  workflow.ReceiveChannel
	L              L.L
	RunSummary     *apilang.RunSummary
	Temporal       temporalclient.Client
	ProjectID      apiproject.ProjectID
	Event          *apievent.Event
	SrcBindingName string
}