elasticsearch

Documentation

Index

• func ValidateElasticSearchCredentials(url, accessKey, accessSecret string) bool
• type ElasticSearchFieldGroup
  • func NewElasticSearchFieldGroup(fullConfig map[string]interface{}) (*ElasticSearchFieldGroup, error)
  • func (fg *ElasticSearchFieldGroup) Fields() []string
  • func (fg *ElasticSearchFieldGroup) Validate() []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)

Functions

func ValidateElasticSearchCredentials

func ValidateElasticSearchCredentials(url, accessKey, accessSecret string) bool

ValidateElasticSearchCredentials will validate credentials

Types

type ElasticSearchFieldGroup

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

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() []shared.ValidationError

Validate checks the configuration settings for this field group

type ElasticsearchConfigStruct

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

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" yaml:"topic"`
	BootstrapServers []interface{} `default:"" validate:"" json:"bootstrap_servers" yaml:"bootstrap_servers"`
	MaxBlockSeconds  int           `default:"" validate:"" json:"max_block_seconds" yaml:"max_block_seconds"`
}

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" yaml:"retries"`
	ReadTimeout        int    `default:"" validate:"" json:"read_timeout" yaml:"read_timeout"`
	MaxPoolConnections int    `default:"" validate:"" json:"max_pool_connections" yaml:"max_pool_connections"`
	AwsRegion          string `default:"" validate:"" json:"aws_region" yaml:"aws_region"`
	ConnectTimeout     int    `default:"" validate:"" json:"connect_timeout" yaml:"connect_timeout"`
	AwsSecretKey       string `default:"" validate:"" json:"aws_secret_key" yaml:"aws_secret_key"`
	StreamName         string `default:"" validate:"" json:"stream_name" yaml:"stream_name"`
	AwsAccessKey       string `default:"" validate:"" json:"aws_access_key" yaml:"aws_access_key"`
}

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" yaml:"kafka_config"`
	ElasticsearchConfig *ElasticsearchConfigStruct `default:"" validate:"" json:"elasticsearch_config" yaml:"elasticsearch_config"`
	KinesisStreamConfig *KinesisStreamConfigStruct `default:"" validate:"" json:"kinesis_stream_config" yaml:"kinesis_stream_config"`
	Producer            string                     `default:"" validate:"" json:"producer" yaml:"producer"`
}

LogsModelConfigStruct represents the LogsModelConfigStruct config fields

func NewLogsModelConfigStruct

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

NewLogsModelConfigStruct creates a new LogsModelConfigStruct