conf

package
v0.0.0-...-2081a44 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2018 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AccountingPath string = "/var/log/account/pacct"
View Source 
var DestinationNames = map[DestinationType]string{
	Kafka:           "kafka",
	UDP:             "udp",
	TCP:             "tcp",
	RELP:            "relp",
	File:            "file",
	Stderr:          "stderr",
	Graylog:         "graylog",
	HTTP:            "http",
	HTTPServer:      "httpserver",
	NATS:            "nats",
	WebsocketServer: "websocketserver",
	Elasticsearch:   "elasticsearch",
	Redis:           "redis",
}
View Source 
var Destinations = map[string]DestinationType{
	"kafka":           Kafka,
	"udp":             UDP,
	"tcp":             TCP,
	"relp":            RELP,
	"file":            File,
	"stderr":          Stderr,
	"graylog":         Graylog,
	"http":            HTTP,
	"httpserver":      HTTPServer,
	"nats":            NATS,
	"websocketserver": WebsocketServer,
	"elasticsearch":   Elasticsearch,
	"redis":           Redis,
}
View Source 
var GitCommit string
View Source 
var RDestinations = map[DestinationType]string{
	Kafka:           "k",
	UDP:             "u",
	TCP:             "t",
	RELP:            "r",
	File:            "f",
	Stderr:          "s",
	Graylog:         "g",
	HTTP:            "h",
	HTTPServer:      "e",
	NATS:            "n",
	WebsocketServer: "w",
	Elasticsearch:   "l",
	Redis:           "d",
}
View Source 
var V0_10_0_0 = KafkaVersion{0, 10, 0, 0}

noinspection GoSnakeCaseUsage

View Source 
var V0_10_0_1 = KafkaVersion{0, 10, 0, 1}

noinspection GoSnakeCaseUsage

View Source 
var V0_10_1_0 = KafkaVersion{0, 10, 1, 0}

noinspection GoSnakeCaseUsage

View Source 
var V0_10_2_0 = KafkaVersion{0, 10, 2, 0}

noinspection GoSnakeCaseUsage

View Source 
var V0_11_0_0 = KafkaVersion{0, 11, 0, 0}

noinspection GoSnakeCaseUsage

View Source 
var V0_8_2_0 = KafkaVersion{0, 8, 2, 0}

noinspection GoSnakeCaseUsage

View Source 
var V0_8_2_1 = KafkaVersion{0, 8, 2, 1}

noinspection GoSnakeCaseUsage

View Source 
var V0_8_2_2 = KafkaVersion{0, 8, 2, 2}

noinspection GoSnakeCaseUsage

View Source 
var V0_9_0_0 = KafkaVersion{0, 9, 0, 0}

noinspection GoSnakeCaseUsage

View Source 
var V0_9_0_1 = KafkaVersion{0, 9, 0, 1}

noinspection GoSnakeCaseUsage

View Source 
var V1_0_0_0 = KafkaVersion{1, 0, 0, 0}

noinspection GoSnakeCaseUsage

View Source 
var Version string

Functions

func FromConsul 

func FromConsul(v *viper.Viper, confStr string) (err error)

func ParseVersion 

func ParseVersion(v string) (skv sarama.KafkaVersion, e error)

func SetAccountingDefaults 

func SetAccountingDefaults(v *viper.Viper, prefixed bool)

func SetDefaults 

func SetDefaults(v *viper.Viper)

func SetElasticDestDefaults 

func SetElasticDestDefaults(v *viper.Viper, prefixed bool)

func SetFileDestDefaults 

func SetFileDestDefaults(v *viper.Viper, prefixed bool)

func SetGraylogDestDefaults 

func SetGraylogDestDefaults(v *viper.Viper, prefixed bool)

func SetHTTPDestDefaults 

func SetHTTPDestDefaults(v *viper.Viper, prefixed bool)

func SetHTTPServerDestDefaults 

func SetHTTPServerDestDefaults(v *viper.Viper, prefixed bool)

func SetJournaldDefaults 

func SetJournaldDefaults(v *viper.Viper, prefixed bool)

func SetKafkaDefaults 

func SetKafkaDefaults(v *viper.Viper, prefixed bool)

func SetMacOSDefaults 

func SetMacOSDefaults(v *viper.Viper, prefixed bool)

func SetMainDefaults 

func SetMainDefaults(v *viper.Viper, prefixed bool)

func SetMetricsDefaults 

func SetMetricsDefaults(v *viper.Viper, prefixed bool)

func SetNatsDestDefaults 

func SetNatsDestDefaults(v *viper.Viper, prefixed bool)

func SetRedisDestDefaults 

func SetRedisDestDefaults(v *viper.Viper, prefixed bool)

func SetRelpDestDefaults 

func SetRelpDestDefaults(v *viper.Viper, prefixed bool)

func SetStderrDestDefaults 

func SetStderrDestDefaults(v *viper.Viper, prefixed bool)

func SetStoreDefaults 

func SetStoreDefaults(v *viper.Viper, prefixed bool)

func SetTcpDestDefaults 

func SetTcpDestDefaults(v *viper.Viper, prefixed bool)

func SetUdpDestDefaults 

func SetUdpDestDefaults(v *viper.Viper, prefixed bool)

func SetWebsocketServerDestDefaults 

func SetWebsocketServerDestDefaults(v *viper.Viper, prefixed bool)

Types

type AccountingSourceConfig 

type AccountingSourceConfig struct {
	FilterSubConfig `mapstructure:",squash"`
	ConfID          utils.MyULID  `mapstructure:"-" toml:"-" json:"conf_id"`
	Period          time.Duration `mapstructure:"period" toml:"period" json:"period"`
	Path            string        `mapstructure:"path" toml:"path" json:"path"`
	Enabled         bool          `mapstructure:"enabled" toml:"enabled" json:"enabled"`
}

func (*AccountingSourceConfig) DecoderConf 

func (c *AccountingSourceConfig) DecoderConf() *DecoderBaseConfig

func (*AccountingSourceConfig) DefaultPort 

func (c *AccountingSourceConfig) DefaultPort() int

func (*AccountingSourceConfig) FilterConf 

func (c *AccountingSourceConfig) FilterConf() *FilterSubConfig

func (*AccountingSourceConfig) ListenersConf 

func (c *AccountingSourceConfig) ListenersConf() *ListenersConfig

func (*AccountingSourceConfig) SetConfID 

func (c *AccountingSourceConfig) SetConfID()

type BaseConfig 

