evstepfunc

Documentation

Index

• func NewPollCreator(es v1.EventSource, awsSession *session.Session, gateway http.Handler) (evsource.PollCreator, error)
• type StepFuncPollCreator
  • func (s *StepFuncPollCreator) ComponentName() string
  • func (s *StepFuncPollCreator) MaxConcurrency() int
  • func (s *StepFuncPollCreator) MaxConcurrencyPerPoller() int
  • func (s *StepFuncPollCreator) NewPoller() evsource.Poller
  • func (s *StepFuncPollCreator) RoleIdPrefix() string
• type StepFuncPoller
  • func (s *StepFuncPoller) Run(ctx context.Context, concurrency int, roleId string)

Functions

func NewPollCreator

func NewPollCreator(es v1.EventSource, awsSession *session.Session, gateway http.Handler) (evsource.PollCreator, error)

Types

type StepFuncPollCreator

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

func (*StepFuncPollCreator) ComponentName

func (s *StepFuncPollCreator) ComponentName() string

func (*StepFuncPollCreator) MaxConcurrency

func (s *StepFuncPollCreator) MaxConcurrency() int

func (*StepFuncPollCreator) MaxConcurrencyPerPoller

func (s *StepFuncPollCreator) MaxConcurrencyPerPoller() int

func (*StepFuncPollCreator) NewPoller

func (s *StepFuncPollCreator) NewPoller() evsource.Poller

func (*StepFuncPollCreator) RoleIdPrefix

func (s *StepFuncPollCreator) RoleIdPrefix() string

type StepFuncPoller

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

func (*StepFuncPoller) Run

func (s *StepFuncPoller) Run(ctx context.Context, concurrency int, roleId string)