sinks

type Avro struct {
	SchemaID string `yaml:"schemaID"`
	Schema   string `yaml:"schema"`
	// contains filtered or unexported fields
}

type BatchSink interface {
	Sink
	SendBatch([]*kube.EnhancedEvent) error
}

type BigQueryConfig struct {
	// BigQuery table config
	Location string `yaml:"location"`
	Project  string `yaml:"project"`
	Dataset  string `yaml:"dataset"`
	Table    string `yaml:"table"`

	// Path to a JSON file that contains your service account key.
	CredentialsPath string `yaml:"credentials_path"`

	// Batching config
	BatchSize       int `yaml:"batch_size"`
	MaxRetries      int `yaml:"max_retries"`
	IntervalSeconds int `yaml:"interval_seconds"`
	TimeoutSeconds  int `yaml:"timeout_seconds"`
}

type BigQuerySink struct {
	// contains filtered or unexported fields
}

type Elasticsearch struct {
	// contains filtered or unexported fields
}

type ElasticsearchConfig struct {
	// Connection specific
	Hosts    []string `yaml:"hosts"`
	Username string   `yaml:"username"`
	Password string   `yaml:"password"`
	CloudID  string   `yaml:"cloudID"`
	APIKey   string   `yaml:"apiKey"`
	// Indexing preferences
	UseEventID bool `yaml:"useEventID"`
	// DeDot all labels and annotations in the event. For both the event and the involvedObject
	DeDot       bool                   `yaml:"deDot"`
	Index       string                 `yaml:"index"`
	IndexFormat string                 `yaml:"indexFormat"`
	Type        string                 `yaml:"type"`
	TLS         TLS                    `yaml:"tls"`
	Layout      map[string]interface{} `yaml:"layout"`
}

type EventBridgeConfig struct {
	DetailType   string                 `yaml:"detailType"`
	Details      map[string]interface{} `yaml:"details"`
	Source       string                 `yaml:"source"`
	EventBusName string                 `yaml:"eventBusName"`
	Region       string                 `yaml:"region"`
}

type EventBridgeSink struct {
	// contains filtered or unexported fields
}

type File struct {
	// contains filtered or unexported fields
}

type FileConfig struct {
	Path       string                 `yaml:"path"`
	Layout     map[string]interface{} `yaml:"layout"`
	MaxSize    int                    `yaml:"maxsize"`
	MaxAge     int                    `yaml:"maxage"`
	MaxBackups int                    `yaml:"maxbackups"`
}

type FirehoseConfig struct {
	DeliveryStreamName string                 `yaml:"deliveryStreamName"`
	Region             string                 `yaml:"region"`
	Layout             map[string]interface{} `yaml:"layout"`
}

type FirehoseSink struct {
	// contains filtered or unexported fields
}

type InMemory struct {
	Events []*kube.EnhancedEvent
	Config *InMemoryConfig
}

type InMemoryConfig struct {
	Ref *InMemory
}

type KafkaConfig struct {
	Topic            string                 `yaml:"topic"`
	Brokers          []string               `yaml:"brokers"`
	Layout           map[string]interface{} `yaml:"layout"`
	ClientId         string                 `yaml:"clientId"`
	CompressionCodec string                 `yaml:"compressionCodec" default:"none"`
	TLS              struct {
		Enable             bool   `yaml:"enable"`
		CaFile             string `yaml:"caFile"`
		CertFile           string `yaml:"certFile"`
		KeyFile            string `yaml:"keyFile"`
		InsecureSkipVerify bool   `yaml:"insecureSkipVerify"`
	} `yaml:"tls"`
	SASL struct {
		Enable   bool   `yaml:"enable"`
		Username string `yaml:"username"`
		Password string `yaml:"password"`
	} `yaml:"sasl"`
	KafkaEncode Avro `yaml:"avro"`
}

type KafkaEncoder interface {
	// contains filtered or unexported methods
}

type KafkaSink struct {
	// contains filtered or unexported fields
}

type KinesisConfig struct {
	StreamName string                 `yaml:"streamName"`
	Region     string                 `yaml:"region"`
	Layout     map[string]interface{} `yaml:"layout"`
}

type KinesisSink struct {
	// contains filtered or unexported fields
}

type OpsCenterConfig struct {
	Category        string            `yaml:"category"`
	Description     string            `yaml:"description"`
	Notifications   []string          `yaml:"notifications"`
	OperationalData map[string]string `yaml:"operationalData"`
	Priority        string            `yaml:"priority"`
	Region          string            `yaml:"region"`
	RelatedOpsItems []string          `yaml:"relatedOpsItems"`
	Severity        string            `yaml:"severity"`
	Source          string            `yaml:"source"`
	Tags            map[string]string `yaml:"tags"`
	Title           string            `yaml:"title"`
}

