event

Documentation

Index

• type Controller
  • func NewController(instanceIDService instanceid.Service, ...) *Controller
  • func (s *Controller) ListWorkflowEventBindings(ctx context.Context, in *eventpkg.ListWorkflowEventBindingsRequest) (*wfv1.WorkflowEventBindingList, error)
  • func (s *Controller) ReceiveEvent(ctx context.Context, req *eventpkg.EventRequest) (*eventpkg.EventResponse, error)
  • func (s *Controller) Run(stopCh <-chan struct{})

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

func NewController

func NewController(instanceIDService instanceid.Service, eventRecorderManager events.EventRecorderManager, operationQueueSize, workerCount int, asyncDispatch bool) *Controller

func (*Controller) ListWorkflowEventBindings

func (s *Controller) ListWorkflowEventBindings(ctx context.Context, in *eventpkg.ListWorkflowEventBindingsRequest) (*wfv1.WorkflowEventBindingList, error)

func (*Controller) ReceiveEvent

func (s *Controller) ReceiveEvent(ctx context.Context, req *eventpkg.EventRequest) (*eventpkg.EventResponse, error)

func (*Controller) Run

func (s *Controller) Run(stopCh <-chan struct{})