metastorev1connect

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// IndexServiceAddBlockProcedure is the fully-qualified name of the IndexService's AddBlock RPC.
	IndexServiceAddBlockProcedure = "/metastore.v1.IndexService/AddBlock"
	// IndexServiceGetBlockMetadataProcedure is the fully-qualified name of the IndexService's
	// GetBlockMetadata RPC.
	IndexServiceGetBlockMetadataProcedure = "/metastore.v1.IndexService/GetBlockMetadata"
)

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 (
	// MetadataQueryServiceQueryMetadataProcedure is the fully-qualified name of the
	// MetadataQueryService's QueryMetadata RPC.
	MetadataQueryServiceQueryMetadataProcedure = "/metastore.v1.MetadataQueryService/QueryMetadata"
	// MetadataQueryServiceQueryMetadataLabelsProcedure is the fully-qualified name of the
	// MetadataQueryService's QueryMetadataLabels RPC.
	MetadataQueryServiceQueryMetadataLabelsProcedure = "/metastore.v1.MetadataQueryService/QueryMetadataLabels"
)

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 (
	// TenantServiceGetTenantProcedure is the fully-qualified name of the TenantService's GetTenant RPC.
	TenantServiceGetTenantProcedure = "/metastore.v1.TenantService/GetTenant"
	// TenantServiceDeleteTenantProcedure is the fully-qualified name of the TenantService's
	// DeleteTenant RPC.
	TenantServiceDeleteTenantProcedure = "/metastore.v1.TenantService/DeleteTenant"
)

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 (
	// CompactionServiceName is the fully-qualified name of the CompactionService service.
	CompactionServiceName = "metastore.v1.CompactionService"
)
View Source 
const (
	// CompactionServicePollCompactionJobsProcedure is the fully-qualified name of the
	// CompactionService's PollCompactionJobs RPC.
	CompactionServicePollCompactionJobsProcedure = "/metastore.v1.CompactionService/PollCompactionJobs"
)

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 (
	// IndexServiceName is the fully-qualified name of the IndexService service.
	IndexServiceName = "metastore.v1.IndexService"
)
View Source 
const (
	// MetadataQueryServiceName is the fully-qualified name of the MetadataQueryService service.
	MetadataQueryServiceName = "metastore.v1.MetadataQueryService"
)
View Source 
const (
	// TenantServiceName is the fully-qualified name of the TenantService service.
	TenantServiceName = "metastore.v1.TenantService"
)

Variables

This section is empty.

Functions

func NewCompactionServiceHandler added in v1.1.0 

func NewCompactionServiceHandler(svc CompactionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCompactionServiceHandler 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 NewIndexServiceHandler added in v1.1.0 

func NewIndexServiceHandler(svc IndexServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewIndexServiceHandler 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 NewMetadataQueryServiceHandler added in v1.1.0 

func NewMetadataQueryServiceHandler(svc MetadataQueryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMetadataQueryServiceHandler 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 NewTenantServiceHandler added in v1.1.0 

func NewTenantServiceHandler(svc TenantServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTenantServiceHandler 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 RegisterCompactionServiceHandler added in v1.1.0 

func RegisterCompactionServiceHandler(mux *mux.Router, svc CompactionServiceHandler, opts ...connect.HandlerOption)

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

func RegisterIndexServiceHandler added in v1.1.0 

func RegisterIndexServiceHandler(mux *mux.Router, svc IndexServiceHandler, opts ...connect.HandlerOption)

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

func RegisterMetadataQueryServiceHandler added in v1.1.0 

func RegisterMetadataQueryServiceHandler(mux *mux.Router, svc MetadataQueryServiceHandler, opts ...connect.HandlerOption)

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

func RegisterTenantServiceHandler added in v1.1.0 

func RegisterTenantServiceHandler(mux *mux.Router, svc TenantServiceHandler, opts ...connect.HandlerOption)

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

Types

type CompactionServiceClient added in v1.1.0 

type CompactionServiceClient interface {
	// Used to both retrieve jobs and update the jobs status at the same time.
	PollCompactionJobs(context.Context, *connect.Request[v1.PollCompactionJobsRequest]) (*connect.Response[v1.PollCompactionJobsResponse], error)
}

CompactionServiceClient is a client for the metastore.v1.CompactionService service.

func NewCompactionServiceClient added in v1.1.0 

func NewCompactionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CompactionServiceClient

NewCompactionServiceClient constructs a client for the metastore.v1.CompactionService 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 CompactionServiceHandler added in v1.1.0 

type CompactionServiceHandler interface {
	// Used to both retrieve jobs and update the jobs status at the same time.
	PollCompactionJobs(context.Context, *connect.Request[v1.PollCompactionJobsRequest]) (*connect.Response[v1.PollCompactionJobsResponse], error)
}

CompactionServiceHandler is an implementation of the metastore.v1.CompactionService service.

type IndexServiceClient added in v1.1.0 

type IndexServiceClient interface {
	AddBlock(context.Context, *connect.Request[v1.AddBlockRequest]) (*connect.Response[v1.AddBlockResponse], error)
	GetBlockMetadata(context.Context, *connect.Request[v1.GetBlockMetadataRequest]) (*connect.Response[v1.GetBlockMetadataResponse], error)
}

IndexServiceClient is a client for the metastore.v1.IndexService service.

func NewIndexServiceClient added in v1.1.0 

func NewIndexServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) IndexServiceClient

NewIndexServiceClient constructs a client for the metastore.v1.IndexService 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 IndexServiceHandler added in v1.1.0 

type IndexServiceHandler interface {
	AddBlock(context.Context, *connect.Request[v1.AddBlockRequest]) (*connect.Response[v1.AddBlockResponse], error)
	GetBlockMetadata(context.Context, *connect.Request[v1.GetBlockMetadataRequest]) (*connect.Response[v1.GetBlockMetadataResponse], error)
}

IndexServiceHandler is an implementation of the metastore.v1.IndexService service.

type MetadataQueryServiceClient added in v1.1.0 

type MetadataQueryServiceClient interface {
	QueryMetadata(context.Context, *connect.Request[v1.QueryMetadataRequest]) (*connect.Response[v1.QueryMetadataResponse], error)
	QueryMetadataLabels(context.Context, *connect.Request[v1.QueryMetadataLabelsRequest]) (*connect.Response[v1.QueryMetadataLabelsResponse], error)
}

MetadataQueryServiceClient is a client for the metastore.v1.MetadataQueryService service.

func NewMetadataQueryServiceClient added in v1.1.0 

func NewMetadataQueryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MetadataQueryServiceClient

NewMetadataQueryServiceClient constructs a client for the metastore.v1.MetadataQueryService 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 MetadataQueryServiceHandler added in v1.1.0 

type MetadataQueryServiceHandler interface {
	QueryMetadata(context.Context, *connect.Request[v1.QueryMetadataRequest]) (*connect.Response[v1.QueryMetadataResponse], error)
	QueryMetadataLabels(context.Context, *connect.Request[v1.QueryMetadataLabelsRequest]) (*connect.Response[v1.QueryMetadataLabelsResponse], error)
}

MetadataQueryServiceHandler is an implementation of the metastore.v1.MetadataQueryService service.

type TenantServiceClient added in v1.1.0 

type TenantServiceClient interface {
	GetTenant(context.Context, *connect.Request[v1.GetTenantRequest]) (*connect.Response[v1.GetTenantResponse], error)
	DeleteTenant(context.Context, *connect.Request[v1.DeleteTenantRequest]) (*connect.Response[v1.DeleteTenantResponse], error)
}

TenantServiceClient is a client for the metastore.v1.TenantService service.

func NewTenantServiceClient added in v1.1.0 

func NewTenantServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TenantServiceClient

NewTenantServiceClient constructs a client for the metastore.v1.TenantService 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 TenantServiceHandler added in v1.1.0 

type TenantServiceHandler interface {
	GetTenant(context.Context, *connect.Request[v1.GetTenantRequest]) (*connect.Response[v1.GetTenantResponse], error)
	DeleteTenant(context.Context, *connect.Request[v1.DeleteTenantRequest]) (*connect.Response[v1.DeleteTenantResponse], error)
}

TenantServiceHandler is an implementation of the metastore.v1.TenantService service.

type UnimplementedCompactionServiceHandler added in v1.1.0 

type UnimplementedCompactionServiceHandler struct{}

UnimplementedCompactionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCompactionServiceHandler) PollCompactionJobs added in v1.1.0 

func (UnimplementedCompactionServiceHandler) PollCompactionJobs(context.Context, *connect.Request[v1.PollCompactionJobsRequest]) (*connect.Response[v1.PollCompactionJobsResponse], error)

type UnimplementedIndexServiceHandler added in v1.1.0 

type UnimplementedIndexServiceHandler struct{}

UnimplementedIndexServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedIndexServiceHandler) AddBlock added in v1.1.0 

func (UnimplementedIndexServiceHandler) AddBlock(context.Context, *connect.Request[v1.AddBlockRequest]) (*connect.Response[v1.AddBlockResponse], error)

func (UnimplementedIndexServiceHandler) GetBlockMetadata added in v1.1.0 

func (UnimplementedIndexServiceHandler) GetBlockMetadata(context.Context, *connect.Request[v1.GetBlockMetadataRequest]) (*connect.Response[v1.GetBlockMetadataResponse], error)

type UnimplementedMetadataQueryServiceHandler added in v1.1.0 

type UnimplementedMetadataQueryServiceHandler struct{}

UnimplementedMetadataQueryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMetadataQueryServiceHandler) QueryMetadata added in v1.1.0 

func (UnimplementedMetadataQueryServiceHandler) QueryMetadata(context.Context, *connect.Request[v1.QueryMetadataRequest]) (*connect.Response[v1.QueryMetadataResponse], error)

func (UnimplementedMetadataQueryServiceHandler) QueryMetadataLabels added in v1.1.0 

func (UnimplementedMetadataQueryServiceHandler) QueryMetadataLabels(context.Context, *connect.Request[v1.QueryMetadataLabelsRequest]) (*connect.Response[v1.QueryMetadataLabelsResponse], error)

type UnimplementedTenantServiceHandler added in v1.1.0 

type UnimplementedTenantServiceHandler struct{}

UnimplementedTenantServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTenantServiceHandler) DeleteTenant added in v1.1.0 

func (UnimplementedTenantServiceHandler) DeleteTenant(context.Context, *connect.Request[v1.DeleteTenantRequest]) (*connect.Response[v1.DeleteTenantResponse], error)

func (UnimplementedTenantServiceHandler) GetTenant added in v1.1.0 

func (UnimplementedTenantServiceHandler) GetTenant(context.Context, *connect.Request[v1.GetTenantRequest]) (*connect.Response[v1.GetTenantResponse], 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.
JackTT - Gopher 🇻🇳