type BaseConfig struct {
	FSSource            []FilesystemSourceConfig  `mapstructure:"fs_source" toml:"fs_source" json:"fs_source"`
	TCPSource           []TCPSourceConfig         `mapstructure:"tcp_source" toml:"tcp_source" json:"tcp_source"`
	UDPSource           []UDPSourceConfig         `mapstructure:"udp_source" toml:"udp_source" json:"udp_source"`
	RELPSource          []RELPSourceConfig        `mapstructure:"relp_source" toml:"relp_source" json:"relp_source"`
	HTTPServerSource    []HTTPServerSourceConfig  `mapstructure:"httpserver_source" toml:"httpserver_source" json:"httpserver_source"`
	DirectRELPSource    []DirectRELPSourceConfig  `mapstructure:"directrelp_source" toml:"directrelp_source" json:"directrelp_source"`
	KafkaSource         []KafkaSourceConfig       `mapstructure:"kafka_source" toml:"kafka_source" json:"kafka_source"`
	GraylogSource       []GraylogSourceConfig     `mapstructure:"graylog_source" toml:"graylog_source" json:"graylog_source"`
	Store               StoreConfig               `mapstructure:"store" toml:"store" json:"store"`
	Parsers             []ParserConfig            `mapstructure:"parser" toml:"parser" json:"parser"`
	Journald            JournaldConfig            `mapstructure:"journald" toml:"journald" json:"journald"`
	Metrics             MetricsConfig             `mapstructure:"metrics" toml:"metrics" json:"metrics"`
	Accounting          AccountingSourceConfig    `mapstructure:"accounting" toml:"accounting" json:"accounting"`
	MacOS               MacOSSourceConfig         `mapstructure:"macos" toml:"macos" json:"macos"`
	Main                MainConfig                `mapstructure:"main" toml:"main" json:"main"`
	KafkaDest           *KafkaDestConfig          `mapstructure:"kafka_destination" toml:"kafka_destination" json:"kafka_destination"`
	UDPDest             UDPDestConfig             `mapstructure:"udp_destination" toml:"udp_destination" json:"udp_destination"`
	TCPDest             TCPDestConfig             `mapstructure:"tcp_destination" toml:"tcp_destination" json:"tcp_destination"`
	HTTPDest            HTTPDestConfig            `mapstructure:"http_destination" toml:"http_destination" json:"http_destination"`
	HTTPServerDest      HTTPServerDestConfig      `mapstructure:"httpserver_destination" toml:"httpserver_destination" json:"httpserver_destination"`
	WebsocketServerDest WebsocketServerDestConfig `mapstructure:"websocketserver_destination" toml:"websocketserver_destination" json:"websocketserver_destination"`
	NATSDest            *NATSDestConfig           `mapstructure:"nats_destination" toml:"nats_destination" json:"nats_destination"`
	RELPDest            RELPDestConfig            `mapstructure:"relp_destination" toml:"relp_destination" json:"relp_destination"`
	FileDest            FileDestConfig            `mapstructure:"file_destination" toml:"file_destination" json:"file_destination"`
	StderrDest          StderrDestConfig          `mapstructure:"stderr_destination" toml:"stderr_destination" json:"stderr_destination"`
	GraylogDest         GraylogDestConfig         `mapstructure:"graylog_destination" toml:"graylog_destination" json:"graylog_destination"`
	ElasticDest         ElasticDestConfig         `mapstructure:"elasticsearch_destination" toml:"elasticsearch_destination" json:"elasticsearch_destination"`
	RedisDest           RedisDestConfig           `mapstructure:"redis_destination" toml:"redis_destination" json:"redis_destination"`
}

BaseConfig is the root of all configuration parameters.

func Default 

func Default() (BaseConfig, error)

func InitLoad 

func InitLoad(ctx context.Context, confDir string, p consul.ConnParams, r kring.Ring, l log15.Logger) (c BaseConfig, updates chan *BaseConfig, err error)

func NewBaseConf 

func NewBaseConf() BaseConfig

func (*BaseConfig) CheckDestinations 

func (c *BaseConfig) CheckDestinations() error

func (BaseConfig) Clone 

func (c BaseConfig) Clone() BaseConfig

func (*BaseConfig) Complete 

func (c *BaseConfig) Complete(r kring.Ring) (err error)

func (*BaseConfig) Export 

func (c *BaseConfig) Export() (string, error)

func (*BaseConfig) GetCertificateFiles 

func (c *BaseConfig) GetCertificateFiles() (res map[string][]string)

func (*BaseConfig) GetCertificatePaths 

func (c *BaseConfig) GetCertificatePaths() (res map[string][]string)

func (*BaseConfig) String 

func (c *BaseConfig) String() (string, error)

type DecoderBaseConfig 

type DecoderBaseConfig struct {
	Format    string `mapstructure:"format" toml:"format" json:"format"`
	Charset   string `mapstructure:"charset" toml:"charset" json:"charset"`
	W3CFields string `mapstructure:"w3c_fields" toml:"w3c_fields" json:"fields"`
}

func (*DecoderBaseConfig) Equals 

func (c *DecoderBaseConfig) Equals(other gotomic.Thing) bool

func (*DecoderBaseConfig) HashCode 

func (c *DecoderBaseConfig) HashCode() uint32

type DestinationType 

type DestinationType uint64

DestinationType lists the possible kind of destinations where skewer can forward messages. 

const (
	Kafka           DestinationType = 1
	UDP             DestinationType = 2
	TCP             DestinationType = 4
	RELP            DestinationType = 8
	File            DestinationType = 16
	Stderr          DestinationType = 32
	Graylog         DestinationType = 64
	HTTP            DestinationType = 128
	NATS            DestinationType = 256
	HTTPServer      DestinationType = 512
	WebsocketServer DestinationType = 1024
	Elasticsearch   DestinationType = 2048
	Redis           DestinationType = 4096
)

func (DestinationType) Has 

func (dests DestinationType) Has(one DestinationType) bool

func (DestinationType) Iterate 

func (dests DestinationType) Iterate() (res []DestinationType)

type DirectRELPSourceConfig 

type DirectRELPSourceConfig struct {
	DecoderBaseConfig `mapstructure:",squash"`
	ListenersConfig   `mapstructure:",squash"`
	FilterSubConfig   `mapstructure:",squash"`
	TlsBaseConfig     `mapstructure:",squash"`
	ClientAuthType    string       `mapstructure:"client_auth_type" toml:"client_auth_type" json:"client_auth_type"`
	LineFraming       bool         `mapstructure:"line_framing" toml:"line_framing" json:"line_framing"`
	FrameDelimiter    string       `mapstructure:"delimiter" toml:"delimiter" json:"delimiter"`
	ConfID            utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
}

