storegatewaypb

Documentation

Index

• func RegisterStoreGatewayServer(s *grpc.Server, srv StoreGatewayServer)
• type StoreGatewayClient
  • func NewCustomStoreGatewayClient(cc *grpc.ClientConn) StoreGatewayClient
  • func NewStoreGatewayClient(cc *grpc.ClientConn) 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

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 NewCustomStoreGatewayClient

func NewCustomStoreGatewayClient(cc *grpc.ClientConn) StoreGatewayClient

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

func (*UnimplementedStoreGatewayServer) LabelNames(ctx context.Context, req *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error)

func (*UnimplementedStoreGatewayServer) LabelValues

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