roadrunner_temporal

Feb 29, 2024

Changes in this version

type Plugin

+ func (p *Plugin) Ready() (*status.Status, error)

+ func (p *Plugin) Status() (*status.Status, error)

Oct 5, 2023

Changes in this version

type Plugin

+ func (p *Plugin) AddWorker() error

+ func (p *Plugin) RemoveWorker(ctx context.Context) error

Feb 6, 2023

Changes in this version

type Plugin

+ func (p *Plugin) Collects() []*dep.In

Jan 10, 2023

Changes in this version

+ const MetricsTypeSummary

+ const PluginName

+ const RrCodec

+ const RrCodecVal

+ const RrMode

+ func ActivitiesInfo(wi []*internal.WorkerInfo) map[string]*internal.ActivityInfo

+ func WorkerInfo(c common.Codec, p common.Pool, rrVersion string) ([]*internal.WorkerInfo, error)

+ func WorkflowsInfo(wi []*internal.WorkerInfo) map[string]*internal.WorkflowInfo

+ type ClientAuthType string

+ const NoClientCert

+ const RequestClientCert

+ const RequireAndVerifyClientCert

+ const RequireAnyClientCert

+ const VerifyClientCertIfGiven

+ type Config struct

+ Activities *pool.Config

+ Address string

+ CacheSize int

+ Metrics *Metrics

+ Namespace string

+ TLS *TLS

+ func (c *Config) InitDefault() error

+ type Informer interface

+ Workers func() []*process.State

+ type Logger interface

+ NamedLogger func(name string) *zap.Logger

+ type Metrics struct

+ Driver string

+ Prometheus *Prometheus

+ Statsd *Statsd

+ type Plugin struct

+ func (p *Plugin) Init(cfg common.Configurer, log Logger, server common.Server) error

+ func (p *Plugin) MetricsCollector() []prom.Collector

+ func (p *Plugin) Name() string

+ func (p *Plugin) RPC() any

+ func (p *Plugin) Reset() error

+ func (p *Plugin) ResetAP() error

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

+ func (p *Plugin) Stop(context.Context) error

+ func (p *Plugin) Workers() []*process.State

+ type Prometheus struct

+ Address string

+ Prefix string

+ Type string

+ type RecordHeartbeatRequest struct

+ Details []byte

+ TaskToken []byte

+ type RecordHeartbeatResponse struct

+ Canceled bool

+ type Statsd struct

+ FlushBytes int

+ FlushInterval time.Duration

+ HostPort string

+ Prefix string

+ TagPrefix string

+ TagSeparator string

+ Tags map[string]string

+ type StatsdReporterConfig struct

+ TagSeparator string

+ type TLS struct

+ AuthType ClientAuthType

+ Cert string

+ Key string

+ RootCA string

+ ServerName string