Documentation
¶
Index ¶
- func ParseRequest(r *http.Request) (*logproto.PushRequest, error)
- type Config
- type Distributor
- func (*Distributor) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
- func (d *Distributor) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error)
- func (d *Distributor) PushHandler(w http.ResponseWriter, r *http.Request)
- type Limits
- type ReadLifecycler
- type Validator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseRequest ¶ added in v1.6.0
func ParseRequest(r *http.Request) (*logproto.PushRequest, error)
Types ¶
type Config ¶
type Config struct {
// Distributors ring
DistributorRing cortex_distributor.RingConfig `yaml:"ring,omitempty"`
// contains filtered or unexported fields
}
Config for a Distributor.
func (*Config) RegisterFlags ¶
func (cfg *Config) RegisterFlags(f *flag.FlagSet)
RegisterFlags registers the flags.
type Distributor ¶
type Distributor struct {
services.Service
// contains filtered or unexported fields
}
Distributor coordinates replicates and distribution of log streams.
func New ¶
func New(cfg Config, clientCfg client.Config, ingestersRing ring.ReadRing, overrides *validation.Overrides, registerer prometheus.Registerer) (*Distributor, error)
New a distributor creates.
func (*Distributor) Check ¶
func (*Distributor) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
Check implements the grpc healthcheck
func (*Distributor) Push ¶
func (d *Distributor) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error)
Push a set of streams.
func (*Distributor) PushHandler ¶
func (d *Distributor) PushHandler(w http.ResponseWriter, r *http.Request)
PushHandler reads a snappy-compressed proto from the HTTP body.
type Limits ¶ added in v1.4.0
type Limits interface {
MaxLineSize(userID string) int
EnforceMetricName(userID string) bool
MaxLabelNamesPerSeries(userID string) int
MaxLabelNameLength(userID string) int
MaxLabelValueLength(userID string) int
CreationGracePeriod(userID string) time.Duration
RejectOldSamples(userID string) bool
RejectOldSamplesMaxAge(userID string) time.Duration
}
Limits is an interface for distributor limits/related configs
type ReadLifecycler ¶ added in v1.3.0
type ReadLifecycler interface {
HealthyInstancesCount() int
}
ReadLifecycler represents the read interface to the lifecycler.
type Validator ¶ added in v1.4.0
type Validator struct {
Limits
}
func NewValidator ¶ added in v1.4.0
func NewValidator(l Limits) (*Validator, error)
func (Validator) ValidateEntry ¶ added in v1.4.0
func (v Validator) ValidateEntry(userID string, labels string, entry logproto.Entry) error
ValidateEntry returns an error if the entry is invalid
func (Validator) ValidateLabels ¶ added in v1.4.0
func (v Validator) ValidateLabels(userID string, stream logproto.Stream) error
Validate labels returns an error if the labels are invalid
Click to show internal directories.
Click to hide internal directories.