dispatcher

Documentation

Index

• type FanOutDispatcher
  • func New(integrationUC *biz.IntegrationUseCase, wfUC *biz.WorkflowUseCase, ...) *FanOutDispatcher
  • func (d *FanOutDispatcher) Run(ctx context.Context, opts *RunOpts) error
• type RunOpts

Types

type FanOutDispatcher

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

func New

func New(integrationUC *biz.IntegrationUseCase, wfUC *biz.WorkflowUseCase, wfRunUC *biz.WorkflowRunUseCase, creds credentials.ReaderWriter, c biz.CASClient, registered sdk.AvailablePlugins, l log.Logger) *FanOutDispatcher

func (*FanOutDispatcher) Run

func (d *FanOutDispatcher) Run(ctx context.Context, opts *RunOpts) error

type RunOpts

type RunOpts struct {
	Envelope            *dsse.Envelope
	OrgID               string
	WorkflowID          string
	WorkflowRunID       string
	DownloadBackendType string
	DownloadSecretName  string
}