notification

Documentation

Index

• func NewService(gateways map[string]gateway.Notification) (service.Notification, error)
• type Service
  • func (s *Service) ListNotifiers(ctx context.Context) []*notification.Notifier
  • func (s *Service) NotifyExecutionCompletion(ctx context.Context, e workflow.ExecutionIdentifier, w workflow.WorkflowName, ...) error

Functions

func NewService

func NewService(gateways map[string]gateway.Notification) (service.Notification, error)

Types

type Service

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

func (*Service) ListNotifiers

func (s *Service) ListNotifiers(ctx context.Context) []*notification.Notifier

func (*Service) NotifyExecutionCompletion

func (s *Service) NotifyExecutionCompletion(ctx context.Context, e workflow.ExecutionIdentifier, w workflow.WorkflowName, status workflow.Status, results workflow.ExecutionResult) error