pattern

Documentation

Index

• type Config
  • func (cfg *Config) RegisterFlags(fs *flag.FlagSet)
  • func (cfg *Config) Validate() error
• type Ingester
  • func New(cfg Config, metricsNamespace string, registerer prometheus.Registerer, ...) (*Ingester, error)
  • 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
  • func NewIngesterQuerier(cfg Config, ringClient *RingClient, metricsNamespace string, ...) (*IngesterQuerier, error)
  • func (q *IngesterQuerier) Patterns(ctx context.Context, req *logproto.QueryPatternsRequest) (*logproto.QueryPatternsResponse, error)
• type ResponseFromIngesters
• type RingClient
  • func NewRingClient(cfg Config, metricsNamespace string, registerer prometheus.Registerer, ...) (*RingClient, error)
• type Tee
  • func NewTee(cfg Config, ringClient *RingClient, metricsNamespace string, ...) (*Tee, error)
  • func (t *Tee) Duplicate(tenant string, streams []distributor.KeyedStream)

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

func (cfg *Config) RegisterFlags(fs *flag.FlagSet)

RegisterFlags registers pattern ingester related flags.

func (*Config) Validate

func (cfg *Config) Validate() error

type Ingester

type Ingester struct {
	services.Service
	// contains filtered or unexported fields
}

func New

func New(
	cfg Config,
	metricsNamespace string,
	registerer prometheus.Registerer,
	logger log.Logger,
) (*Ingester, error)

func (*Ingester) CheckReady

func (i *Ingester) CheckReady(ctx context.Context) error

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) Flush

func (i *Ingester) Flush()

func (*Ingester) GetOrCreateInstance

func (i *Ingester) GetOrCreateInstance(instanceID string) (*instance, error)

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) TransferOut

func (i *Ingester) TransferOut(_ context.Context) error

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

type RingClient struct {
	services.Service
	// contains filtered or unexported fields
}

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.