rrtemporal

type ClientAuthType string

type Config struct {
	Metrics                *Metrics     `mapstructure:"metrics"`
	Activities             *pool.Config `mapstructure:"activities"`
	TLS                    *TLS         `mapstructure:"tls, omitempty"`
	Interceptors           []string     `mapstructure:"interceptors"`
	DataConverters         []string     `mapstructure:"data_converters"`
	DisableActivityWorkers bool         `mapstructure:"disable_activity_workers"`

	Address   string `mapstructure:"address"`
	Namespace string `mapstructure:"namespace"`
	CacheSize int    `mapstructure:"cache_size"`
}

type Informer interface {
	Workers() []*process.State
}

type Logger interface {
	NamedLogger(name string) *zap.Logger
}

type Metrics struct {
	Driver     string      `mapstructure:"driver"`
	Prometheus *Prometheus `mapstructure:"prometheus"`
	Statsd     *Statsd     `mapstructure:"statsd"`
}

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

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

type RecordHeartbeatRequest struct {
	TaskToken []byte `json:"taskToken"`
	Details   []byte `json:"details"`
}

type RecordHeartbeatResponse struct {
	Canceled bool `json:"canceled"`
	Paused   bool `json:"paused"`
}

type StatsExporter struct {
	TotalMemoryDesc  *prom.Desc
	StateDesc        *prom.Desc
	WorkerMemoryDesc *prom.Desc
	TotalWorkersDesc *prom.Desc

	WorkersReady   *prom.Desc
	WorkersWorking *prom.Desc
	WorkersInvalid *prom.Desc

	Workers Informer
}

type Statsd struct {
	// The host and port of the statsd server
	HostPort string `mapstructure:"host_port" validate:"nonzero"`
	// The prefix to use in reporting to statsd
	Prefix string `mapstructure:"prefix" validate:"nonzero"`
	// FlushInterval is the maximum interval for sending packets.
	// If it is not specified, it defaults to 1 second.
	FlushInterval time.Duration `mapstructure:"flush_interval"`
	// FlushBytes specifies the maximum udp packet size you wish to send.
	// If FlushBytes is unspecified, it defaults  to 1432 bytes, which is
	// considered safe for local traffic.
	FlushBytes int `mapstructure:"flush_bytes"`
	// Tags to pass to the Tally scope options
	Tags map[string]string `mapstructure:"tags"`
	// TagPrefix ...
	TagPrefix string `mapstructure:"tag_prefix"`
	// TagSeparator allows tags to be appended with a separator. If not specified tag keys and values
	// are embedded to the stat name directly.
	TagSeparator string `mapstructure:"tag_separator"`
}

type StatsdReporterConfig struct {
	// TagSeparator allows tags to be appended with a separator. If not specified tag keys and values
	// are embedded to the stat name directly.
	TagSeparator string `yaml:"tag_separator"`
}

type TLS struct {
	Key        string         `mapstructure:"key"`
	Cert       string         `mapstructure:"cert"`
	RootCA     string         `mapstructure:"root_ca"`
	AuthType   ClientAuthType `mapstructure:"client_auth_type"`
	ServerName string         `mapstructure:"server_name"`
	UseH2C     bool           `mapstructure:"use_h2c"`
	// contains filtered or unexported fields
}