service

Documentation

Index

• type Notification
• type NotificationTypeEnum
• type Service
  • func NewService(config *config.Config, logger log.Logger, metricScope tally.Scope) (*Service, error)
  • func (s *Service) Start()
  • func (s *Service) Stop()

Types

type Notification

type Notification struct {
	ID               string
	NotificationType NotificationTypeEnum
	// TODO: replace with domainName, need to pass by Cadence server
	DomainID         string
	WorkflowID       string
	RunID            string
	WorkflowType     string
	StartedTimestamp time.Time
	ClosedTimestamp  time.Time
	SearchAttributes map[string]interface{}
	Memo             map[string]interface{}
}

type NotificationTypeEnum

type NotificationTypeEnum string

const (
	NotificationTypeWorkflowStarted                NotificationTypeEnum = "workflowStarted"
	NotificationTypeWorkflowClosed                 NotificationTypeEnum = "workflowClosed"
	NotificationTypeWorkflowUpsertSearchAttributes NotificationTypeEnum = "upsertSearchAttributes"
)

type Service

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

Service represents the cadence notification service. This service hosts background processing for delivering notifications

func NewService

func NewService(
	config *config.Config,
	logger log.Logger,
	metricScope tally.Scope,
) (*Service, error)

NewService builds a new cadence-worker service

func (*Service) Start

func (s *Service) Start()

Start is called to start the service

func (*Service) Stop

func (s *Service) Stop()

Stop is called to stop the service