Documentation
¶
Index ¶
- func ParseRequest(logger gokit.Logger, userID string, 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 ¶
func ParseRequest(logger gokit.Logger, userID string, 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, configs *runtime.TenantConfigs, 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 ¶
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 ¶
type ReadLifecycler interface {
HealthyInstancesCount() int
}
ReadLifecycler represents the read interface to the lifecycler.
type Validator ¶
type Validator struct {
Limits
}
func NewValidator ¶
func NewValidator(l Limits) (*Validator, error)
func (Validator) ValidateEntry ¶
func (v Validator) ValidateEntry(ctx validationContext, labels string, entry logproto.Entry) error
ValidateEntry returns an error if the entry is invalid
func (Validator) ValidateLabels ¶
func (v Validator) ValidateLabels(ctx validationContext, ls labels.Labels, stream logproto.Stream) error
Validate labels returns an error if the labels are invalid
Source Files
Click to show internal directories.
Click to hide internal directories.