eventingester

Documentation

Index

• Constants
• type Config
  • func (c *Config) Validate() error
• type Handler
  • func NewHandler(log logrus.FieldLogger, clockDrift *time.Duration, ...) *Handler
  • func (h *Handler) Events(ctx context.Context, events []*xatu.DecoratedEvent, user *auth.User, ...) ([]*xatu.DecoratedEvent, error)
• type Ingester
  • func NewIngester(ctx context.Context, log logrus.FieldLogger, conf *Config, ...) (*Ingester, error)
  • func (e *Ingester) CreateEvents(ctx context.Context, req *xatu.CreateEventsRequest) (*xatu.CreateEventsResponse, error)
  • func (e *Ingester) CreateSinks() ([]output.Sink, error)
  • func (e *Ingester) Start(ctx context.Context, grpcServer *grpc.Server) error
  • func (e *Ingester) Stop(ctx context.Context) error
• type Metrics
  • func NewMetrics(namespace string) *Metrics
  • func (m *Metrics) AddDecoratedEventFromUserReceived(count int, user, group string)
  • func (m *Metrics) AddDecoratedEventReceived(count int, event, sentryID string)

Constants

const (
	ServiceType = "event-ingester"
)

Types

type Config

type Config struct {
	Enabled bool `yaml:"enabled" default:"false"`
	// Outputs is the list of sinks to use.
	Outputs []output.Config `yaml:"outputs"`
	// Authorization is the authorization configuration.
	Authorization auth.AuthorizationConfig `yaml:"authorization"`
	// ClientNameSalt is the salt to use for computing client names
	ClientNameSalt string `yaml:"clientNameSalt"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Handler

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

func NewHandler

func NewHandler(log logrus.FieldLogger, clockDrift *time.Duration, geoipProvider geoip.Provider, cache store.Cache, clientNameSalt string) *Handler

func (*Handler) Events

func (h *Handler) Events(ctx context.Context, events []*xatu.DecoratedEvent, user *auth.User, group *auth.Group) ([]*xatu.DecoratedEvent, error)

type Ingester

type Ingester struct {
	xatu.UnimplementedEventIngesterServer
	// contains filtered or unexported fields
}

func NewIngester

func NewIngester(ctx context.Context, log logrus.FieldLogger, conf *Config, clockDrift *time.Duration, geoipProvider geoip.Provider, cache store.Cache) (*Ingester, error)

func (*Ingester) CreateEvents

func (e *Ingester) CreateEvents(ctx context.Context, req *xatu.CreateEventsRequest) (*xatu.CreateEventsResponse, error)

func (*Ingester) CreateSinks

func (e *Ingester) CreateSinks() ([]output.Sink, error)

func (*Ingester) Start

func (e *Ingester) Start(ctx context.Context, grpcServer *grpc.Server) error

func (*Ingester) Stop

func (e *Ingester) Stop(ctx context.Context) error

type Metrics

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

func NewMetrics

func NewMetrics(namespace string) *Metrics

func (*Metrics) AddDecoratedEventFromUserReceived

func (m *Metrics) AddDecoratedEventFromUserReceived(count int, user, group string)

func (*Metrics) AddDecoratedEventReceived

func (m *Metrics) AddDecoratedEventReceived(count int, event, sentryID string)