Documentation
¶
Index ¶
- func RegisterStoreGatewayServer(s *grpc.Server, srv StoreGatewayServer)
- type StoreGatewayClient
- type StoreGatewayServer
- type StoreGateway_SeriesClient
- type StoreGateway_SeriesServer
- type UnimplementedStoreGatewayServer
- func (*UnimplementedStoreGatewayServer) LabelNames(ctx context.Context, req *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)
- func (*UnimplementedStoreGatewayServer) LabelValues(ctx context.Context, req *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)
- func (*UnimplementedStoreGatewayServer) Series(req *storepb.SeriesRequest, srv StoreGateway_SeriesServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterStoreGatewayServer ¶
func RegisterStoreGatewayServer(s *grpc.Server, srv StoreGatewayServer)
Types ¶
type StoreGatewayClient ¶
type StoreGatewayClient interface {
// Series streams each Series for given label matchers and time range.
//
// Series should strictly stream full series after series, optionally split by time. This means that a single frame can contain
// partition of the single series, but once a new series is started to be streamed it means that no more data will
// be sent for previous one.
//
// Series are sorted.
Series(ctx context.Context, in *storepb.SeriesRequest, opts ...grpc.CallOption) (StoreGateway_SeriesClient, error)
// LabelNames returns all label names that is available.
LabelNames(ctx context.Context, in *storepb.LabelNamesRequest, opts ...grpc.CallOption) (*storepb.LabelNamesResponse, error)
// LabelValues returns all label values for given label name.
LabelValues(ctx context.Context, in *storepb.LabelValuesRequest, opts ...grpc.CallOption) (*storepb.LabelValuesResponse, error)
}
StoreGatewayClient is the client API for StoreGateway service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStoreGatewayClient ¶
func NewStoreGatewayClient(cc *grpc.ClientConn) StoreGatewayClient
type StoreGatewayServer ¶
type StoreGatewayServer interface {
// Series streams each Series for given label matchers and time range.
//
// Series should strictly stream full series after series, optionally split by time. This means that a single frame can contain
// partition of the single series, but once a new series is started to be streamed it means that no more data will
// be sent for previous one.
//
// Series are sorted.
Series(*storepb.SeriesRequest, StoreGateway_SeriesServer) error
// LabelNames returns all label names that is available.
LabelNames(context.Context, *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)
// LabelValues returns all label values for given label name.
LabelValues(context.Context, *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)
}
StoreGatewayServer is the server API for StoreGateway service.
type StoreGateway_SeriesClient ¶
type StoreGateway_SeriesClient interface {
Recv() (*storepb.SeriesResponse, error)
grpc.ClientStream
}
type StoreGateway_SeriesServer ¶
type StoreGateway_SeriesServer interface {
Send(*storepb.SeriesResponse) error
grpc.ServerStream
}
type UnimplementedStoreGatewayServer ¶
type UnimplementedStoreGatewayServer struct {
}
UnimplementedStoreGatewayServer can be embedded to have forward compatible implementations.
func (*UnimplementedStoreGatewayServer) LabelNames ¶ added in v1.6.0
func (*UnimplementedStoreGatewayServer) LabelNames(ctx context.Context, req *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)
func (*UnimplementedStoreGatewayServer) LabelValues ¶ added in v1.6.0
func (*UnimplementedStoreGatewayServer) LabelValues(ctx context.Context, req *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error)
func (*UnimplementedStoreGatewayServer) Series ¶
func (*UnimplementedStoreGatewayServer) Series(req *storepb.SeriesRequest, srv StoreGateway_SeriesServer) error
Click to show internal directories.
Click to hide internal directories.