cadence

Documentation

Index

• func NewClient(config Config, logger *zap.Logger) (client.Client, error)
• func NewWorker(config Config, taskList string, logger *zap.Logger) (worker.Worker, error)
• type Config
  • func (c Config) Addr() string
  • func (c Config) Validate() error

Functions

func NewClient

func NewClient(config Config, logger *zap.Logger) (client.Client, error)

NewClient returns a new Cadence client.

func NewWorker

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

NewWorker returns a new Cadence worker.

Types

type Config

type Config struct {
	// Cadence connection details
	Host string
	Port int

	Domain                                 string
	WorkflowExecutionRetentionPeriodInDays int32
	CreateNonexistentDomain                bool

	// Client identity (not used for now; falls back to machine host name)
	Identity string
}

Config holds information necessary for connecting to Cadence.

func (Config) Addr

func (c Config) Addr() string

Addr returns the Cadence connection address.

func (Config) Validate

func (c Config) Validate() error

Validate checks that the configuration is valid.