store

Documentation

Index

• func NewGRPCAppendable(logger log.Logger, c storepb.WritableProfileStoreClient) *grpcStoreAppendable
• func NewGRPCQueryable(c storepb.ReadableProfileStoreClient) *grpcStoreClient
• func NewProfileStore(logger log.Logger, db db, maxBytesPerFrame int) *profileStore
• func RegisterReadableStoreServer(storeSrv storepb.ReadableProfileStoreServer) func(*grpc.Server)
• func RegisterSymbolStore(storeSrv storepb.SymbolStoreServer) func(*grpc.Server)
• func RegisterWritableStoreServer(storeSrv storepb.WritableProfileStoreServer) func(*grpc.Server)
• type EndlessProfileStore
  • func NewEndlessProfileStore() *EndlessProfileStore
  • func (s *EndlessProfileStore) LabelNames(ctx context.Context, r *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)
  • func (s *EndlessProfileStore) LabelValues(ctx context.Context, r *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)
  • func (s *EndlessProfileStore) Profile(ctx context.Context, r *storepb.ProfileRequest) (*storepb.ProfileResponse, error)
  • func (s *EndlessProfileStore) Series(r *storepb.SeriesRequest, srv storepb.ReadableProfileStore_SeriesServer) error
  • func (s *EndlessProfileStore) Write(ctx context.Context, r *storepb.WriteRequest) (*storepb.WriteResponse, error)

Functions

func NewGRPCAppendable

func NewGRPCAppendable(logger log.Logger, c storepb.WritableProfileStoreClient) *grpcStoreAppendable

func NewGRPCQueryable

func NewGRPCQueryable(c storepb.ReadableProfileStoreClient) *grpcStoreClient

func NewProfileStore

func NewProfileStore(logger log.Logger, db db, maxBytesPerFrame int) *profileStore

func RegisterReadableStoreServer

func RegisterReadableStoreServer(storeSrv storepb.ReadableProfileStoreServer) func(*grpc.Server)

func RegisterSymbolStore

func RegisterSymbolStore(storeSrv storepb.SymbolStoreServer) func(*grpc.Server)

func RegisterWritableStoreServer

func RegisterWritableStoreServer(storeSrv storepb.WritableProfileStoreServer) func(*grpc.Server)

Types

type EndlessProfileStore

type EndlessProfileStore struct{}

EndlessProfileStore is a no-op writable store and returns infinite amounts of series when reading. This is meant for testing timeout issues.

func NewEndlessProfileStore

func NewEndlessProfileStore() *EndlessProfileStore

func (*EndlessProfileStore) LabelNames

func (s *EndlessProfileStore) LabelNames(ctx context.Context, r *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

func (*EndlessProfileStore) LabelValues

func (s *EndlessProfileStore) LabelValues(ctx context.Context, r *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)

func (*EndlessProfileStore) Profile

func (s *EndlessProfileStore) Profile(ctx context.Context, r *storepb.ProfileRequest) (*storepb.ProfileResponse, error)

func (*EndlessProfileStore) Series

func (s *EndlessProfileStore) Series(r *storepb.SeriesRequest, srv storepb.ReadableProfileStore_SeriesServer) error

func (*EndlessProfileStore) Write

func (s *EndlessProfileStore) Write(ctx context.Context, r *storepb.WriteRequest) (*storepb.WriteResponse, error)