func (*DirectRELPSourceConfig) DecoderConf 

func (c *DirectRELPSourceConfig) DecoderConf() *DecoderBaseConfig

func (*DirectRELPSourceConfig) DefaultPort 

func (c *DirectRELPSourceConfig) DefaultPort() int

func (*DirectRELPSourceConfig) Export 

func (c *DirectRELPSourceConfig) Export() string

func (*DirectRELPSourceConfig) FilterConf 

func (c *DirectRELPSourceConfig) FilterConf() *FilterSubConfig

func (*DirectRELPSourceConfig) GetClientAuthType 

func (c *DirectRELPSourceConfig) GetClientAuthType() tls.ClientAuthType

func (*DirectRELPSourceConfig) ListenersConf 

func (c *DirectRELPSourceConfig) ListenersConf() *ListenersConfig

func (*DirectRELPSourceConfig) SetConfID 

func (c *DirectRELPSourceConfig) SetConfID()

type ElasticDestConfig 

type ElasticDestConfig struct {
	TlsBaseConfig       `mapstructure:",squash"`
	Insecure            bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	ProxyURL            string        `mapstructure:"proxy_url" toml:"proxy_url" json:"proxy_url"`
	ConnTimeout         time.Duration `mapstructure:"connection_timeout" toml:"connection_timeout" json:"connection_timeout"`
	ConnKeepAlive       bool          `mapstructure:"conn_keepalive" toml:"conn_keepalive" json:"conn_keepalive"`
	ConnKeepAlivePeriod time.Duration `mapstructure:"conn_keepalive_period" toml:"conn_keepalive_period" json:"conn_keepalive_period"`
	Rebind              time.Duration `mapstructure:"rebind" toml:"rebind" json:"rebind"`
	Format              string        `mapstructure:"format" toml:"format" json:"format"`

	URLs                      []string      `mapstructure:"urls" toml:"urls" json:"urls"`
	Username                  string        `mapstructure:"username" toml:"username" json:"username"`
	Password                  string        `mapstructure:"password" toml:"password" json:"password"`
	HealthCheckInterval       time.Duration `mapstructure:"health_check_interval" toml:"health_check_interval" json:"health_check_interval"`
	HealthCheck               bool          `mapstructure:"health_check" toml:"health_check" toml:"health_check" json:"health_check"`
	HealthCheckTimeout        time.Duration `mapstructure:"health_check_timeout" toml:"health_check_timeout" json:"health_check_timeout"`
	HealthCheckTimeoutStartup time.Duration `mapstructure:"health_check_timeout_startup" toml:"health_check_timeout_startup" json:"health_check_timeout_startup"`
	Sniffing                  bool          `mapstructure:"sniffing" toml:"sniffing" json:"sniffing"`
	IndexNameTpl              string        `mapstructure:"index_name_template" toml:"index_name_template" json:"index_name_template"`
	MessagesType              string        `mapstructure:"messages_type" toml:"messages_type" json:"messages_type"`
	BatchSize                 int           `mapstructure:"batch_size" toml:"batch_size" json:"batch_size"`
	FlushPeriod               time.Duration `mapstructure:"flush_period" toml:"flush_period" json:"flush_period"`
	CreateIndices             bool          `mapstructure:"create_indices" toml:"create_indices" json:"create_indices"`

	RefreshInterval time.Duration `mapstructure:"refresh_interval" toml:"refresh_interval" json:"refresh_interval"`
	CheckStartup    bool          `mapstructure:"check_startup" toml:"check_startup" json:"check_startup"`
	NShards         uint          `mapstructure:"shards" toml:"shards" json:"shards"`
	NReplicas       uint          `mapstructure:"replicas" toml:"replicas" json:"replicas"`
}

type FileDestConfig 

type FileDestConfig struct {
	Filename        string        `mapstructure:"filename" toml:"filename" json:"filename"`
	Sync            bool          `mapstructure:"sync" toml:"sync" json:"sync"`
	SyncPeriod      time.Duration `mapstructure:"sync_period" toml:"sync_period" json:"sync_period"`
	FlushPeriod     time.Duration `mapstructure:"flush_period" toml:"flush_period" json:"flush_period"`
	BufferSize      int           `mapstructure:"buffer_size" toml:"buffer_size" json:"buffer_size"`
	OpenFileTimeout time.Duration `mapstructure:"open_file_timeout" toml:"open_file_timeout" json:"open_file_timeout"`
	Gzip            bool          `mapstructure:"gzip" toml:"gzip" json:"gzip"`
	GzipLevel       int           `mapstructure:"gzip_level" toml:"gzip_level" json:"gzip_level"`
	Format          string        `mapstructure:"format" toml:"format" json:"format"`
}

type FilesystemSourceConfig 

type FilesystemSourceConfig struct {
	FilterSubConfig   `mapstructure:",squash"`
	DecoderBaseConfig `mapstructure:",squash"`
	BaseDirectory     string       `mapstructure:"base_directory" toml:"base_directory" json:"base_directory"`
	Glob              string       `mapstructure:"glob" toml:"glob" json:"glob"`
	ConfID            utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
}

func (*FilesystemSourceConfig) DecoderConf 

func (c *FilesystemSourceConfig) DecoderConf() *DecoderBaseConfig

func (*FilesystemSourceConfig) DefaultPort 

func (c *FilesystemSourceConfig) DefaultPort() int

func (*FilesystemSourceConfig) FilterConf 

func (c *FilesystemSourceConfig) FilterConf() *FilterSubConfig

func (*FilesystemSourceConfig) ListenersConf 

func (c *FilesystemSourceConfig) ListenersConf() *ListenersConfig

func (*FilesystemSourceConfig) SetConfID 

func (c *FilesystemSourceConfig) SetConfID()

type FilterSubConfig 

type FilterSubConfig struct {
	TopicTmpl           string `mapstructure:"topic_tmpl" toml:"topic_tmpl" json:"topic_tmpl"`
	TopicFunc           string `mapstructure:"topic_function" toml:"topic_function" json:"topic_function"`
	PartitionTmpl       string `mapstructure:"partition_key_tmpl" toml:"partition_key_tmpl" json:"partition_key_tmpl"`
	PartitionFunc       string `mapstructure:"partition_key_func" toml:"partition_key_func" json:"partition_key_func"`
	PartitionNumberFunc string `mapstructure:"partition_number_func" toml:"partition_number_func" json:"partition_number_func"`
	FilterFunc          string `mapstructure:"filter_func" toml:"filter_func" json:"filter_func"`
}

