enginev1connect

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// OfflineStoreServiceGetQueryLogEntriesProcedure is the fully-qualified name of the
	// OfflineStoreService's GetQueryLogEntries RPC.
	OfflineStoreServiceGetQueryLogEntriesProcedure = "/chalk.engine.v1.OfflineStoreService/GetQueryLogEntries"
	// OfflineStoreServiceGetQueryValuesProcedure is the fully-qualified name of the
	// OfflineStoreService's GetQueryValues RPC.
	OfflineStoreServiceGetQueryValuesProcedure = "/chalk.engine.v1.OfflineStoreService/GetQueryValues"
)

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 (
	// PlanServiceGetPlanProcedure is the fully-qualified name of the PlanService's GetPlan RPC.
	PlanServiceGetPlanProcedure = "/chalk.engine.v1.PlanService/GetPlan"
	// PlanServiceExecuteQueryProcedure is the fully-qualified name of the PlanService's ExecuteQuery
	// RPC.
	PlanServiceExecuteQueryProcedure = "/chalk.engine.v1.PlanService/ExecuteQuery"
)

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 (
	// QueryServicePingProcedure is the fully-qualified name of the QueryService's Ping RPC.
	QueryServicePingProcedure = "/chalk.engine.v1.QueryService/Ping"
	// QueryServiceOnlineQueryProcedure is the fully-qualified name of the QueryService's OnlineQuery
	// RPC.
	QueryServiceOnlineQueryProcedure = "/chalk.engine.v1.QueryService/OnlineQuery"
	// QueryServiceOnlineQueryBulkProcedure is the fully-qualified name of the QueryService's
	// OnlineQueryBulk RPC.
	QueryServiceOnlineQueryBulkProcedure = "/chalk.engine.v1.QueryService/OnlineQueryBulk"
	// QueryServiceOnlineQueryMultiProcedure is the fully-qualified name of the QueryService's
	// OnlineQueryMulti RPC.
	QueryServiceOnlineQueryMultiProcedure = "/chalk.engine.v1.QueryService/OnlineQueryMulti"
	// QueryServiceUploadFeaturesBulkProcedure is the fully-qualified name of the QueryService's
	// UploadFeaturesBulk RPC.
	QueryServiceUploadFeaturesBulkProcedure = "/chalk.engine.v1.QueryService/UploadFeaturesBulk"
	// QueryServicePlanAggregateBackfillProcedure is the fully-qualified name of the QueryService's
	// PlanAggregateBackfill RPC.
	QueryServicePlanAggregateBackfillProcedure = "/chalk.engine.v1.QueryService/PlanAggregateBackfill"
	// QueryServiceGetAggregatesProcedure is the fully-qualified name of the QueryService's
	// GetAggregates RPC.
	QueryServiceGetAggregatesProcedure = "/chalk.engine.v1.QueryService/GetAggregates"
)

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 (
	// OfflineStoreServiceName is the fully-qualified name of the OfflineStoreService service.
	OfflineStoreServiceName = "chalk.engine.v1.OfflineStoreService"
)
View Source 
const (
	// PlanServiceName is the fully-qualified name of the PlanService service.
	PlanServiceName = "chalk.engine.v1.PlanService"
)
View Source 
const (
	// QueryServiceName is the fully-qualified name of the QueryService service.
	QueryServiceName = "chalk.engine.v1.QueryService"
)

Variables

This section is empty.

Functions

func NewOfflineStoreServiceHandler added in v0.10.0 

