eventingester

package
v1.0.22 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: GPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ServiceType = "event-ingester"
)

Variables

This section is empty.

Functions

This section is empty.

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 (*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 added in v0.0.202

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

func (*Metrics) AddDecoratedEventReceived

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL