storegatewayv1connect

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 10, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// StoreGatewayServiceMergeProfilesStacktracesProcedure is the fully-qualified name of the
	// StoreGatewayService's MergeProfilesStacktraces RPC.
	StoreGatewayServiceMergeProfilesStacktracesProcedure = "/storegateway.v1.StoreGatewayService/MergeProfilesStacktraces"
	// StoreGatewayServiceMergeProfilesLabelsProcedure is the fully-qualified name of the
	// StoreGatewayService's MergeProfilesLabels RPC.
	StoreGatewayServiceMergeProfilesLabelsProcedure = "/storegateway.v1.StoreGatewayService/MergeProfilesLabels"
	// StoreGatewayServiceMergeProfilesPprofProcedure is the fully-qualified name of the
	// StoreGatewayService's MergeProfilesPprof RPC.
	StoreGatewayServiceMergeProfilesPprofProcedure = "/storegateway.v1.StoreGatewayService/MergeProfilesPprof"
	// StoreGatewayServiceMergeSpanProfileProcedure is the fully-qualified name of the
	// StoreGatewayService's MergeSpanProfile RPC.
	StoreGatewayServiceMergeSpanProfileProcedure = "/storegateway.v1.StoreGatewayService/MergeSpanProfile"
	// StoreGatewayServiceProfileTypesProcedure is the fully-qualified name of the StoreGatewayService's
	// ProfileTypes RPC.
	StoreGatewayServiceProfileTypesProcedure = "/storegateway.v1.StoreGatewayService/ProfileTypes"
	// StoreGatewayServiceLabelValuesProcedure is the fully-qualified name of the StoreGatewayService's
	// LabelValues RPC.
	StoreGatewayServiceLabelValuesProcedure = "/storegateway.v1.StoreGatewayService/LabelValues"
	// StoreGatewayServiceLabelNamesProcedure is the fully-qualified name of the StoreGatewayService's
	// LabelNames RPC.
	StoreGatewayServiceLabelNamesProcedure = "/storegateway.v1.StoreGatewayService/LabelNames"
	// StoreGatewayServiceSeriesProcedure is the fully-qualified name of the StoreGatewayService's
	// Series RPC.
	StoreGatewayServiceSeriesProcedure = "/storegateway.v1.StoreGatewayService/Series"
	// StoreGatewayServiceBlockMetadataProcedure is the fully-qualified name of the
	// StoreGatewayService's BlockMetadata RPC.
	StoreGatewayServiceBlockMetadataProcedure = "/storegateway.v1.StoreGatewayService/BlockMetadata"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// StoreGatewayServiceName is the fully-qualified name of the StoreGatewayService service.
	StoreGatewayServiceName = "storegateway.v1.StoreGatewayService"
)

Variables

This section is empty.

Functions

func NewStoreGatewayServiceHandler 

func NewStoreGatewayServiceHandler(svc StoreGatewayServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewStoreGatewayServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func RegisterStoreGatewayServiceHandler 

func RegisterStoreGatewayServiceHandler(mux *mux.Router, svc StoreGatewayServiceHandler, opts ...connect.HandlerOption)

RegisterStoreGatewayServiceHandler register an HTTP handler to a mux.Router from the service implementation.

Types

type StoreGatewayServiceClient 

type StoreGatewayServiceClient interface {
	MergeProfilesStacktraces(context.Context) *connect.BidiStreamForClient[v11.MergeProfilesStacktracesRequest, v11.MergeProfilesStacktracesResponse]
	MergeProfilesLabels(context.Context) *connect.BidiStreamForClient[v11.MergeProfilesLabelsRequest, v11.MergeProfilesLabelsResponse]
	MergeProfilesPprof(context.Context) *connect.BidiStreamForClient[v11.MergeProfilesPprofRequest, v11.MergeProfilesPprofResponse]
	MergeSpanProfile(context.Context) *connect.BidiStreamForClient[v11.MergeSpanProfileRequest, v11.MergeSpanProfileResponse]
	ProfileTypes(context.Context, *connect.Request[v11.ProfileTypesRequest]) (*connect.Response[v11.ProfileTypesResponse], error)
	LabelValues(context.Context, *connect.Request[v12.LabelValuesRequest]) (*connect.Response[v12.LabelValuesResponse], error)
	LabelNames(context.Context, *connect.Request[v12.LabelNamesRequest]) (*connect.Response[v12.LabelNamesResponse], error)
	Series(context.Context, *connect.Request[v11.SeriesRequest]) (*connect.Response[v11.SeriesResponse], error)
	BlockMetadata(context.Context, *connect.Request[v11.BlockMetadataRequest]) (*connect.Response[v11.BlockMetadataResponse], error)
}

StoreGatewayServiceClient is a client for the storegateway.v1.StoreGatewayService service.

func NewStoreGatewayServiceClient 

func NewStoreGatewayServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) StoreGatewayServiceClient

NewStoreGatewayServiceClient constructs a client for the storegateway.v1.StoreGatewayService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type StoreGatewayServiceHandler 

type StoreGatewayServiceHandler interface {
	MergeProfilesStacktraces(context.Context, *connect.BidiStream[v11.MergeProfilesStacktracesRequest, v11.MergeProfilesStacktracesResponse]) error
	MergeProfilesLabels(context.Context, *connect.BidiStream[v11.MergeProfilesLabelsRequest, v11.MergeProfilesLabelsResponse]) error
	MergeProfilesPprof(context.Context, *connect.BidiStream[v11.MergeProfilesPprofRequest, v11.MergeProfilesPprofResponse]) error
	MergeSpanProfile(context.Context, *connect.BidiStream[v11.MergeSpanProfileRequest, v11.MergeSpanProfileResponse]) error
	ProfileTypes(context.Context, *connect.Request[v11.ProfileTypesRequest]) (*connect.Response[v11.ProfileTypesResponse], error)
	LabelValues(context.Context, *connect.Request[v12.LabelValuesRequest]) (*connect.Response[v12.LabelValuesResponse], error)
	LabelNames(context.Context, *connect.Request[v12.LabelNamesRequest]) (*connect.Response[v12.LabelNamesResponse], error)
	Series(context.Context, *connect.Request[v11.SeriesRequest]) (*connect.Response[v11.SeriesResponse], error)
	BlockMetadata(context.Context, *connect.Request[v11.BlockMetadataRequest]) (*connect.Response[v11.BlockMetadataResponse], error)
}

StoreGatewayServiceHandler is an implementation of the storegateway.v1.StoreGatewayService service.

type UnimplementedStoreGatewayServiceHandler 

type UnimplementedStoreGatewayServiceHandler struct{}

UnimplementedStoreGatewayServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedStoreGatewayServiceHandler) BlockMetadata added in v0.3.0 

func (UnimplementedStoreGatewayServiceHandler) BlockMetadata(context.Context, *connect.Request[v11.BlockMetadataRequest]) (*connect.Response[v11.BlockMetadataResponse], error)

func (UnimplementedStoreGatewayServiceHandler) LabelNames added in v0.3.0 

func (UnimplementedStoreGatewayServiceHandler) LabelNames(context.Context, *connect.Request[v12.LabelNamesRequest]) (*connect.Response[v12.LabelNamesResponse], error)

func (UnimplementedStoreGatewayServiceHandler) LabelValues added in v0.3.0 

func (UnimplementedStoreGatewayServiceHandler) LabelValues(context.Context, *connect.Request[v12.LabelValuesRequest]) (*connect.Response[v12.LabelValuesResponse], error)

func (UnimplementedStoreGatewayServiceHandler) MergeProfilesLabels 

func (UnimplementedStoreGatewayServiceHandler) MergeProfilesLabels(context.Context, *connect.BidiStream[v11.MergeProfilesLabelsRequest, v11.MergeProfilesLabelsResponse]) error

func (UnimplementedStoreGatewayServiceHandler) MergeProfilesPprof 

func (UnimplementedStoreGatewayServiceHandler) MergeProfilesPprof(context.Context, *connect.BidiStream[v11.MergeProfilesPprofRequest, v11.MergeProfilesPprofResponse]) error

func (UnimplementedStoreGatewayServiceHandler) MergeProfilesStacktraces 

func (UnimplementedStoreGatewayServiceHandler) MergeProfilesStacktraces(context.Context, *connect.BidiStream[v11.MergeProfilesStacktracesRequest, v11.MergeProfilesStacktracesResponse]) error

func (UnimplementedStoreGatewayServiceHandler) MergeSpanProfile added in v0.2.1 

func (UnimplementedStoreGatewayServiceHandler) MergeSpanProfile(context.Context, *connect.BidiStream[v11.MergeSpanProfileRequest, v11.MergeSpanProfileResponse]) error

func (UnimplementedStoreGatewayServiceHandler) ProfileTypes added in v0.3.0 

func (UnimplementedStoreGatewayServiceHandler) ProfileTypes(context.Context, *connect.Request[v11.ProfileTypesRequest]) (*connect.Response[v11.ProfileTypesResponse], error)

func (UnimplementedStoreGatewayServiceHandler) Series added in v0.2.1 

func (UnimplementedStoreGatewayServiceHandler) Series(context.Context, *connect.Request[v11.SeriesRequest]) (*connect.Response[v11.SeriesResponse], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.