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
- type TPService
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrReadOnly = errors.New("tracepoint is shutting down")
ErrReadOnly is returned when we are shutting down
Functions ¶
This section is empty.
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.
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) LoadTracepoints ¶
func (ts *TPService) LoadTracepoints(ctx context.Context, req *deeppb.LoadTracepointRequest) (*deeppb.LoadTracepointResponse, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.