elasticsearch

Documentation

Index

• type ElasticSearchFieldGroup
  • func NewElasticSearchFieldGroup(fullConfig map[string]interface{}) (*ElasticSearchFieldGroup, error)
  • func (fg *ElasticSearchFieldGroup) Fields() []string
  • func (fg *ElasticSearchFieldGroup) Validate(opts shared.Options) []shared.ValidationError
• type ElasticsearchConfigStruct
  • func NewElasticsearchConfigStruct(fullConfig map[string]interface{}) (*ElasticsearchConfigStruct, error)
• type IndexSettingsStruct
  • func NewIndexSettingsStruct(fullConfig map[string]interface{}) (*IndexSettingsStruct, error)
• type KafkaConfigStruct
  • func NewKafkaConfigStruct(fullConfig map[string]interface{}) (*KafkaConfigStruct, error)
• type KinesisStreamConfigStruct
  • func NewKinesisStreamConfigStruct(fullConfig map[string]interface{}) (*KinesisStreamConfigStruct, error)
• type LogsModelConfigStruct
  • func NewLogsModelConfigStruct(fullConfig map[string]interface{}) (*LogsModelConfigStruct, error)

Types

type ElasticSearchFieldGroup

type ElasticSearchFieldGroup struct {
	LogsModel       string                 `default:"database" validate:"" json:"LOGS_MODEL,omitempty" yaml:"LOGS_MODEL,omitempty"`
	LogsModelConfig *LogsModelConfigStruct `default:"" validate:"" json:"LOGS_MODEL_CONFIG,omitempty" yaml:"LOGS_MODEL_CONFIG,omitempty"`
}

ElasticSearchFieldGroup represents the ElasticSearchFieldGroup config fields

func NewElasticSearchFieldGroup

func NewElasticSearchFieldGroup(fullConfig map[string]interface{}) (*ElasticSearchFieldGroup, error)

NewElasticSearchFieldGroup creates a new ElasticSearchFieldGroup

func (*ElasticSearchFieldGroup) Fields

func (fg *ElasticSearchFieldGroup) Fields() []string

Fields returns a list of strings representing the fields in this field group

func (*ElasticSearchFieldGroup) Validate

func (fg *ElasticSearchFieldGroup) Validate(opts shared.Options) []shared.ValidationError

Validate checks the configuration settings for this field group

type ElasticsearchConfigStruct

type ElasticsearchConfigStruct struct {
	AwsRegion     string               `default:"" validate:"" json:"aws_region,omitempty" yaml:"aws_region,omitempty"`
	Port          int                  `default:"" validate:"" json:"port,omitempty" yaml:"port,omitempty"`
	AccessKey     string               `default:"" validate:"" json:"access_key,omitempty" yaml:"access_key,omitempty"`
	Host          string               `default:"" validate:"" json:"host,omitempty" yaml:"host,omitempty"`
	IndexPrefix   string               `default:"logentry_" validate:"" json:"index_prefix,omitempty" yaml:"index_prefix,omitempty"`
	IndexSettings *IndexSettingsStruct `default:"" validate:"" json:"index_settings,omitempty" yaml:"index_settings,omitempty"`
	UseSsl        bool                 `default:"true" validate:"" json:"use_ssl" yaml:"use_ssl"`
	SecretKey     string               `default:"" validate:"" json:"secret_key,omitempty" yaml:"secret_key,omitempty"`
}

ElasticsearchConfigStruct represents the ElasticsearchConfigStruct config fields

func NewElasticsearchConfigStruct

func NewElasticsearchConfigStruct(fullConfig map[string]interface{}) (*ElasticsearchConfigStruct, error)

NewElasticsearchConfigStruct creates a new ElasticsearchConfigStruct

type IndexSettingsStruct

type IndexSettingsStruct map[string]interface{}

IndexSettingsStruct represents the IndexSettings struct

func NewIndexSettingsStruct

func NewIndexSettingsStruct(fullConfig map[string]interface{}) (*IndexSettingsStruct, error)

NewIndexSettingsStruct creates a new IndexSettingsStruct

type KafkaConfigStruct

type KafkaConfigStruct struct {
	Topic            string        `default:"" validate:"" json:"topic,omitempty" yaml:"topic,omitempty"`
	BootstrapServers []interface{} `default:"" validate:"" json:"bootstrap_servers,omitempty" yaml:"bootstrap_servers,omitempty"`
	MaxBlockSeconds  int           `default:"" validate:"" json:"max_block_seconds,omitempty" yaml:"max_block_seconds,omitempty"`
}

KafkaConfigStruct represents the KafkaConfigStruct config fields

func NewKafkaConfigStruct

func NewKafkaConfigStruct(fullConfig map[string]interface{}) (*KafkaConfigStruct, error)

NewKafkaConfigStruct creates a new KafkaConfigStruct

type KinesisStreamConfigStruct

type KinesisStreamConfigStruct struct {
	Retries            int    `default:"" validate:"" json:"retries,omitempty" yaml:"retries,omitempty"`
	ReadTimeout        int    `default:"" validate:"" json:"read_timeout,omitempty" yaml:"read_timeout,omitempty"`
	MaxPoolConnections int    `default:"" validate:"" json:"max_pool_connections,omitempty" yaml:"max_pool_connections,omitempty"`
	AwsRegion          string `default:"" validate:"" json:"aws_region,omitempty" yaml:"aws_region,omitempty"`
	ConnectTimeout     int    `default:"" validate:"" json:"connect_timeout,omitempty" yaml:"connect_timeout,omitempty"`
	AwsSecretKey       string `default:"" validate:"" json:"aws_secret_key,omitempty" yaml:"aws_secret_key,omitempty"`
	StreamName         string `default:"" validate:"" json:"stream_name,omitempty" yaml:"stream_name,omitempty"`
	AwsAccessKey       string `default:"" validate:"" json:"aws_access_key,omitempty" yaml:"aws_access_key,omitempty"`
}

KinesisStreamConfigStruct represents the KinesisStreamConfigStruct config fields

func NewKinesisStreamConfigStruct

func NewKinesisStreamConfigStruct(fullConfig map[string]interface{}) (*KinesisStreamConfigStruct, error)

NewKinesisStreamConfigStruct creates a new KinesisStreamConfigStruct

type LogsModelConfigStruct

type LogsModelConfigStruct struct {
	KafkaConfig         *KafkaConfigStruct         `default:"" validate:"" json:"kafka_config,omitempty" yaml:"kafka_config,omitempty"`
	ElasticsearchConfig *ElasticsearchConfigStruct `default:"" validate:"" json:"elasticsearch_config,omitempty" yaml:"elasticsearch_config,omitempty"`
	KinesisStreamConfig *KinesisStreamConfigStruct `default:"" validate:"" json:"kinesis_stream_config,omitempty" yaml:"kinesis_stream_config,omitempty"`
	Producer            string                     `default:"" validate:"" json:"producer,omitempty" yaml:"producer,omitempty"`
}

LogsModelConfigStruct represents the LogsModelConfigStruct config fields

func NewLogsModelConfigStruct

func NewLogsModelConfigStruct(fullConfig map[string]interface{}) (*LogsModelConfigStruct, error)

NewLogsModelConfigStruct creates a new LogsModelConfigStruct