func ImportSyslogConfig 

func ImportSyslogConfig(data []byte) (*FilterSubConfig, error)

func (*FilterSubConfig) CalculateID 

func (c *FilterSubConfig) CalculateID() utils.MyULID

func (*FilterSubConfig) Export 

func (c *FilterSubConfig) Export() string

type GraylogDestConfig 

type GraylogDestConfig struct {
	Host             string        `mapstructure:"host" toml:"host" json:"host"`
	Port             int           `mapstructure:"port" toml:"port" json:"port"`
	Mode             string        `mapstructure:"mode" toml:"mode" json:"mode"`
	MaxReconnect     int           `mapstructure:"max_reconnect" toml:"max_reconnect" json:"max_reconnect"`
	ReconnectDelay   time.Duration `mapstructure:"reconnect_delay" toml:"reconnect_delay" json:"reconnect_delay"`
	CompressionLevel int           `mapstructure:"compression_level" toml:"compression_level" json:"compression_level"`
	CompressionType  string        `mapstructure:"compression_type" toml:"compression_type" json:"compression_type"`
}

type GraylogSourceConfig 

type GraylogSourceConfig struct {
	DecoderBaseConfig `mapstructure:",squash"`
	ListenersConfig   `mapstructure:",squash"`
	FilterSubConfig   `mapstructure:",squash"`
	ConfID            utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
}

func (*GraylogSourceConfig) DecoderConf 

func (c *GraylogSourceConfig) DecoderConf() *DecoderBaseConfig

func (*GraylogSourceConfig) DefaultPort 

func (c *GraylogSourceConfig) DefaultPort() int

func (*GraylogSourceConfig) Export 

func (c *GraylogSourceConfig) Export() string

func (*GraylogSourceConfig) FilterConf 

func (c *GraylogSourceConfig) FilterConf() *FilterSubConfig

func (*GraylogSourceConfig) ListenersConf 

func (c *GraylogSourceConfig) ListenersConf() *ListenersConfig

func (*GraylogSourceConfig) SetConfID 

func (c *GraylogSourceConfig) SetConfID()

type HTTPDestConfig 

type HTTPDestConfig struct {
	TlsBaseConfig       `mapstructure:",squash"`
	Insecure            bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	URL                 string        `mapstructure:"url" toml:"url" json:"url"`
	Method              string        `mapstructure:"method" toml:"method" json:"method"`
	ProxyURL            string        `mapstructure:"proxy_url" toml:"proxy_url" json:"proxy_url"`
	Rebind              time.Duration `mapstructure:"rebind" toml:"rebind" json:"rebind"`
	Format              string        `mapstructure:"format" toml:"format" json:"format"`
	MaxIdleConnsPerHost int           `mapstructure:"max_idle_conns_per_host" toml:"max_idle_conns_per_host" json:"max_idle_conns_per_host"`
	IdleConnTimeout     time.Duration `mapstructure:"idle_conn_timeout" toml:"idle_conn_timeout" json:"idle_conn_timeout"`
	ConnTimeout         time.Duration `mapstructure:"connection_timeout" toml:"connection_timeout" json:"connection_timeout"`
	RequestTimeout      time.Duration `mapstructure:"request_timeout" toml:"request_timeout" json:"request_timeout"`
	ConnKeepAlive       bool          `mapstructure:"conn_keepalive" toml:"conn_keepalive" json:"conn_keepalive"`
	ConnKeepAlivePeriod time.Duration `mapstructure:"conn_keepalive_period" toml:"conn_keepalive_period" json:"conn_keepalive_period"`
	BasicAuth           bool          `mapstructure:"basic_auth" toml:"basic_auth" json:"basic_auth"`
	Username            string        `mapstructure:"username" toml:"username" json:"username"`
	Password            string        `mapstructure:"password" toml:"password" json:"password"`
	UserAgent           string        `mapstructure:"user_agent" toml:"user_agent" json:"user_agent"`
	ContentType         string        `mapstructure:"content_type" toml:"content_type" json:"content_type"`
}

type HTTPServerBaseConfig 

type HTTPServerBaseConfig struct {
	BindAddr             string        `mapstructure:"bind_addr" toml:"bind_addr" json:"bind_addr"`
	ReadTimeout          time.Duration `mapstructure:"read_timeout" toml:"read_timeout" json:"read_timeout"`
	ReadHeaderTimeout    time.Duration `mapstructure:"read_header_timeout" toml:"read_header_timeout" json:"read_header_timeout"`
	WriteTimeout         time.Duration `mapstructure:"write_timeout" toml:"write_timeout" json:"write_timeout"`
	IdleTimeout          time.Duration `mapstructure:"idle_timeout" toml:"idle_timeout" json:"idle_timeout"`
	MaxHeaderBytes       int           `mapstructure:"max_header_bytes" toml:"max_header_bytes" json:"max_header_bytes"`
	DisableConnKeepAlive bool          `mapstructure:"disable_conn_keepalive" toml:"disable_conn_keepalive" json:"disable_conn_keepalive"`
	ConnKeepAlivePeriod  time.Duration `mapstructure:"conn_keepalive_period" toml:"conn_keepalive_period" json:"conn_keepalive_period"`
	DisableHTTPKeepAlive bool          `mapstructure:"disable_http_keepalive" toml:"disable_http_keepalive" json:"disable_http_keepalive"`
}

type HTTPServerDestConfig 

type HTTPServerDestConfig struct {
	HTTPServerBaseConfig `mapstructure:",squash"`

	TlsBaseConfig  `mapstructure:",squash"`
	ClientAuthType string `mapstructure:"client_auth_type" toml:"client_auth_type" json:"client_auth_type"`

	Port int `mapstructure:"port" toml:"port" json:"port"`

	// format can be empty if the format should be inferred by the accepted mimetypes sent by the client
	Format         string `mapstructure:"format" toml:"format" json:"format"`
	LineFraming    bool   `mapstructure:"line_framing" toml:"line_framing" json:"line_framing"`
	FrameDelimiter uint8  `mapstructure:"delimiter" toml:"delimiter" json:"delimiter"`
	NMessages      int32  `mapstructure:"messages_number" toml:"messages_number" json:"messages_number"`
}

