Documentation
¶
Index ¶
- Constants
- type Config
- type Handler
- type Ingester
- func (e *Ingester) CreateEvents(ctx context.Context, req *xatu.CreateEventsRequest) (*xatu.CreateEventsResponse, error)
- func (e *Ingester) CreateSinks() ([]output.Sink, error)
- func (e *Ingester) Name() string
- func (e *Ingester) Start(ctx context.Context, grpcServer *grpc.Server) error
- func (e *Ingester) Stop(ctx context.Context) error
- type Metrics
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"`
}
type Ingester ¶
type Ingester struct {
xatu.UnimplementedEventIngesterServer
// contains filtered or unexported fields
}
func NewIngester ¶
func (*Ingester) CreateEvents ¶
func (e *Ingester) CreateEvents(ctx context.Context, req *xatu.CreateEventsRequest) (*xatu.CreateEventsResponse, error)
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
func NewMetrics ¶
func (*Metrics) AddDecoratedEventFromUserReceived ¶ added in v0.0.202
func (*Metrics) AddDecoratedEventReceived ¶
Click to show internal directories.
Click to hide internal directories.