func NewOfflineStoreServiceHandler(svc OfflineStoreServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewOfflineStoreServiceHandler 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 NewPlanServiceHandler 

func NewPlanServiceHandler(svc PlanServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewPlanServiceHandler 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 NewQueryServiceHandler 

func NewQueryServiceHandler(svc QueryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewQueryServiceHandler 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.

Types

type OfflineStoreServiceClient added in v0.10.0 

type OfflineStoreServiceClient interface {
	GetQueryLogEntries(context.Context, *connect.Request[v11.GetQueryLogEntriesRequest]) (*connect.Response[v11.GetQueryLogEntriesResponse], error)
	GetQueryValues(context.Context, *connect.Request[v11.GetQueryValuesRequest]) (*connect.Response[v11.GetQueryValuesResponse], error)
}

OfflineStoreServiceClient is a client for the chalk.engine.v1.OfflineStoreService service.

func NewOfflineStoreServiceClient added in v0.10.0 

func NewOfflineStoreServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) OfflineStoreServiceClient

NewOfflineStoreServiceClient constructs a client for the chalk.engine.v1.OfflineStoreService 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 OfflineStoreServiceHandler added in v0.10.0 

type OfflineStoreServiceHandler interface {
	GetQueryLogEntries(context.Context, *connect.Request[v11.GetQueryLogEntriesRequest]) (*connect.Response[v11.GetQueryLogEntriesResponse], error)
	GetQueryValues(context.Context, *connect.Request[v11.GetQueryValuesRequest]) (*connect.Response[v11.GetQueryValuesResponse], error)
}

OfflineStoreServiceHandler is an implementation of the chalk.engine.v1.OfflineStoreService service.

type PlanServiceClient 

type PlanServiceClient interface {
	GetPlan(context.Context, *connect.Request[v1.GetPlanRequest]) (*connect.Response[v1.GetPlanResponse], error)
	// Fall-back for executing queries on the python engine
	ExecuteQuery(context.Context, *connect.Request[v1.ExecuteQueryRequest]) (*connect.Response[v1.ExecuteQueryResponse], error)
}

PlanServiceClient is a client for the chalk.engine.v1.PlanService service.

func NewPlanServiceClient 

func NewPlanServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PlanServiceClient

NewPlanServiceClient constructs a client for the chalk.engine.v1.PlanService 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 PlanServiceHandler 

type PlanServiceHandler interface {
	GetPlan(context.Context, *connect.Request[v1.GetPlanRequest]) (*connect.Response[v1.GetPlanResponse], error)
	// Fall-back for executing queries on the python engine
	ExecuteQuery(context.Context, *connect.Request[v1.ExecuteQueryRequest]) (*connect.Response[v1.ExecuteQueryResponse], error)
}

PlanServiceHandler is an implementation of the chalk.engine.v1.PlanService service.

type QueryServiceClient 

type QueryServiceClient interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	OnlineQuery(context.Context, *connect.Request[v11.OnlineQueryRequest]) (*connect.Response[v11.OnlineQueryResponse], error)
	OnlineQueryBulk(context.Context, *connect.Request[v11.OnlineQueryBulkRequest]) (*connect.Response[v11.OnlineQueryBulkResponse], error)
	OnlineQueryMulti(context.Context, *connect.Request[v11.OnlineQueryMultiRequest]) (*connect.Response[v11.OnlineQueryMultiResponse], error)
	UploadFeaturesBulk(context.Context, *connect.Request[v11.UploadFeaturesBulkRequest]) (*connect.Response[v11.UploadFeaturesBulkResponse], error)
	// PlanAggregateBackfill determines the estimated resources needed to backfill
	// an aggregate.
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	PlanAggregateBackfill(context.Context, *connect.Request[v12.PlanAggregateBackfillRequest]) (*connect.Response[v12.PlanAggregateBackfillResponse], error)
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	GetAggregates(context.Context, *connect.Request[v12.GetAggregatesRequest]) (*connect.Response[v12.GetAggregatesResponse], error)
}

QueryServiceClient is a client for the chalk.engine.v1.QueryService service.

func NewQueryServiceClient 

func NewQueryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) QueryServiceClient

NewQueryServiceClient constructs a client for the chalk.engine.v1.QueryService 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 QueryServiceHandler 

