server

package
v0.9.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Server              ServerConfig
	TLS                 TLSConfig
	Worker              WorkerConfig
	Transport           TransportOptions
	Observability       ObservabilityConfig
	Prometheus          PrometheusConfig
	TransformConfigFile string

	// MessageQueueImpl backs the deprecated --message-queue-impl flag. Prefer
	// Transport.Type (--transport). Retained for backwards compatibility.
	MessageQueueImpl string
}

type ObservabilityConfig

type ObservabilityConfig struct {
	Verbosity    int
	RedisTracing bool
}

type Options

type Options struct {
	Config

	// Deprecated per-backend flag options, retained for backwards compatibility.
	// They are translated into the transport config by the compat shim.
	Redis           redis.PubSubFlowOptions
	RedisSortedSet  redis.SortedSetFlowOptions
	RedisConnection redis.ConnectionOptions
	PubSub          pubsub.Options
	// contains filtered or unexported fields
}

func NewOptions

func NewOptions() *Options

func (*Options) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet)

func (*Options) Complete

func (o *Options) Complete() error

func (*Options) IsQueueConfigSet

func (o *Options) IsQueueConfigSet() bool

IsQueueConfigSet reports whether any backend has multi-queue/topic configuration set.

func (*Options) LoggingOptions

func (o *Options) LoggingOptions() *zap.Options

LoggingOptions returns the zap options for initializing the logger.

func (*Options) Validate

func (o *Options) Validate() error

type PrometheusConfig

type PrometheusConfig struct {
	URL      string
	CacheTTL time.Duration
}

type Runner

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

func NewRunner

func NewRunner(opts *Options) *Runner

func (*Runner) Run

func (r *Runner) Run(ctx context.Context) (err error)

type ServerConfig

type ServerConfig struct {
	HealthPort          int
	MetricsPort         int
	MetricsEndpointAuth bool
}

type TLSConfig

type TLSConfig struct {
	CACert             string
	Cert               string
	Key                string
	InsecureSkipVerify bool
}

type TransportOptions added in v0.9.1

type TransportOptions struct {
	Type                  string
	Config                string
	ConfigFile            string
	ConfigWatchInterval   time.Duration
	MergePolicyConfigFile string
	BacklogPollInterval   time.Duration
}

TransportOptions groups the transport selection and configuration flags.

type WorkerConfig

type WorkerConfig struct {
	Concurrency    int
	RequestTimeout time.Duration
	DrainTimeout   time.Duration
	PoolConfigFile string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL