tracepoint

README

Tracepoint

This module is responsible for handling requests for tracepoint data. This module works in a similar way to the querier, we create a worker to poll the fontend services for requests and then work each request here then return the response.

Documentation

Index

• Variables
• type Config
  • func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)
• type TPService
  • func New(cfg Config, store storage.Store, logger gkLog.Logger, ...) (*TPService, error)
  • func (ts *TPService) CreateTracepoint(ctx context.Context, req *deeppb.CreateTracepointRequest) (*deeppb.CreateTracepointResponse, error)
  • func (ts *TPService) DeleteTracepoint(ctx context.Context, req *deeppb.DeleteTracepointRequest) (*deeppb.DeleteTracepointResponse, error)
  • func (ts *TPService) ExecuteDeepQl(ctx context.Context, req *deeppb.DeepQlRequest) (*deeppb.DeepQlResponse, error)
  • func (ts *TPService) Flush()
  • func (ts *TPService) LoadTracepoints(ctx context.Context, req *deeppb.LoadTracepointRequest) (*deeppb.LoadTracepointResponse, error)
  • func (ts *TPService) TransferOut(context.Context) error

Variables

var ErrReadOnly = errors.New("tracepoint is shutting down")

ErrReadOnly is returned when we are shutting down

Types

type Config

type Config struct {
	LifecyclerConfig ring.LifecyclerConfig `yaml:"lifecycler,omitempty"`

	MaxBlockDuration     time.Duration `yaml:"max_block_duration"`
	MaxBlockBytes        uint64        `yaml:"max_block_bytes"`
	CompleteBlockTimeout time.Duration `yaml:"complete_block_timeout"`
	OverrideRingKey      string        `yaml:"override_ring_key"`

	Client client.Config `yaml:"client"`

	API api.Config `yaml:"api"`
}

Config for an ingester.

func (*Config) RegisterFlagsAndApplyDefaults

func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

RegisterFlagsAndApplyDefaults registers the flags.

type TPService

type TPService struct {
	services.Service
	deeppb.UnimplementedTracepointConfigServiceServer
	// contains filtered or unexported fields
}

func New

func New(cfg Config, store storage.Store, logger gkLog.Logger, reg prometheus.Registerer) (*TPService, error)

New will create a new TPService that handles reading and writing tracepoint changes to disk

func (*TPService) CreateTracepoint

func (ts *TPService) CreateTracepoint(ctx context.Context, req *deeppb.CreateTracepointRequest) (*deeppb.CreateTracepointResponse, error)

func (*TPService) DeleteTracepoint

func (ts *TPService) DeleteTracepoint(ctx context.Context, req *deeppb.DeleteTracepointRequest) (*deeppb.DeleteTracepointResponse, error)

func (*TPService) ExecuteDeepQl

func (ts *TPService) ExecuteDeepQl(ctx context.Context, req *deeppb.DeepQlRequest) (*deeppb.DeepQlResponse, error)

func (*TPService) Flush

func (ts *TPService) Flush()

func (*TPService) LoadTracepoints

func (ts *TPService) LoadTracepoints(ctx context.Context, req *deeppb.LoadTracepointRequest) (*deeppb.LoadTracepointResponse, error)

func (*TPService) TransferOut

func (ts *TPService) TransferOut(context.Context) error