Documentation
¶
Index ¶
- type Config
- type Ingester
- func (i *Ingester) CheckReady(ctx context.Context) error
- func (i *Ingester) Flush()
- func (i *Ingester) GetOrCreateInstance(instanceID string) (*instance, error)
- func (i *Ingester) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error)
- func (i *Ingester) Query(req *logproto.QueryPatternsRequest, stream logproto.Pattern_QueryServer) error
- func (i *Ingester) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (i *Ingester) TransferOut(_ context.Context) error
- func (*Ingester) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error
- type IngesterQuerier
- type ResponseFromIngesters
- type RingClient
- type Tee
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Enabled bool `yaml:"enabled,omitempty" doc:"description=Whether the pattern ingester is enabled."` LifecyclerConfig ring.LifecyclerConfig `` /* 153-byte string literal not displayed */ ClientConfig clientpool.Config `yaml:"client_config,omitempty" doc:"description=Configures how the pattern ingester will connect to the ingesters."` ConcurrentFlushes int `yaml:"concurrent_flushes"` FlushCheckPeriod time.Duration `yaml:"flush_check_period"` // contains filtered or unexported fields }
func (*Config) RegisterFlags ¶
RegisterFlags registers pattern ingester related flags.
type Ingester ¶
func New ¶
func New( cfg Config, metricsNamespace string, registerer prometheus.Registerer, logger log.Logger, ) (*Ingester, error)
func (*Ingester) CheckReady ¶
ReadinessHandler is used to indicate to k8s when the ingesters are ready for the addition removal of another ingester. Returns 204 when the ingester is ready, 500 otherwise.
func (*Ingester) GetOrCreateInstance ¶
func (*Ingester) Push ¶
func (i *Ingester) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error)
func (*Ingester) Query ¶
func (i *Ingester) Query(req *logproto.QueryPatternsRequest, stream logproto.Pattern_QueryServer) error
func (*Ingester) ServeHTTP ¶
func (i *Ingester) ServeHTTP(w http.ResponseWriter, r *http.Request)
ServeHTTP implements the pattern ring status page.
func (*Ingester) Watch ¶
func (*Ingester) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error
Watch implements grpc_health_v1.HealthCheck.
type IngesterQuerier ¶
type IngesterQuerier struct {
// contains filtered or unexported fields
}
func NewIngesterQuerier ¶
func NewIngesterQuerier( cfg Config, ringClient *RingClient, metricsNamespace string, registerer prometheus.Registerer, logger log.Logger, ) (*IngesterQuerier, error)
func (*IngesterQuerier) Patterns ¶
func (q *IngesterQuerier) Patterns(ctx context.Context, req *logproto.QueryPatternsRequest) (*logproto.QueryPatternsResponse, error)
type ResponseFromIngesters ¶
type ResponseFromIngesters struct {
// contains filtered or unexported fields
}
type RingClient ¶
func NewRingClient ¶
func NewRingClient( cfg Config, metricsNamespace string, registerer prometheus.Registerer, logger log.Logger, ) (*RingClient, error)
type Tee ¶
type Tee struct {
// contains filtered or unexported fields
}
func NewTee ¶
func NewTee( cfg Config, ringClient *RingClient, metricsNamespace string, registerer prometheus.Registerer, logger log.Logger, ) (*Tee, error)
func (*Tee) Duplicate ¶
func (t *Tee) Duplicate(tenant string, streams []distributor.KeyedStream)
Duplicate Implements distributor.Tee which is used to tee distributor requests to pattern ingesters.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.