cadence

Documentation

Index

• Constants
• func FirstHistoryEvent(ctx context.Context, cc client.Client, exec *shared.WorkflowExecution) (event *shared.HistoryEvent, err error)
• func HistoryEvents(ctx context.Context, cc client.Client, exec *shared.WorkflowExecution, ...) ([]*shared.HistoryEvent, error)
• func NewDomainClient(logger *zap.Logger, appName string, config Config) (client.DomainClient, error)
• func NewWorker(logger *zap.Logger, appName string, config Config) (worker.Worker, error)
• func NewWorkflowClient(logger *zap.Logger, appName string, config Config) (client.Client, error)
• func RegisterActivity(activityFunc interface{}, name string)
• func RegisterWorkflow(workflowFunc interface{}, name string)
• type Config

Constants

const (
	// This is the task list name we use to identify our global client worker.
	// It also identifies the group of workflow and activity implementations
	// that are hosted by a single worker process.
	GlobalTaskListName = "global"
)

Functions

func FirstHistoryEvent

func FirstHistoryEvent(ctx context.Context, cc client.Client, exec *shared.WorkflowExecution) (event *shared.HistoryEvent, err error)

func HistoryEvents

func HistoryEvents(ctx context.Context, cc client.Client, exec *shared.WorkflowExecution, poll bool) ([]*shared.HistoryEvent, error)

func NewDomainClient

func NewDomainClient(logger *zap.Logger, appName string, config Config) (client.DomainClient, error)

NewDomainClient returns a Cadence Domain client.

func NewWorker

func NewWorker(logger *zap.Logger, appName string, config Config) (worker.Worker, error)

func NewWorkflowClient

func NewWorkflowClient(logger *zap.Logger, appName string, config Config) (client.Client, error)

NewWorkflowClient returns a new Cadence client.

func RegisterActivity

func RegisterActivity(activityFunc interface{}, name string)

func RegisterWorkflow

func RegisterWorkflow(workflowFunc interface{}, name string)

Types

type Config

type Config struct {
	Domain  string
	Address string
}