func (*HTTPServerDestConfig) GetClientAuthType 

func (c *HTTPServerDestConfig) GetClientAuthType() tls.ClientAuthType

type HTTPServerSourceConfig 

type HTTPServerSourceConfig struct {
	HTTPServerBaseConfig `mapstructure:",squash"`
	DecoderBaseConfig    `mapstructure:",squash"`

	FilterSubConfig `mapstructure:",squash"`
	ConfID          utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`

	TlsBaseConfig  `mapstructure:",squash"`
	ClientAuthType string `mapstructure:"client_auth_type" toml:"client_auth_type" json:"client_auth_type"`

	Port int `mapstructure:"port" toml:"port" json:"port"`
	// should the server accept multiple messages per request
	DisableMultiple bool   `mapstructure:"disable_multiple" toml:"disable_multiple" json:"disable_multiple"`
	FrameDelimiter  string `mapstructure:"delimiter" toml:"delimiter" json:"delimiter"`
	MaxBodySize     int64  `mapstructure:"max_body_size" toml:"max_body_size" json:"max_body_size"`
	MaxMessages     int    `mapstructure:"max_messages" toml:"max_messages" json:"max_messages"`
}

func (*HTTPServerSourceConfig) DecoderConf 

func (c *HTTPServerSourceConfig) DecoderConf() *DecoderBaseConfig

func (*HTTPServerSourceConfig) DefaultPort 

func (c *HTTPServerSourceConfig) DefaultPort() int

func (*HTTPServerSourceConfig) FilterConf 

func (c *HTTPServerSourceConfig) FilterConf() *FilterSubConfig

func (*HTTPServerSourceConfig) GetClientAuthType 

func (c *HTTPServerSourceConfig) GetClientAuthType() tls.ClientAuthType

func (*HTTPServerSourceConfig) ListenersConf 

func (c *HTTPServerSourceConfig) ListenersConf() *ListenersConfig

func (*HTTPServerSourceConfig) SetConfID 

func (c *HTTPServerSourceConfig) SetConfID()

type JournaldConfig 

type JournaldConfig struct {
	FilterSubConfig `mapstructure:",squash"`
	ConfID          utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
	Enabled         bool         `mapstructure:"enabled" toml:"enabled" json:"enabled"`
}

func (*JournaldConfig) DecoderConf 

func (c *JournaldConfig) DecoderConf() *DecoderBaseConfig

func (*JournaldConfig) DefaultPort 

func (c *JournaldConfig) DefaultPort() int

func (*JournaldConfig) FilterConf 

func (c *JournaldConfig) FilterConf() *FilterSubConfig

func (*JournaldConfig) ListenersConf 

func (c *JournaldConfig) ListenersConf() *ListenersConfig

func (*JournaldConfig) SetConfID 

func (c *JournaldConfig) SetConfID()

type KafkaBaseConfig 

type KafkaBaseConfig struct {
	Brokers                  []string      `mapstructure:"brokers" toml:"brokers" json:"brokers"`
	ClientID                 string        `mapstructure:"client_id" toml:"client_id" json:"client_id"`
	Version                  string        `mapstructure:"version" toml:"version" json:"version"`
	ChannelBufferSize        int           `mapstructure:"channel_buffer_size" toml:"channel_buffer_size" json:"channel_buffer_size"`
	MaxOpenRequests          int           `mapstructure:"max_open_requests" toml:"max_open_requests" json:"max_open_requests"`
	DialTimeout              time.Duration `mapstructure:"dial_timeout" toml:"dial_timeout" json:"dial_timeout"`
	ReadTimeout              time.Duration `mapstructure:"read_timeout" toml:"read_timeout" json:"read_timeout"`
	WriteTimeout             time.Duration `mapstructure:"write_timeout" toml:"write_timeout" json:"write_timeout"`
	KeepAlive                time.Duration `mapstructure:"keepalive" toml:"keepalive" json:"keepalive"`
	MetadataRetryMax         int           `mapstructure:"metadata_retry_max" toml:"metadata_retry_max" json:"metadata_retry_max"`
	MetadataRetryBackoff     time.Duration `mapstructure:"metadata_retry_backoff" toml:"metadata_retry_backoff" json:"metadata_retry_backoff"`
	MetadataRefreshFrequency time.Duration `mapstructure:"metadata_refresh_frequency" toml:"metadata_refresh_frequency" json:"metadata_refresh_frequency"`
}

type KafkaConsumerBaseConfig 

type KafkaConsumerBaseConfig struct {
	RetryBackoff          time.Duration `mapstructure:"retry_backoff" toml:"retry_backoff" json:"retry_backoff"`
	MinFetchBytes         int32         `mapstructure:"min_fetch_bytes" toml:"min_fetch_bytes" json:"min_fetch_bytes"`
	DefaultFetchBytes     int32         `mapstructure:"default_fetch_bytes" toml:"default_fetch_bytes" json:"default_fetch_bytes"`
	MaxFetchBytes         int32         `mapstructure:"max_fetch_bytes" toml:"max_fetch_bytes" json:"max_fetch_bytes"`
	MaxWaitTime           time.Duration `mapstructure:"max_wait_time" toml:"max_wait_time" json:"max_wait_time"`
	MaxProcessingTime     time.Duration `mapstructure:"max_processing_time" toml:"max_processing_time" json:"max_processing_time"`
	OffsetsCommitInterval time.Duration `mapstructure:"offsets_commit_interval" toml:"offsets_commit_interval" json:"offsets_commit_interval"`
	OffsetsInitial        int64         `mapstructure:"offsets_initial" toml:"offsets_initial" json:"offsets_initial"`
	OffsetsRetention      time.Duration `mapstructure:"offsets_retention" toml:"offsets_retention" json:"offsets_retention"`
}

type KafkaDestConfig 

type KafkaDestConfig struct {
	KafkaBaseConfig         `mapstructure:",squash"`
	KafkaProducerBaseConfig `mapstructure:",squash"`
	TlsBaseConfig           `mapstructure:",squash"`
	Insecure                bool   `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	Format                  string `mapstructure:"format" toml:"format" json:"format"`
}

func (*KafkaDestConfig) GetAsyncProducer 

func (c *KafkaDestConfig) GetAsyncProducer(confined bool) (sarama.AsyncProducer, metrics.Registry, error)

func (*KafkaDestConfig) GetClient 

func (c *KafkaDestConfig) GetClient(confined bool) (sarama.Client, error)

