status

type GRPCClient ¶

type GRPCClient struct {
	// contains filtered or unexported fields
}

func NewGRPCClient(ss statuspb.StatusServer) *GRPCClient

func (gc *GRPCClient) TSDBStatistics(ctx context.Context, req *statuspb.TSDBStatisticsRequest) (map[string]*statuspb.TSDBStatisticsEntry, annotations.Annotations, error)

type Proxy ¶

type Proxy struct {
	// contains filtered or unexported fields
}

Proxy implements statuspb.Status gRPC that fanouts requests to given statuspb.Status servers.

func NewProxy(logger log.Logger, statusClients func() []statuspb.StatusClient) *Proxy

func (s *Proxy) TSDBStatistics(req *statuspb.TSDBStatisticsRequest, srv statuspb.Status_TSDBStatisticsServer) error

type Server ¶

type Server struct {
	// contains filtered or unexported fields
}

Server implements the corresponding protobuf interface to provide status information about the given component.

func NewServer(
	component string,
	options ...ServerOptionFunc,
) *Server

func (srv *Server) TSDBStatistics(r *statuspb.TSDBStatisticsRequest, s statuspb.Status_TSDBStatisticsServer) error

type ServerOptionFunc ¶

type ServerOptionFunc func(*Server)

ServerOptionFunc represents a functional option to configure the status server.

type TSDBStatisticsGetter ¶

type TSDBStatisticsGetter interface {
	// TSDBStatistics returns the TSDB statistics for the given tenant.
	// When tenantID is empty, it returns statistics for all tenants.
	TSDBStatistics(limit int, tenantID string) (map[string]tsdb.Stats, error)
}

TSDBStatisticsGetter is an interface to retrieve TSDB statistics.

type TSDBStatisticsGetterFunc ¶

type TSDBStatisticsGetterFunc func(int, string) (map[string]tsdb.Stats, error)

func (f TSDBStatisticsGetterFunc) TSDBStatistics(limit int, tenantID string) (map[string]tsdb.Stats, error)

type UnaryClient ¶

type UnaryClient interface {
	TSDBStatistics(context.Context, *statuspb.TSDBStatisticsRequest) (map[string]*statuspb.TSDBStatisticsEntry, annotations.Annotations, error)
}

UnaryClient is a gRPC statuspb.Status client which expands the streaming status API. Useful for consumers that does not support streaming.