Versions in this module Expand all Collapse all v1 v1.1.4 Jan 1, 2018 Changes in this version + const URLPrefix + func MakeDataKey(name string, source string, r Resolution, timestamp int64) roachpb.Key + type DB struct + func NewDB(db *client.DB) *DB + func (db *DB) PollSource(ambient log.AmbientContext, source DataSource, frequency time.Duration, ...) + func (db *DB) Query(ctx context.Context, query tspb.Query, queryResolution Resolution, ...) ([]tspb.TimeSeriesDatapoint, []string, error) + func (db *DB) StoreData(ctx context.Context, r Resolution, data []tspb.TimeSeriesData) error + func (tsdb *DB) ContainsTimeSeries(start, end roachpb.RKey) bool + func (tsdb *DB) PruneTimeSeries(ctx context.Context, snapshot engine.Reader, start, end roachpb.RKey, ...) error + type DataSource interface + GetTimeSeriesData func() []tspb.TimeSeriesData + type Resolution int64 + const Resolution10s + func DecodeDataKey(key roachpb.Key) (string, string, Resolution, int64, error) + func (r Resolution) PruneThreshold() int64 + func (r Resolution) SampleDuration() int64 + func (r Resolution) SlabDuration() int64 + func (r Resolution) String() string + type Server struct + func MakeServer(ambient log.AmbientContext, db *DB, cfg ServerConfig, stopper *stop.Stopper) Server + func (s *Server) Query(ctx context.Context, request *tspb.TimeSeriesQueryRequest) (*tspb.TimeSeriesQueryResponse, error) + func (s *Server) RegisterGateway(ctx context.Context, mux *gwruntime.ServeMux, conn *grpc.ClientConn) error + func (s *Server) RegisterService(g *grpc.Server) + type ServerConfig struct + QueryWorkerMax int
Go to main page