Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Workers slice contains configuration for all workers
Workers []*WorkerConfig
// StateStoreIntervalSec the number of seconds between saving state calls
StateStoreIntervalSec int
// SyncWorkersIntervalSec the number of second between re-checking configurations (files)
SyncWorkersIntervalSec int
// ReloadFn the function which is called for re-load the config (Read from a file, for instance)
ReloadFn func() (*Config, error) `json:"-"`
}
Config struct contains the comprehensive forwarder configuration. It describes workers, and some common parameters
func NewDefaultConfig ¶
func NewDefaultConfig() *Config
NewDefaultConfig creates a new instance of Config with default values
func (*Config) Check ¶
Check performs a parameter checks and returns an error if they are not acceptable
type Forwarder ¶
type Forwarder struct {
// contains filtered or unexported fields
}
func NewForwarder ¶
type PipeConfig ¶
type PipeConfig struct {
// Name contains name of pipe that
Name string
// From contains an expression for selecting partitions where records will be considered
// The value could be empty - app partitions
From string
// Filter contains an expression for filtering records (true means record is taken).
// The value could be empty - all records match
Filter string
}
PipeConfig struct constains settings for filtering records from different partitions
func (*PipeConfig) Check ¶
func (sc *PipeConfig) Check() error
func (*PipeConfig) String ¶
func (sc *PipeConfig) String() string
String is fmt.Stringer implementation
type WorkerConfig ¶
type WorkerConfig struct {
// Name contains the name of the forwarding configuration
Name string
// Pipe describes the source, where records will be taken
Pipe *PipeConfig
// Sink describes the destination, where records will be written
Sink *sink.Config
}
WorkerConfig struct sets up the name of forwarder, the source (Pipe) and the records destination (Sink)
func (*WorkerConfig) Check ¶
func (wc *WorkerConfig) Check() error
Check performs an internal check for WorkerConfig fields
func (*WorkerConfig) String ¶
func (wc *WorkerConfig) String() string
String is fmt.Stringer implementation
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.