func (*KafkaDestConfig) GetSaramaProducerConfig 

func (c *KafkaDestConfig) GetSaramaProducerConfig(confined bool) (*sarama.Config, error)

type KafkaProducerBaseConfig 

type KafkaProducerBaseConfig struct {
	MessageBytesMax  int           `mapstructure:"message_bytes_max" toml:"message_bytes_max" json:"message_bytes_max"`
	RequiredAcks     int16         `mapstructure:"required_acks" toml:"required_acks" json:"required_acks"`
	ProducerTimeout  time.Duration `mapstructure:"producer_timeout" toml:"producer_timeout" json:"producer_timeout"`
	Compression      string        `mapstructure:"compression" toml:"compression" json:"compression"`
	Partitioner      string        `mapstructure:"partitioner" toml:"partitioner" json:"partitioner"`
	FlushBytes       int           `mapstructure:"flush_bytes" toml:"flush_bytes" json:"flush_bytes"`
	FlushMessages    int           `mapstructure:"flush_messages" toml:"flush_messages" json:"flush_messages"`
	FlushFrequency   time.Duration `mapstructure:"flush_frequency" toml:"flush_frequency" json:"flush_frequency"`
	FlushMessagesMax int           `mapstructure:"flush_messages_max" toml:"flush_messages_max" json:"flush_messages_max"`
	RetrySendMax     int           `mapstructure:"retry_send_max" toml:"retry_send_max" json:"retry_send_max"`
	RetrySendBackoff time.Duration `mapstructure:"retry_send_backoff" toml:"retry_send_backoff" json:"retry_send_backoff"`
}

type KafkaSourceConfig 

type KafkaSourceConfig struct {
	KafkaBaseConfig         `mapstructure:",squash"`
	KafkaConsumerBaseConfig `mapstructure:",squash"`
	FilterSubConfig         `mapstructure:",squash"`
	TlsBaseConfig           `mapstructure:",squash"`
	DecoderBaseConfig       `mapstructure:",squash"`
	Insecure                bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	ConfID                  utils.MyULID  `mapstructure:"-" toml:"-" json:"conf_id"`
	SessionTimeout          time.Duration `mapstructure:"session_timeout" toml:"session_timeout" json:"session_timeout"`
	HeartbeatInterval       time.Duration `mapstructure:"heartbeat_interval" toml:"heartbeat_interval" json:"heartbeat_interval"`
	OffsetsMaxRetry         int           `mapstructure:"offsets_max_retry" toml:"offsets_max_retry" json:"offsets_max_retry"`
	GroupID                 string        `mapstructure:"group_ip" toml:"group_id" json:"group_id"`
	Topics                  []string      `mapstructure:"topics" toml:"topics" json:"topics"`
}

func (*KafkaSourceConfig) DecoderConf 

func (c *KafkaSourceConfig) DecoderConf() *DecoderBaseConfig

func (*KafkaSourceConfig) DefaultPort 

func (c *KafkaSourceConfig) DefaultPort() int

func (*KafkaSourceConfig) FilterConf 

func (c *KafkaSourceConfig) FilterConf() *FilterSubConfig

func (*KafkaSourceConfig) GetClient 

func (c *KafkaSourceConfig) GetClient(confined bool) (*cluster.Consumer, metrics.Registry, error)

func (*KafkaSourceConfig) GetSaramaConsumerConfig 

func (c *KafkaSourceConfig) GetSaramaConsumerConfig(confined bool) (*cluster.Config, error)

func (*KafkaSourceConfig) ListenersConf 

func (c *KafkaSourceConfig) ListenersConf() *ListenersConfig

func (*KafkaSourceConfig) SetConfID 

func (c *KafkaSourceConfig) SetConfID()

type KafkaVersion 

type KafkaVersion [4]int

func (KafkaVersion) Greater 

func (l KafkaVersion) Greater(r KafkaVersion) bool

func (KafkaVersion) ToSaramaVersion 

func (l KafkaVersion) ToSaramaVersion() (v sarama.KafkaVersion, e error)

type ListenersConfig 

type ListenersConfig struct {
	Ports           []int         `mapstructure:"ports" toml:"ports" json:"ports"`
	BindAddr        string        `mapstructure:"bind_addr" toml:"bind_addr" json:"bind_addr"`
	UnixSocketPath  string        `mapstructure:"unix_socket_path" toml:"unix_socket_path" json:"unix_socket_path"`
	KeepAlive       bool          `mapstructure:"keepalive" toml:"keepalive" json:"keepalive"`
	KeepAlivePeriod time.Duration `mapstructure:"keepalive_period" toml:"keepalive_period" json:"keepalive_period"`
	Timeout         time.Duration `mapstructure:"timeout" toml:"timeout" json:"timeout"`
}

func (*ListenersConfig) GetListenAddrs 

func (c *ListenersConfig) GetListenAddrs() (addrs map[int]string, err error)

type MacOSSourceConfig 

type MacOSSourceConfig struct {
	FilterSubConfig `mapstructure:",squash"`
	ConfID          utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
	Enabled         bool         `mapstructure:"enabled" toml:"enabled" json:"enabled"`
	Level           string       `mapstructure:"level" toml:"level" json:"level"`
	Process         string       `mapstructure:"process" toml:"process" json:"process"`
	Predicate       string       `mapstructure:"predicate" toml:"predicate" json:"predicate"`
	Command         string       `mapstructure:"command" toml:"command" json:"command"`
}

func (*MacOSSourceConfig) DecoderConf 

func (c *MacOSSourceConfig) DecoderConf() *DecoderBaseConfig

func (*MacOSSourceConfig) DefaultPort 

func (c *MacOSSourceConfig) DefaultPort() int

func (*MacOSSourceConfig) FilterConf 

func (c *MacOSSourceConfig) FilterConf() *FilterSubConfig

func (*MacOSSourceConfig) ListenersConf 

func (c *MacOSSourceConfig) ListenersConf() *ListenersConfig

func (*MacOSSourceConfig) SetConfID 

func (c *MacOSSourceConfig) SetConfID()

type MainConfig 

type MainConfig struct {
	InputQueueSize      uint64 `mapstructure:"input_queue_size" toml:"input_queue_size" json:"input_queue_size"`
	MaxInputMessageSize int    `mapstructure:"max_input_message_size" toml:"max_input_message_size" json:"max_input_message_size"`
	Destination         string `mapstructure:"destination" toml:"destination" json:"destination"`
	EncryptIPC          bool   `mapstructure:"encrypt_ipc" toml:"encrypt_ipc" json:"encrypt_ipc"`
}

