server

Documentation

Index

• func NewBigQuerySink(config BigQueryConfig) (*bigQuerySink, error)
• func NewChannelSink(ch chan types.Event) *chanSink
• func NewLogSink() *logSink
• func NewServer(config ServerConfig) *server
• type BigQueryConfig
  • func (c BigQueryConfig) Check() error
• type ServerConfig
• type Sink

Functions

func NewBigQuerySink

func NewBigQuerySink(config BigQueryConfig) (*bigQuerySink, error)

NewBigQuerySink returns a new Google BigQuery events sink

func NewChannelSink

func NewChannelSink(ch chan types.Event) *chanSink

NewChannelSink returns a new sink that submits events into the provided channel

func NewLogSink

func NewLogSink() *logSink

NewLogSink returns a new sink that just logs events

func NewServer

func NewServer(config ServerConfig) *server

NewServer returns a new reporting gRPC server

Types

type BigQueryConfig

type BigQueryConfig struct {
	// ProjectID is the GCP project ID. Note that proper authentication should
	// be setup as described in
	// https://cloud.google.com/docs/authentication/getting-started
	ProjectID string `json:"projectID"`
}

BigQueryConfig is config for Google BigQuery sink

func (BigQueryConfig) Check

func (c BigQueryConfig) Check() error

Check makes sure that BigQuery sink config is valid

type ServerConfig

type ServerConfig struct {
	// Sinks is the list of event sinks
	Sinks []Sink
}

ServerConfig defines the reporting server config

type Sink

type Sink interface {
	// Put saves a series of events
	Put([]types.Event) error
}

Sink defines an event sink interface