client

Sep 2, 2021

Changes in this version

+ const MetricsTypeSummary

type Config

+ Metrics *Metrics

+ func (c *Config) InitDefault()

+ type Metrics struct

+ Address string

+ Prefix string

+ Type string

Mar 2, 2021

Changes in this version

+ const PluginName

+ type Config struct

+ Activities *pool.Config

+ Address string

+ CacheSize int

+ Codec string

+ DebugLevel int

+ Namespace string

+ type Plugin struct

+ func (p *Plugin) CreateWorker(tq string, options worker.Options) (worker.Worker, error)

+ func (p *Plugin) GetClient() client.Client

+ func (p *Plugin) GetCodec() rrt.Codec

+ func (p *Plugin) GetConfig() Config

+ func (p *Plugin) GetDataConverter() converter.DataConverter

+ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error

+ func (p *Plugin) Name() string

+ func (p *Plugin) Serve() chan error

+ func (p *Plugin) Stop() error

+ type Temporal interface

+ CreateWorker func(taskQueue string, options worker.Options) (worker.Worker, error)

+ GetClient func() client.Client

+ GetCodec func() rrt.Codec

+ GetConfig func() Config

+ GetDataConverter func() converter.DataConverter