service

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 10, 2022 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL