config

Documentation

Index

• Constants
• func GetLocalRabbitMQCredentials(rabbitMQSalt string) (username, password string, err error)
• func Max(a, b int) int
• func Min(a, b int) int
• type CompressionType
  • func CompressionTypeFromString(typeString string) (CompressionType, error)
• type Configuration
  • func ParseConfig(fn string, rabbitMQSalt string) (Configuration, error)
  • func (config *Configuration) AMQPURL(censorPassword bool) string
  • func (config Configuration) FileExtensionForCompressionType() string
  • func (config *Configuration) GetAMQPTLSConfigFromConf() *tls.Config
  • func (config *Configuration) MoveFileToDebug(name string)
  • func (config *Configuration) ParseEventTypes(input *ini.File)
  • func (config *Configuration) ParseOAuthConfiguration(input *ini.File, errs *ConfigurationError)
  • func (config Configuration) WrapWriterWithCompressionSettings(writer io.WriteCloser) (FlushableWriteCloser, error)
• type ConfigurationError
  • func (e ConfigurationError) Error() string
• type FlushableWriteCloser
• type NOPFlushWrappedWriter
  • func (writer NOPFlushWrappedWriter) Flush() error

Constants

const (
	FileOutputType = iota
	S3OutputType
	OLDS3OutputType
	TCPOutputType
	UDPOutputType
	SyslogOutputType
	HTTPOutputType
	SplunkOutputType
	KafkaOutputType
)

const (
	LEEFOutputFormat = iota
	JSONOutputFormat
)

const DEFAULTEXITTIMEOUT = 7

const DEFAULTLOGBACKUPS = 7

const DEFAULTLOGLOCATION = "/var/log/cb/integrations/cb-event-forwarder"

const DEFAULTLOGRETAINDAYS = 21

const DEFAULTLOGSIZE = 50

const MAXLOGBACKUPS = 30

const MAXLOGSIZE = 500

Functions

func GetLocalRabbitMQCredentials

func GetLocalRabbitMQCredentials(rabbitMQSalt string) (username, password string, err error)

func Max

func Max(a, b int) int

func Min

func Min(a, b int) int

Types

type CompressionType

type CompressionType string

const (
	LZ4COMPRESSION  CompressionType = "LZ4"
	GZIPCOMPRESSION CompressionType = "GZIP"
	NOCOMPRESSION   CompressionType = "NONE"
)

func CompressionTypeFromString

func CompressionTypeFromString(typeString string) (CompressionType, error)

type Configuration

type Configuration struct {
	ServerName           string
	AMQPHostname         string
	DebugFlag            bool
	DebugStore           string
	OutputType           int
	OutputFormat         int
	AMQPUsername         string
	AMQPPassword         string
	AMQPPort             int
	AMQPTLSEnabled       bool
	AMQPTLSClientKey     string
	AMQPTLSClientCert    string
	AMQPTLSCACert        string
	AMQPQueueName        string
	AMQPAutomaticAcking  bool
	OutputParameters     string
	EventTypes           []string
	EventMap             map[string]bool
	HTTPServerPort       int
	CbServerURL          string
	UseRawSensorExchange bool

	// DRY RUN CONTROLS REAL OUTPUT - WHEN DRYRUN IS TRUE, REAL OUTPUT WILL NOT OCCUR
	DryRun bool
	// CannedInput bool CONTROLS REAL INPUT - WHEN CANNEDINPUT IS TRUE, bundles from stress_rabbit will be used instead
	CannedInput         bool
	CannedInputLocation *string
	// RunConsumer bool
	// Controls whether or not a rabbitmq consumer is bound
	RunConsumer bool

	// this is a hack for S3 specific configuration
	S3ServerSideEncryption  *string
	S3CredentialProfileName *string
	S3ACLPolicy             *string
	S3ObjectPrefix          *string
	S3Endpoint              *string
	S3UseDualStack          bool
	S3Concurrency           int

	// SSL/TLS-specific configuration
	TLSClientKey  *string
	TLSClientCert *string
	TLSCACert     *string
	TLSVerify     bool
	TLSCName      *string
	TLS12Only     bool

	// HTTP-specific configuration
	HTTPAuthorizationToken *string
	HTTPPostTemplate       *template.Template
	HTTPContentType        *string
	OAuthJwtClientEmail    string
	OAuthJwtPrivateKey     []byte
	OAuthJwtPrivateKeyId   string
	OAuthJwtScopes         []string
	OAuthJwtTokenUrl       string

	EventTextAsJsonByteArray bool

	CompressHTTPPayload bool

	// configuration options common to bundled outputs (S3, HTTP)
	UploadEmptyFiles    bool
	CommaSeparateEvents bool
	BundleSendTimeout   time.Duration
	BundleSizeMax       int64

	// Compress data on S3 or file output types
	FileHandlerCompressData bool
	CompressionLevel        int
	CompressionType         CompressionType

	TLSConfig *tls.Config

	// Kafka-specific configuration
	KafkaBrokers        *string
	KafkaTopicSuffix    string
	KafkaTopic          string
	KafkaUsername       string
	KafkaPassword       string
	KafkaMaxRequestSize int32

	KafkaCompressionType *string

	KafkaSSLKeyLocation *string

	KafkaSSLCertificateLocation *string
	KafkaSSLCALocation          *string

	KafkaAlgorithm       string
	KafkaUseTLSTransport bool

	// Splunkd
	SplunkToken *string

	RemoveFromOutput []string
	AuditLog         bool
	NumProcessors    int

	UseTimeFloat       bool
	ExitTimeoutSeconds time.Duration

	// graphite/carbon
	RunMetrics            bool
	CarbonMetricsEndpoint *string
	MetricTag             string

	//Logging
	LogLevel   log.Level
	LogDir     string
	LogSizeMB  int
	LogBackups int
	LogMaxAge  int
}

func ParseConfig

func ParseConfig(fn string, rabbitMQSalt string) (Configuration, error)

func (*Configuration) AMQPURL

func (config *Configuration) AMQPURL(censorPassword bool) string

func (Configuration) FileExtensionForCompressionType

func (config Configuration) FileExtensionForCompressionType() string

func (*Configuration) GetAMQPTLSConfigFromConf

func (config *Configuration) GetAMQPTLSConfigFromConf() *tls.Config

func (*Configuration) MoveFileToDebug

func (config *Configuration) MoveFileToDebug(name string)

func (*Configuration) ParseEventTypes

func (config *Configuration) ParseEventTypes(input *ini.File)

func (*Configuration) ParseOAuthConfiguration

func (config *Configuration) ParseOAuthConfiguration(input *ini.File, errs *ConfigurationError)

parseOAuthConfiguration parses OAuth related configuration from input and populates config with relevant fields.

func (Configuration) WrapWriterWithCompressionSettings

func (config Configuration) WrapWriterWithCompressionSettings(writer io.WriteCloser) (FlushableWriteCloser, error)

type ConfigurationError

type ConfigurationError struct {
	Errors []string
	Empty  bool
}

func (ConfigurationError) Error

func (e ConfigurationError) Error() string

type FlushableWriteCloser

type FlushableWriteCloser interface {
	Close() error
	Flush() error
	Write(buf []byte) (int, error)
}

type NOPFlushWrappedWriter

type NOPFlushWrappedWriter struct {
	io.WriteCloser
}

func (NOPFlushWrappedWriter) Flush

func (writer NOPFlushWrappedWriter) Flush() error