type QueryServiceHandler interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	OnlineQuery(context.Context, *connect.Request[v11.OnlineQueryRequest]) (*connect.Response[v11.OnlineQueryResponse], error)
	OnlineQueryBulk(context.Context, *connect.Request[v11.OnlineQueryBulkRequest]) (*connect.Response[v11.OnlineQueryBulkResponse], error)
	OnlineQueryMulti(context.Context, *connect.Request[v11.OnlineQueryMultiRequest]) (*connect.Response[v11.OnlineQueryMultiResponse], error)
	UploadFeaturesBulk(context.Context, *connect.Request[v11.UploadFeaturesBulkRequest]) (*connect.Response[v11.UploadFeaturesBulkResponse], error)
	// PlanAggregateBackfill determines the estimated resources needed to backfill
	// an aggregate.
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	PlanAggregateBackfill(context.Context, *connect.Request[v12.PlanAggregateBackfillRequest]) (*connect.Response[v12.PlanAggregateBackfillResponse], error)
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	GetAggregates(context.Context, *connect.Request[v12.GetAggregatesRequest]) (*connect.Response[v12.GetAggregatesResponse], error)
}

QueryServiceHandler is an implementation of the chalk.engine.v1.QueryService service.

type UnimplementedOfflineStoreServiceHandler added in v0.10.0 

type UnimplementedOfflineStoreServiceHandler struct{}

UnimplementedOfflineStoreServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedOfflineStoreServiceHandler) GetQueryLogEntries added in v0.10.0 

func (UnimplementedOfflineStoreServiceHandler) GetQueryLogEntries(context.Context, *connect.Request[v11.GetQueryLogEntriesRequest]) (*connect.Response[v11.GetQueryLogEntriesResponse], error)

func (UnimplementedOfflineStoreServiceHandler) GetQueryValues added in v0.10.0 

func (UnimplementedOfflineStoreServiceHandler) GetQueryValues(context.Context, *connect.Request[v11.GetQueryValuesRequest]) (*connect.Response[v11.GetQueryValuesResponse], error)

type UnimplementedPlanServiceHandler 

type UnimplementedPlanServiceHandler struct{}

UnimplementedPlanServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedPlanServiceHandler) ExecuteQuery 

func (UnimplementedPlanServiceHandler) ExecuteQuery(context.Context, *connect.Request[v1.ExecuteQueryRequest]) (*connect.Response[v1.ExecuteQueryResponse], error)

func (UnimplementedPlanServiceHandler) GetPlan 

func (UnimplementedPlanServiceHandler) GetPlan(context.Context, *connect.Request[v1.GetPlanRequest]) (*connect.Response[v1.GetPlanResponse], error)

type UnimplementedQueryServiceHandler 

type UnimplementedQueryServiceHandler struct{}

UnimplementedQueryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedQueryServiceHandler) GetAggregates added in v0.14.6 

func (UnimplementedQueryServiceHandler) GetAggregates(context.Context, *connect.Request[v12.GetAggregatesRequest]) (*connect.Response[v12.GetAggregatesResponse], error)

func (UnimplementedQueryServiceHandler) OnlineQuery 

func (UnimplementedQueryServiceHandler) OnlineQuery(context.Context, *connect.Request[v11.OnlineQueryRequest]) (*connect.Response[v11.OnlineQueryResponse], error)

func (UnimplementedQueryServiceHandler) OnlineQueryBulk added in v0.5.0 

func (UnimplementedQueryServiceHandler) OnlineQueryBulk(context.Context, *connect.Request[v11.OnlineQueryBulkRequest]) (*connect.Response[v11.OnlineQueryBulkResponse], error)

func (UnimplementedQueryServiceHandler) OnlineQueryMulti added in v0.7.7 

func (UnimplementedQueryServiceHandler) OnlineQueryMulti(context.Context, *connect.Request[v11.OnlineQueryMultiRequest]) (*connect.Response[v11.OnlineQueryMultiResponse], error)

func (UnimplementedQueryServiceHandler) Ping 

func (UnimplementedQueryServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)

func (UnimplementedQueryServiceHandler) PlanAggregateBackfill added in v0.14.6 

func (UnimplementedQueryServiceHandler) PlanAggregateBackfill(context.Context, *connect.Request[v12.PlanAggregateBackfillRequest]) (*connect.Response[v12.PlanAggregateBackfillResponse], error)

func (UnimplementedQueryServiceHandler) UploadFeaturesBulk added in v0.13.2 

func (UnimplementedQueryServiceHandler) UploadFeaturesBulk(context.Context, *connect.Request[v11.UploadFeaturesBulkRequest]) (*connect.Response[v11.UploadFeaturesBulkResponse], 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.