type OpsCenterSink struct {
	// contains filtered or unexported fields
}

type OpsgenieConfig struct {
	ApiKey      string            `yaml:"apiKey"`
	URL         client.ApiUrl     `yaml:"URL"`
	Priority    string            `yaml:"priority"`
	Message     string            `yaml:"message"`
	Alias       string            `yaml:"alias"`
	Description string            `yaml:"description"`
	Tags        []string          `yaml:"tags"`
	Details     map[string]string `yaml:"details"`
}

type OpsgenieSink struct {
	// contains filtered or unexported fields
}

type Pipe struct {
	// contains filtered or unexported fields
}

type PipeConfig struct {
	Path   string                 `yaml:"path"`
	Layout map[string]interface{} `yaml:"layout"`
}

type PubsubConfig struct {
	GcloudProjectId string `yaml:"gcloud_project_id"`
	Topic           string `yaml:"topic"`
	CreateTopic     bool   `yaml:"create_topic"`
}

type PubsubSink struct {
	// contains filtered or unexported fields
}

type ReceiverConfig struct {
	Name          string               `yaml:"name"`
	InMemory      *InMemoryConfig      `yaml:"inMemory"`
	Webhook       *WebhookConfig       `yaml:"webhook"`
	File          *FileConfig          `yaml:"file"`
	Syslog        *SyslogConfig        `yaml:"syslog"`
	Stdout        *StdoutConfig        `yaml:"stdout"`
	Elasticsearch *ElasticsearchConfig `yaml:"elasticsearch"`
	Kinesis       *KinesisConfig       `yaml:"kinesis"`
	Firehose      *FirehoseConfig      `yaml:"firehose"`
	Opsgenie      *OpsgenieConfig      `yaml:"opsgenie"`
	SQS           *SQSConfig           `yaml:"sqs"`
	SNS           *SNSConfig           `yaml:"sns"`
	Slack         *SlackConfig         `yaml:"slack"`
	Kafka         *KafkaConfig         `yaml:"kafka"`
	Pubsub        *PubsubConfig        `yaml:"pubsub"`
	Opscenter     *OpsCenterConfig     `yaml:"opscenter"`
	Teams         *TeamsConfig         `yaml:"teams"`
	BigQuery      *BigQueryConfig      `yaml:"bigquery"`
	EventBridge   *EventBridgeConfig   `yaml:"eventbridge"`
	Pipe          *PipeConfig          `yaml:"pipe"`
}

type SNSConfig struct {
	TopicARN string                 `yaml:"topicARN"`
	Region   string                 `yaml:"region"`
	Layout   map[string]interface{} `yaml:"layout"`
}

type SNSSink struct {
	// contains filtered or unexported fields
}

type SQSConfig struct {
	QueueName string                 `yaml:"queueName"`
	Region    string                 `yaml:"region"`
	Layout    map[string]interface{} `yaml:"layout"`
}

type SQSSink struct {
	// contains filtered or unexported fields
}

type Sink interface {
	Send(ctx context.Context, ev *kube.EnhancedEvent) error
	Close()
}

type SlackConfig struct {
	Token      string            `yaml:"token"`
	Channel    string            `yaml:"channel"`
	Message    string            `yaml:"message"`
	Color      string            `yaml:"color"`
	Footer     string            `yaml:"footer"`
	Title      string            `yaml:"title"`
	AuthorName string            `yaml:"author_name"`
	Fields     map[string]string `yaml:"fields"`
}

type SlackSink struct {
	// contains filtered or unexported fields
}

type Stdout struct {
	// contains filtered or unexported fields
}

type StdoutConfig struct {
	Layout map[string]interface{} `yaml:"layout"`
}

type SyslogConfig struct {
	Network string `yaml:"network"`
	Address string `yaml:"address"`
	Tag     string `yaml:"tag"`
}

type SyslogSink struct {
	// contains filtered or unexported fields
}

type TLS struct {
	InsecureSkipVerify bool   `yaml:"insecureSkipVerify"`
	ServerName         string `yaml:"serverName"`
	CaFile             string `yaml:"caFile"`
	KeyFile            string `yaml:"keyFile"`
	CertFile           string `yaml:"certFile"`
}

type Teams struct {
	// contains filtered or unexported fields
}

type TeamsConfig struct {
	Endpoint string                 `yaml:"endpoint"`
	Layout   map[string]interface{} `yaml:"layout"`
	Headers  map[string]string      `yaml:"headers"`
}

type Webhook struct {
	// contains filtered or unexported fields
}

type WebhookConfig struct {
	Endpoint string                 `yaml:"endpoint"`
	TLS      TLS                    `yaml:"tls"`
	Layout   map[string]interface{} `yaml:"layout"`
	Headers  map[string]string      `yaml:"headers"`
}