client

Documentation

Index

• func TokenFor(tenantID string) uint32
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
• type TPClient
  • func New(clientCfg Config, tracepointRing ring.ReadRing, logger log.Logger) (*TPClient, error)
  • func (ts *TPClient) CreateTracepoint(ctx context.Context, req *deeppb.CreateTracepointRequest) (*deeppb.CreateTracepointResponse, error)
  • func (ts *TPClient) DeleteTracepoint(ctx context.Context, req *deeppb.DeleteTracepointRequest) (*deeppb.DeleteTracepointResponse, error)
  • func (ts *TPClient) ExecuteDeepQl(ctx context.Context, query string) (*deeppb.DeepQlResponse, error)
  • func (ts *TPClient) LoadTracepoints(ctx context.Context, req *deeppb.LoadTracepointRequest) (*deeppb.LoadTracepointResponse, error)

Functions

func TokenFor

func TokenFor(tenantID string) uint32

TokenFor generates a token used for finding ingesters from ring

Types

type Config

type Config struct {
	PoolConfig       ring_client.PoolConfig `yaml:"pool_config,omitempty"`
	RemoteTimeout    time.Duration          `yaml:"remote_timeout,omitempty"`
	GRPCClientConfig grpcclient.Config      `yaml:"grpc_client_config"`
}

func (*Config) RegisterFlags

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

RegisterFlags registers flags.

type TPClient

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

func New

func New(clientCfg Config, tracepointRing ring.ReadRing, logger log.Logger) (*TPClient, error)

func (*TPClient) CreateTracepoint

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

func (*TPClient) DeleteTracepoint

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

func (*TPClient) ExecuteDeepQl

func (ts *TPClient) ExecuteDeepQl(ctx context.Context, query string) (*deeppb.DeepQlResponse, error)

func (*TPClient) LoadTracepoints

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