client

Documentation

Index

• Constants
• type Config
  • func (c *Config) InitDefault()
• type Metrics
• type Plugin
  • 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

Constants

const (
	MetricsTypeSummary string = "summary"
)

const PluginName = "temporal"

PluginName defines public service name.

Types

type Config

type Config struct {
	Address    string
	Namespace  string
	Metrics    *Metrics
	Activities *pool.Config
	Codec      string
	DebugLevel int `mapstructure:"debug_level"`
	CacheSize  int `mapstructure:"cache_size"`
}

Config of the temporal client and depended services.

func (*Config) InitDefault

func (c *Config) InitDefault()

type Metrics

type Metrics struct {
	Address string `mapstructure:"address"`
	Type    string `mapstructure:"type"`
	Prefix  string `mapstructure:"prefix"`
}

type Plugin

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

Plugin implement Temporal contract.

func (*Plugin) CreateWorker

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

CreateWorker allocates new temporal worker on an active connection.

func (*Plugin) GetClient

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

GetClient returns active srv connection.

func (*Plugin) GetCodec

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

GetCodec returns communication codec.

func (*Plugin) GetConfig

func (p *Plugin) GetConfig() Config

GetConfig returns temporal configuration.

func (*Plugin) GetDataConverter

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

GetDataConverter returns data active data converter.

func (*Plugin) Init

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

Init initiates temporal client plugin.

func (*Plugin) Name

func (p *Plugin) Name() string

Name of the service.

func (*Plugin) Serve

func (p *Plugin) Serve() chan error

Serve starts temporal srv.

func (*Plugin) Stop

func (p *Plugin) Stop() error

Stop stops temporal srv connection.

type Temporal

type Temporal interface {
	GetClient() client.Client
	GetDataConverter() converter.DataConverter
	GetConfig() Config
	GetCodec() rrt.Codec
	CreateWorker(taskQueue string, options worker.Options) (worker.Worker, error)
}

Temporal define common interface for RoadRunner plugins.