provisionerconnect

package
v0.386.3 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ProvisionerPluginServicePingProcedure is the fully-qualified name of the
	// ProvisionerPluginService's Ping RPC.
	ProvisionerPluginServicePingProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService/Ping"
	// ProvisionerPluginServiceProvisionProcedure is the fully-qualified name of the
	// ProvisionerPluginService's Provision RPC.
	ProvisionerPluginServiceProvisionProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService/Provision"
	// ProvisionerPluginServicePlanProcedure is the fully-qualified name of the
	// ProvisionerPluginService's Plan RPC.
	ProvisionerPluginServicePlanProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService/Plan"
	// ProvisionerPluginServiceStatusProcedure is the fully-qualified name of the
	// ProvisionerPluginService's Status RPC.
	ProvisionerPluginServiceStatusProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService/Status"
)

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 (
	// ProvisionerServicePingProcedure is the fully-qualified name of the ProvisionerService's Ping RPC.
	ProvisionerServicePingProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/Ping"
	// ProvisionerServiceStatusProcedure is the fully-qualified name of the ProvisionerService's Status
	// RPC.
	ProvisionerServiceStatusProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/Status"
	// ProvisionerServiceGetArtefactDiffsProcedure is the fully-qualified name of the
	// ProvisionerService's GetArtefactDiffs RPC.
	ProvisionerServiceGetArtefactDiffsProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/GetArtefactDiffs"
	// ProvisionerServiceUploadArtefactProcedure is the fully-qualified name of the ProvisionerService's
	// UploadArtefact RPC.
	ProvisionerServiceUploadArtefactProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/UploadArtefact"
	// ProvisionerServiceCreateDeploymentProcedure is the fully-qualified name of the
	// ProvisionerService's CreateDeployment RPC.
	ProvisionerServiceCreateDeploymentProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/CreateDeployment"
	// ProvisionerServiceUpdateDeployProcedure is the fully-qualified name of the ProvisionerService's
	// UpdateDeploy RPC.
	ProvisionerServiceUpdateDeployProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/UpdateDeploy"
	// ProvisionerServiceReplaceDeployProcedure is the fully-qualified name of the ProvisionerService's
	// ReplaceDeploy RPC.
	ProvisionerServiceReplaceDeployProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/ReplaceDeploy"
	// ProvisionerServiceGetSchemaProcedure is the fully-qualified name of the ProvisionerService's
	// GetSchema RPC.
	ProvisionerServiceGetSchemaProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/GetSchema"
	// ProvisionerServicePullSchemaProcedure is the fully-qualified name of the ProvisionerService's
	// PullSchema RPC.
	ProvisionerServicePullSchemaProcedure = "/xyz.block.ftl.v1beta1.provisioner.ProvisionerService/PullSchema"
)

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 (
	// ProvisionerPluginServiceName is the fully-qualified name of the ProvisionerPluginService service.
	ProvisionerPluginServiceName = "xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService"
)
View Source 
const (
	// ProvisionerServiceName is the fully-qualified name of the ProvisionerService service.
	ProvisionerServiceName = "xyz.block.ftl.v1beta1.provisioner.ProvisionerService"
)

Variables

This section is empty.

Functions

func NewProvisionerPluginServiceHandler 

func NewProvisionerPluginServiceHandler(svc ProvisionerPluginServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewProvisionerPluginServiceHandler 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 NewProvisionerServiceHandler added in v0.369.0 

func NewProvisionerServiceHandler(svc ProvisionerServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewProvisionerServiceHandler 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 ProvisionerPluginServiceClient 

type ProvisionerPluginServiceClient interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	Provision(context.Context, *connect.Request[provisioner.ProvisionRequest]) (*connect.Response[provisioner.ProvisionResponse], error)
	Plan(context.Context, *connect.Request[provisioner.PlanRequest]) (*connect.Response[provisioner.PlanResponse], error)
	Status(context.Context, *connect.Request[provisioner.StatusRequest]) (*connect.Response[provisioner.StatusResponse], error)
}

ProvisionerPluginServiceClient is a client for the xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService service.

func NewProvisionerPluginServiceClient 

func NewProvisionerPluginServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProvisionerPluginServiceClient

NewProvisionerPluginServiceClient constructs a client for the xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService 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 ProvisionerPluginServiceHandler 

type ProvisionerPluginServiceHandler interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	Provision(context.Context, *connect.Request[provisioner.ProvisionRequest]) (*connect.Response[provisioner.ProvisionResponse], error)
	Plan(context.Context, *connect.Request[provisioner.PlanRequest]) (*connect.Response[provisioner.PlanResponse], error)
	Status(context.Context, *connect.Request[provisioner.StatusRequest]) (*connect.Response[provisioner.StatusResponse], error)
}