MainConfig lists general/global parameters.

func (*MainConfig) GetDestinations 

func (m *MainConfig) GetDestinations() (dests DestinationType, err error)

type MetricsConfig 

type MetricsConfig struct {
	Path string `mapstructure:"path" toml:"path" json:"path"`
	Port int    `mapstructure:"port" toml:"port" json:"port"`
}

type NATSDestConfig 

type NATSDestConfig struct {
	TlsBaseConfig    `mapstructure:",squash"`
	Insecure         bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	NServers         []string      `mapstructure:"servers" toml:"servers" json:"servers"`
	Format           string        `mapstructure:"format" toml:"format" json:"format"`
	Name             string        `mapstructure:"name" toml:"name" json:"name"`
	MaxReconnect     int           `mapstructure:"max_reconnect" toml:"max_reconnect" json:"max_reconnect"`
	ReconnectWait    time.Duration `mapstructure:"reconnect_wait" toml:"reconnect_wait" json:"reconnect_wait"`
	ConnTimeout      time.Duration `mapstructure:"connection_timeout" toml:"connection_timeout" json:"connection_timeout"`
	FlusherTimeout   time.Duration `mapstructure:"flusher_timeout" toml:"flusher_timeout" json:"flusher_timeout"`
	PingInterval     time.Duration `mapstructure:"ping_interval" toml:"ping_interval" json:"ping_interval"`
	MaxPingsOut      int           `mapstructure:"max_pings_out" toml:"max_pings_out" json:"max_pings_out"`
	ReconnectBufSize int           `mapstructure:"reconnect_buf_size" toml:"reconnect_buf_size" json:"reconnect_buf_size"`
	Username         string        `mapstructure:"username" toml:"username" json:"username"`
	Password         string        `mapstructure:"password" toml:"password" json:"password"`
	NoRandomize      bool          `mapstructure:"no_randomize" toml:"no_randomize" json:"no_randomize"`
	AllowReconnect   bool          `mapstructure:"allow_reconnect" toml:"allow_reconnect" json:"allow_reconnect"`
}

type ParserConfig 

type ParserConfig struct {
	Name string `mapstructure:"name" toml:"name" json:"name"`
	Func string `mapstructure:"func" toml:"func" json:"func"`
}

type RELPDestConfig 

type RELPDestConfig struct {
	TcpUdpRelpDestBaseConfig `mapstructure:",squash"`
	TlsBaseConfig            `mapstructure:",squash"`
	Insecure                 bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	KeepAlive                bool          `mapstructure:"keepalive" toml:"keepalive" json:"keepalive"`
	KeepAlivePeriod          time.Duration `mapstructure:"keepalive_period" toml:"keepalive_period" json:"keepalive_period"`
	ConnTimeout              time.Duration `mapstructure:"connection_timeout" toml:"connection_timeout" json:"connection_timeout"`
	FlushPeriod              time.Duration `mapstructure:"flush_period" toml:"flush_period" json:"flush_period"`

	WindowSize  int32         `mapstructure:"window_size" toml:"window_size" json:"window_size"`
	RelpTimeout time.Duration `mapstructure:"relp_timeout" toml:"relp_timeout" json:"relp_timeout"`
}

type RELPSourceConfig 

type RELPSourceConfig struct {
	DecoderBaseConfig `mapstructure:",squash"`
	ListenersConfig   `mapstructure:",squash"`
	FilterSubConfig   `mapstructure:",squash"`
	TlsBaseConfig     `mapstructure:",squash"`
	ClientAuthType    string       `mapstructure:"client_auth_type" toml:"client_auth_type" json:"client_auth_type"`
	LineFraming       bool         `mapstructure:"line_framing" toml:"line_framing" json:"line_framing"`
	FrameDelimiter    string       `mapstructure:"delimiter" toml:"delimiter" json:"delimiter"`
	ConfID            utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
}

func (*RELPSourceConfig) DecoderConf 

func (c *RELPSourceConfig) DecoderConf() *DecoderBaseConfig

func (*RELPSourceConfig) DefaultPort 

func (c *RELPSourceConfig) DefaultPort() int

func (*RELPSourceConfig) Export 

func (c *RELPSourceConfig) Export() string

func (*RELPSourceConfig) FilterConf 

func (c *RELPSourceConfig) FilterConf() *FilterSubConfig

func (*RELPSourceConfig) GetClientAuthType 

func (c *RELPSourceConfig) GetClientAuthType() tls.ClientAuthType

func (*RELPSourceConfig) ListenersConf 

func (c *RELPSourceConfig) ListenersConf() *ListenersConfig

func (*RELPSourceConfig) SetConfID 

func (c *RELPSourceConfig) SetConfID()

type RedisDestConfig 

type RedisDestConfig struct {
	TlsBaseConfig `mapstructure:",squash"`
	Insecure      bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	Host          string        `mapstructure:"host" toml:"host" json:"host"`
	Port          int           `mapstructure:"port" toml:"port" json:"port"`
	Password      string        `mapstructure:"password" toml:"password" json:"password"`
	Rebind        time.Duration `mapstructure:"rebind" toml:"rebind" json:"rebind"`
	Format        string        `mapstructure:"format" toml:"format" json:"format"`
	Database      int           `mapstructure:"database" toml:"database" json:"database"`
	DialTimeout   time.Duration `mapstructure:"dial_timeout" toml:"dial_timeout" json:"dial_timeout"`
	ReadTimeout   time.Duration `mapstructure:"read_timeout" toml:"read_timeout" json:"read_timeout"`
	WriteTimeout  time.Duration `mapstructure:"write_timeout" toml:"write_timeout" json:"write_timeout"`
}

type Source 

type Source interface {
	FilterConf() *FilterSubConfig
	ListenersConf() *ListenersConfig
	DecoderConf() *DecoderBaseConfig
	DefaultPort() int
	SetConfID()
}

type StderrDestConfig 

type StderrDestConfig struct {
	Format string `mapstructure:"format" toml:"format" json:"format"`
}

type StoreConfig 

type StoreConfig struct {
	Dirname          string `mapstructure:"-" toml:"-" json:"dirname"`
	MaxTableSize     int64  `mapstructure:"max_table_size" toml:"max_table_size" json:"max_table_size"`
	ValueLogFileSize int64  `mapstructure:"value_log_file_size" toml:"value_log_file_size" json:"value_log_file_size"`
	FSync            bool   `mapstructure:"fsync" toml:"fsync" json:"fsync"`
	Secret           string `mapstructure:"secret" toml:"-" json:"secret"`
	BatchSize        uint32 `mapstructure:"batch_size" toml:"batch_size" json:"batch_size"`
	AddMissingMsgID  bool   `mapstructure:"add_missing_msgid" toml:"add_missing_msgid" json:"add_missing_msgid"`
}

func (*StoreConfig) DecryptSecret 

func (s *StoreConfig) DecryptSecret(m *memguard.LockedBuffer) (locked *memguard.LockedBuffer, err error)

func (*StoreConfig) EncryptSecret 

func (s *StoreConfig) EncryptSecret(m *memguard.LockedBuffer) error

func (*StoreConfig) GetSecretB 

func (s *StoreConfig) GetSecretB(m *memguard.LockedBuffer) (secretb *memguard.LockedBuffer, err error)

type TCPDestConfig 

type TCPDestConfig struct {
	TcpUdpRelpDestBaseConfig `mapstructure:",squash"`
	TlsBaseConfig            `mapstructure:",squash"`
	Insecure                 bool          `mapstructure:"insecure" toml:"insecure" json:"insecure"`
	KeepAlive                bool          `mapstructure:"keepalive" toml:"keepalive" json:"keepalive"`
	KeepAlivePeriod          time.Duration `mapstructure:"keepalive_period" toml:"keepalive_period" json:"keepalive_period"`
	ConnTimeout              time.Duration `mapstructure:"connection_timeout" toml:"connection_timeout" json:"connection_timeout"`
	FlushPeriod              time.Duration `mapstructure:"flush_period" toml:"flush_period" json:"flush_period"`

	LineFraming    bool  `mapstructure:"line_framing" toml:"line_framing" json:"line_framing"`
	FrameDelimiter uint8 `mapstructure:"delimiter" toml:"delimiter" json:"delimiter"`
}

type TCPSourceConfig 

type TCPSourceConfig struct {
	DecoderBaseConfig `mapstructure:",squash"`
	ListenersConfig   `mapstructure:",squash"`
	FilterSubConfig   `mapstructure:",squash"`
	TlsBaseConfig     `mapstructure:",squash"`
	ClientAuthType    string       `mapstructure:"client_auth_type" toml:"client_auth_type" json:"client_auth_type"`
	LineFraming       bool         `mapstructure:"line_framing" toml:"line_framing" json:"line_framing"`
	FrameDelimiter    string       `mapstructure:"delimiter" toml:"delimiter" json:"delimiter"`
	ConfID            utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
}

func (*TCPSourceConfig) DecoderConf 

func (c *TCPSourceConfig) DecoderConf() *DecoderBaseConfig

func (*TCPSourceConfig) DefaultPort 

func (c *TCPSourceConfig) DefaultPort() int

func (*TCPSourceConfig) Export 

func (c *TCPSourceConfig) Export() string

func (*TCPSourceConfig) FilterConf 

func (c *TCPSourceConfig) FilterConf() *FilterSubConfig

func (*TCPSourceConfig) GetClientAuthType 

func (c *TCPSourceConfig) GetClientAuthType() tls.ClientAuthType

func (*TCPSourceConfig) ListenersConf 

func (c *TCPSourceConfig) ListenersConf() *ListenersConfig

func (*TCPSourceConfig) SetConfID 

func (c *TCPSourceConfig) SetConfID()

type TcpUdpRelpDestBaseConfig 

type TcpUdpRelpDestBaseConfig struct {
	Host           string        `mapstructure:"host" toml:"host" json:"host"`
	Port           int           `mapstructure:"port" toml:"port" json:"port"`
	UnixSocketPath string        `mapstructure:"unix_socket_path" toml:"unix_socket_path" json:"unix_socket_path"`
	Rebind         time.Duration `mapstructure:"rebind" toml:"rebind" json:"rebind"`
	Format         string        `mapstructure:"format" toml:"format" json:"format"`
}

type TlsBaseConfig 

type TlsBaseConfig struct {
	TLSEnabled bool   `mapstructure:"tls_enabled" toml:"tls_enabled" json:"tls_enabled"`
	CAFile     string `mapstructure:"ca_file" toml:"ca_file" json:"ca_file"`
	CAPath     string `mapstructure:"ca_path" toml:"ca_path" json:"ca_path"`
	KeyFile    string `mapstructure:"key_file" toml:"key_file" json:"key_file"`
	CertFile   string `mapstructure:"cert_file" toml:"cert_file" json:"cert_file"`
}

type UDPDestConfig 

type UDPDestConfig struct {
	TcpUdpRelpDestBaseConfig `mapstructure:",squash"`
}

type UDPSourceConfig 

type UDPSourceConfig struct {
	DecoderBaseConfig `mapstructure:",squash"`
	ListenersConfig   `mapstructure:",squash"`
	FilterSubConfig   `mapstructure:",squash"`
	ConfID            utils.MyULID `mapstructure:"-" toml:"-" json:"conf_id"`
}

func (*UDPSourceConfig) DecoderConf 

func (c *UDPSourceConfig) DecoderConf() *DecoderBaseConfig

func (*UDPSourceConfig) DefaultPort 

func (c *UDPSourceConfig) DefaultPort() int

func (*UDPSourceConfig) Export 

func (c *UDPSourceConfig) Export() string

func (*UDPSourceConfig) FilterConf 

func (c *UDPSourceConfig) FilterConf() *FilterSubConfig

func (*UDPSourceConfig) ListenersConf 

func (c *UDPSourceConfig) ListenersConf() *ListenersConfig

func (*UDPSourceConfig) SetConfID 

func (c *UDPSourceConfig) SetConfID()

type WatcherConfig 

type WatcherConfig struct {
	Filename string `mapstructure:"filename" toml:"filename" json:"filename"`
	Whence   int    `mapstructure:"whence" toml:"whence" json:"whence"`
}

type WebsocketServerDestConfig 

type WebsocketServerDestConfig struct {
	BindAddr    string `mapstructure:"bind_addr" toml:"bind_addr" json:"bind_addr"`
	Port        int    `mapstructure:"port" toml:"port" json:"port"`
	Format      string `mapstructure:"format" toml:"format" json:"format"`
	LogEndPoint string `mapstructure:"log_endpoint" toml:"log_endpoint" json:"log_endpoint"`
	WebEndPoint string `mapstructure:"web_endpoint" toml:"web_endpoint" json:"web_endpoint"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.