ProvisionerPluginServiceHandler is an implementation of the xyz.block.ftl.v1beta1.provisioner.ProvisionerPluginService service.

type ProvisionerServiceClient added in v0.369.0 

type ProvisionerServiceClient interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error)
	GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error)
	UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], error)
	CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error)
	UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error)
	ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error)
	GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error)
	PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest]) (*connect.ServerStreamForClient[v1.PullSchemaResponse], error)
}

ProvisionerServiceClient is a client for the xyz.block.ftl.v1beta1.provisioner.ProvisionerService service.

func NewProvisionerServiceClient added in v0.369.0 

func NewProvisionerServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProvisionerServiceClient

NewProvisionerServiceClient constructs a client for the xyz.block.ftl.v1beta1.provisioner.ProvisionerService 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 ProvisionerServiceHandler added in v0.369.0 

type ProvisionerServiceHandler interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error)
	GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error)
	UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], error)
	CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error)
	UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error)
	ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error)
	GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error)
	PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest], *connect.ServerStream[v1.PullSchemaResponse]) error
}

ProvisionerServiceHandler is an implementation of the xyz.block.ftl.v1beta1.provisioner.ProvisionerService service.

type UnimplementedProvisionerPluginServiceHandler 

type UnimplementedProvisionerPluginServiceHandler struct{}

UnimplementedProvisionerPluginServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProvisionerPluginServiceHandler) Ping 

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

func (UnimplementedProvisionerPluginServiceHandler) Plan 

func (UnimplementedProvisionerPluginServiceHandler) Plan(context.Context, *connect.Request[provisioner.PlanRequest]) (*connect.Response[provisioner.PlanResponse], error)

func (UnimplementedProvisionerPluginServiceHandler) Provision 

func (UnimplementedProvisionerPluginServiceHandler) Provision(context.Context, *connect.Request[provisioner.ProvisionRequest]) (*connect.Response[provisioner.ProvisionResponse], error)

func (UnimplementedProvisionerPluginServiceHandler) Status 

func (UnimplementedProvisionerPluginServiceHandler) Status(context.Context, *connect.Request[provisioner.StatusRequest]) (*connect.Response[provisioner.StatusResponse], error)

type UnimplementedProvisionerServiceHandler added in v0.369.0 

type UnimplementedProvisionerServiceHandler struct{}

UnimplementedProvisionerServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProvisionerServiceHandler) CreateDeployment added in v0.369.0 

func (UnimplementedProvisionerServiceHandler) CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error)

func (UnimplementedProvisionerServiceHandler) GetArtefactDiffs added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error)

func (UnimplementedProvisionerServiceHandler) GetSchema added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error)

func (UnimplementedProvisionerServiceHandler) Ping added in v0.369.0 

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

func (UnimplementedProvisionerServiceHandler) PullSchema added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest], *connect.ServerStream[v1.PullSchemaResponse]) error

func (UnimplementedProvisionerServiceHandler) ReplaceDeploy added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error)

func (UnimplementedProvisionerServiceHandler) Status added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error)

func (UnimplementedProvisionerServiceHandler) UpdateDeploy added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error)

func (UnimplementedProvisionerServiceHandler) UploadArtefact added in v0.372.0 

func (UnimplementedProvisionerServiceHandler) UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], 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.