Documentation ¶
Index ¶
- Constants
- func NewAdminServiceHandler(svc AdminServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewControllerServiceHandler(svc ControllerServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewModuleServiceHandler(svc ModuleServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewSchemaServiceHandler(svc SchemaServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewVerbServiceHandler(svc VerbServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- type AdminServiceClient
- type AdminServiceHandler
- type ControllerServiceClient
- type ControllerServiceHandler
- type ModuleServiceClient
- type ModuleServiceHandler
- type SchemaServiceClient
- type SchemaServiceHandler
- type UnimplementedAdminServiceHandler
- func (UnimplementedAdminServiceHandler) ConfigGet(context.Context, *connect.Request[v1.ConfigGetRequest]) (*connect.Response[v1.ConfigGetResponse], error)
- func (UnimplementedAdminServiceHandler) ConfigList(context.Context, *connect.Request[v1.ConfigListRequest]) (*connect.Response[v1.ConfigListResponse], error)
- func (UnimplementedAdminServiceHandler) ConfigSet(context.Context, *connect.Request[v1.ConfigSetRequest]) (*connect.Response[v1.ConfigSetResponse], error)
- func (UnimplementedAdminServiceHandler) ConfigUnset(context.Context, *connect.Request[v1.ConfigUnsetRequest]) (*connect.Response[v1.ConfigUnsetResponse], error)
- func (UnimplementedAdminServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
- func (UnimplementedAdminServiceHandler) SecretGet(context.Context, *connect.Request[v1.SecretGetRequest]) (*connect.Response[v1.SecretGetResponse], error)
- func (UnimplementedAdminServiceHandler) SecretSet(context.Context, *connect.Request[v1.SecretSetRequest]) (*connect.Response[v1.SecretSetResponse], error)
- func (UnimplementedAdminServiceHandler) SecretUnset(context.Context, *connect.Request[v1.SecretUnsetRequest]) (*connect.Response[v1.SecretUnsetResponse], error)
- func (UnimplementedAdminServiceHandler) SecretsList(context.Context, *connect.Request[v1.SecretsListRequest]) (*connect.Response[v1.SecretsListResponse], error)
- type UnimplementedControllerServiceHandler
- func (UnimplementedControllerServiceHandler) CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error)
- func (UnimplementedControllerServiceHandler) GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error)
- func (UnimplementedControllerServiceHandler) GetCertification(context.Context, *connect.Request[v1.GetCertificationRequest]) (*connect.Response[v1.GetCertificationResponse], error)
- func (UnimplementedControllerServiceHandler) GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error)
- func (UnimplementedControllerServiceHandler) GetDeploymentArtefacts(context.Context, *connect.Request[v1.GetDeploymentArtefactsRequest], ...) error
- func (UnimplementedControllerServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
- func (UnimplementedControllerServiceHandler) ProcessList(context.Context, *connect.Request[v1.ProcessListRequest]) (*connect.Response[v1.ProcessListResponse], error)
- func (UnimplementedControllerServiceHandler) RegisterRunner(context.Context, *connect.ClientStream[v1.RegisterRunnerRequest]) (*connect.Response[v1.RegisterRunnerResponse], error)
- func (UnimplementedControllerServiceHandler) ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error)
- func (UnimplementedControllerServiceHandler) ResetSubscription(context.Context, *connect.Request[v1.ResetSubscriptionRequest]) (*connect.Response[v1.ResetSubscriptionResponse], error)
- func (UnimplementedControllerServiceHandler) Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error)
- func (UnimplementedControllerServiceHandler) StreamDeploymentLogs(context.Context, *connect.ClientStream[v1.StreamDeploymentLogsRequest]) (*connect.Response[v1.StreamDeploymentLogsResponse], error)
- func (UnimplementedControllerServiceHandler) UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error)
- func (UnimplementedControllerServiceHandler) UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], error)
- type UnimplementedModuleServiceHandler
- func (UnimplementedModuleServiceHandler) AcquireLease(context.Context, ...) error
- func (UnimplementedModuleServiceHandler) GetModuleContext(context.Context, *connect.Request[v1.GetModuleContextRequest], ...) error
- func (UnimplementedModuleServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
- func (UnimplementedModuleServiceHandler) PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[v1.PublishEventResponse], error)
- type UnimplementedSchemaServiceHandler
- func (UnimplementedSchemaServiceHandler) GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error)
- func (UnimplementedSchemaServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
- func (UnimplementedSchemaServiceHandler) PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest], ...) error
- type UnimplementedVerbServiceHandler
- type VerbServiceClient
- type VerbServiceHandler
Constants ¶
const ( // AdminServicePingProcedure is the fully-qualified name of the AdminService's Ping RPC. AdminServicePingProcedure = "/xyz.block.ftl.v1.AdminService/Ping" // AdminServiceConfigListProcedure is the fully-qualified name of the AdminService's ConfigList RPC. AdminServiceConfigListProcedure = "/xyz.block.ftl.v1.AdminService/ConfigList" // AdminServiceConfigGetProcedure is the fully-qualified name of the AdminService's ConfigGet RPC. AdminServiceConfigGetProcedure = "/xyz.block.ftl.v1.AdminService/ConfigGet" // AdminServiceConfigSetProcedure is the fully-qualified name of the AdminService's ConfigSet RPC. AdminServiceConfigSetProcedure = "/xyz.block.ftl.v1.AdminService/ConfigSet" // AdminServiceConfigUnsetProcedure is the fully-qualified name of the AdminService's ConfigUnset // RPC. AdminServiceConfigUnsetProcedure = "/xyz.block.ftl.v1.AdminService/ConfigUnset" // AdminServiceSecretsListProcedure is the fully-qualified name of the AdminService's SecretsList // RPC. AdminServiceSecretsListProcedure = "/xyz.block.ftl.v1.AdminService/SecretsList" // AdminServiceSecretGetProcedure is the fully-qualified name of the AdminService's SecretGet RPC. AdminServiceSecretGetProcedure = "/xyz.block.ftl.v1.AdminService/SecretGet" // AdminServiceSecretSetProcedure is the fully-qualified name of the AdminService's SecretSet RPC. AdminServiceSecretSetProcedure = "/xyz.block.ftl.v1.AdminService/SecretSet" // AdminServiceSecretUnsetProcedure is the fully-qualified name of the AdminService's SecretUnset // RPC. AdminServiceSecretUnsetProcedure = "/xyz.block.ftl.v1.AdminService/SecretUnset" )
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.
const ( // ControllerServicePingProcedure is the fully-qualified name of the ControllerService's Ping RPC. ControllerServicePingProcedure = "/xyz.block.ftl.v1.ControllerService/Ping" // ControllerServiceProcessListProcedure is the fully-qualified name of the ControllerService's // ProcessList RPC. ControllerServiceProcessListProcedure = "/xyz.block.ftl.v1.ControllerService/ProcessList" // ControllerServiceStatusProcedure is the fully-qualified name of the ControllerService's Status // RPC. ControllerServiceStatusProcedure = "/xyz.block.ftl.v1.ControllerService/Status" // ControllerServiceGetCertificationProcedure is the fully-qualified name of the ControllerService's // GetCertification RPC. ControllerServiceGetCertificationProcedure = "/xyz.block.ftl.v1.ControllerService/GetCertification" // ControllerServiceGetArtefactDiffsProcedure is the fully-qualified name of the ControllerService's // GetArtefactDiffs RPC. ControllerServiceGetArtefactDiffsProcedure = "/xyz.block.ftl.v1.ControllerService/GetArtefactDiffs" // ControllerServiceUploadArtefactProcedure is the fully-qualified name of the ControllerService's // UploadArtefact RPC. ControllerServiceUploadArtefactProcedure = "/xyz.block.ftl.v1.ControllerService/UploadArtefact" // ControllerServiceCreateDeploymentProcedure is the fully-qualified name of the ControllerService's // CreateDeployment RPC. ControllerServiceCreateDeploymentProcedure = "/xyz.block.ftl.v1.ControllerService/CreateDeployment" // ControllerServiceGetDeploymentProcedure is the fully-qualified name of the ControllerService's // GetDeployment RPC. ControllerServiceGetDeploymentProcedure = "/xyz.block.ftl.v1.ControllerService/GetDeployment" // ControllerServiceGetDeploymentArtefactsProcedure is the fully-qualified name of the // ControllerService's GetDeploymentArtefacts RPC. ControllerServiceGetDeploymentArtefactsProcedure = "/xyz.block.ftl.v1.ControllerService/GetDeploymentArtefacts" // ControllerServiceRegisterRunnerProcedure is the fully-qualified name of the ControllerService's // RegisterRunner RPC. ControllerServiceRegisterRunnerProcedure = "/xyz.block.ftl.v1.ControllerService/RegisterRunner" // ControllerServiceUpdateDeployProcedure is the fully-qualified name of the ControllerService's // UpdateDeploy RPC. ControllerServiceUpdateDeployProcedure = "/xyz.block.ftl.v1.ControllerService/UpdateDeploy" // ControllerServiceReplaceDeployProcedure is the fully-qualified name of the ControllerService's // ReplaceDeploy RPC. ControllerServiceReplaceDeployProcedure = "/xyz.block.ftl.v1.ControllerService/ReplaceDeploy" // ControllerServiceStreamDeploymentLogsProcedure is the fully-qualified name of the // ControllerService's StreamDeploymentLogs RPC. ControllerServiceStreamDeploymentLogsProcedure = "/xyz.block.ftl.v1.ControllerService/StreamDeploymentLogs" // ControllerServiceResetSubscriptionProcedure is the fully-qualified name of the // ControllerService's ResetSubscription RPC. ControllerServiceResetSubscriptionProcedure = "/xyz.block.ftl.v1.ControllerService/ResetSubscription" )
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.
const ( // ModuleServicePingProcedure is the fully-qualified name of the ModuleService's Ping RPC. ModuleServicePingProcedure = "/xyz.block.ftl.v1.ModuleService/Ping" // ModuleServiceGetModuleContextProcedure is the fully-qualified name of the ModuleService's // GetModuleContext RPC. ModuleServiceGetModuleContextProcedure = "/xyz.block.ftl.v1.ModuleService/GetModuleContext" // ModuleServiceAcquireLeaseProcedure is the fully-qualified name of the ModuleService's // AcquireLease RPC. ModuleServiceAcquireLeaseProcedure = "/xyz.block.ftl.v1.ModuleService/AcquireLease" // ModuleServicePublishEventProcedure is the fully-qualified name of the ModuleService's // PublishEvent RPC. ModuleServicePublishEventProcedure = "/xyz.block.ftl.v1.ModuleService/PublishEvent" )
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.
const ( // SchemaServicePingProcedure is the fully-qualified name of the SchemaService's Ping RPC. SchemaServicePingProcedure = "/xyz.block.ftl.v1.SchemaService/Ping" // SchemaServiceGetSchemaProcedure is the fully-qualified name of the SchemaService's GetSchema RPC. SchemaServiceGetSchemaProcedure = "/xyz.block.ftl.v1.SchemaService/GetSchema" // SchemaServicePullSchemaProcedure is the fully-qualified name of the SchemaService's PullSchema // RPC. SchemaServicePullSchemaProcedure = "/xyz.block.ftl.v1.SchemaService/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.
const ( // VerbServicePingProcedure is the fully-qualified name of the VerbService's Ping RPC. VerbServicePingProcedure = "/xyz.block.ftl.v1.VerbService/Ping" // VerbServiceCallProcedure is the fully-qualified name of the VerbService's Call RPC. VerbServiceCallProcedure = "/xyz.block.ftl.v1.VerbService/Call" )
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.
const (
// AdminServiceName is the fully-qualified name of the AdminService service.
AdminServiceName = "xyz.block.ftl.v1.AdminService"
)
const (
// ControllerServiceName is the fully-qualified name of the ControllerService service.
ControllerServiceName = "xyz.block.ftl.v1.ControllerService"
)
const (
// ModuleServiceName is the fully-qualified name of the ModuleService service.
ModuleServiceName = "xyz.block.ftl.v1.ModuleService"
)
const (
// SchemaServiceName is the fully-qualified name of the SchemaService service.
SchemaServiceName = "xyz.block.ftl.v1.SchemaService"
)
const (
// VerbServiceName is the fully-qualified name of the VerbService service.
VerbServiceName = "xyz.block.ftl.v1.VerbService"
)
Variables ¶
This section is empty.
Functions ¶
func NewAdminServiceHandler ¶ added in v0.240.0
func NewAdminServiceHandler(svc AdminServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewAdminServiceHandler 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 NewControllerServiceHandler ¶
func NewControllerServiceHandler(svc ControllerServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewControllerServiceHandler 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 NewModuleServiceHandler ¶ added in v0.360.0
func NewModuleServiceHandler(svc ModuleServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewModuleServiceHandler 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 NewSchemaServiceHandler ¶ added in v0.398.0
func NewSchemaServiceHandler(svc SchemaServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewSchemaServiceHandler 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 NewVerbServiceHandler ¶
func NewVerbServiceHandler(svc VerbServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewVerbServiceHandler 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 AdminServiceClient ¶ added in v0.240.0
type AdminServiceClient interface { Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // List configuration. ConfigList(context.Context, *connect.Request[v1.ConfigListRequest]) (*connect.Response[v1.ConfigListResponse], error) // Get a config value. ConfigGet(context.Context, *connect.Request[v1.ConfigGetRequest]) (*connect.Response[v1.ConfigGetResponse], error) // Set a config value. ConfigSet(context.Context, *connect.Request[v1.ConfigSetRequest]) (*connect.Response[v1.ConfigSetResponse], error) // Unset a config value. ConfigUnset(context.Context, *connect.Request[v1.ConfigUnsetRequest]) (*connect.Response[v1.ConfigUnsetResponse], error) // List secrets. SecretsList(context.Context, *connect.Request[v1.SecretsListRequest]) (*connect.Response[v1.SecretsListResponse], error) // Get a secret. SecretGet(context.Context, *connect.Request[v1.SecretGetRequest]) (*connect.Response[v1.SecretGetResponse], error) // Set a secret. SecretSet(context.Context, *connect.Request[v1.SecretSetRequest]) (*connect.Response[v1.SecretSetResponse], error) // Unset a secret. SecretUnset(context.Context, *connect.Request[v1.SecretUnsetRequest]) (*connect.Response[v1.SecretUnsetResponse], error) }
AdminServiceClient is a client for the xyz.block.ftl.v1.AdminService service.
func NewAdminServiceClient ¶ added in v0.240.0
func NewAdminServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AdminServiceClient
NewAdminServiceClient constructs a client for the xyz.block.ftl.v1.AdminService 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 AdminServiceHandler ¶ added in v0.240.0
type AdminServiceHandler interface { Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // List configuration. ConfigList(context.Context, *connect.Request[v1.ConfigListRequest]) (*connect.Response[v1.ConfigListResponse], error) // Get a config value. ConfigGet(context.Context, *connect.Request[v1.ConfigGetRequest]) (*connect.Response[v1.ConfigGetResponse], error) // Set a config value. ConfigSet(context.Context, *connect.Request[v1.ConfigSetRequest]) (*connect.Response[v1.ConfigSetResponse], error) // Unset a config value. ConfigUnset(context.Context, *connect.Request[v1.ConfigUnsetRequest]) (*connect.Response[v1.ConfigUnsetResponse], error) // List secrets. SecretsList(context.Context, *connect.Request[v1.SecretsListRequest]) (*connect.Response[v1.SecretsListResponse], error) // Get a secret. SecretGet(context.Context, *connect.Request[v1.SecretGetRequest]) (*connect.Response[v1.SecretGetResponse], error) // Set a secret. SecretSet(context.Context, *connect.Request[v1.SecretSetRequest]) (*connect.Response[v1.SecretSetResponse], error) // Unset a secret. SecretUnset(context.Context, *connect.Request[v1.SecretUnsetRequest]) (*connect.Response[v1.SecretUnsetResponse], error) }
AdminServiceHandler is an implementation of the xyz.block.ftl.v1.AdminService service.
type ControllerServiceClient ¶
type ControllerServiceClient interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // List "processes" running on the cluster. ProcessList(context.Context, *connect.Request[v1.ProcessListRequest]) (*connect.Response[v1.ProcessListResponse], error) Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error) // Runner will initially call this to have the controller sign its public key. GetCertification(context.Context, *connect.Request[v1.GetCertificationRequest]) (*connect.Response[v1.GetCertificationResponse], error) // Get list of artefacts that differ between the server and client. GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error) // Upload an artefact to the server. UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], error) // Create a deployment. CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error) // Get the schema and artefact metadata for a deployment. GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error) // Stream deployment artefacts from the server. // // Each artefact is streamed one after the other as a sequence of max 1MB // chunks. GetDeploymentArtefacts(context.Context, *connect.Request[v1.GetDeploymentArtefactsRequest]) (*connect.ServerStreamForClient[v1.GetDeploymentArtefactsResponse], error) // Register a Runner with the Controller. // // Each runner issue a RegisterRunnerRequest to the ControllerService // every 10 seconds to maintain its heartbeat. RegisterRunner(context.Context) *connect.ClientStreamForClient[v1.RegisterRunnerRequest, v1.RegisterRunnerResponse] // Update an existing deployment. UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error) // Gradually replace an existing deployment with a new one. // // If a deployment already exists for the module of the new deployment, // it will be scaled down and replaced by the new one. ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error) // Stream logs from a deployment StreamDeploymentLogs(context.Context) *connect.ClientStreamForClient[v1.StreamDeploymentLogsRequest, v1.StreamDeploymentLogsResponse] // Reset the cursor for a subscription to the head of its topic. ResetSubscription(context.Context, *connect.Request[v1.ResetSubscriptionRequest]) (*connect.Response[v1.ResetSubscriptionResponse], error) }
ControllerServiceClient is a client for the xyz.block.ftl.v1.ControllerService service.
func NewControllerServiceClient ¶
func NewControllerServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ControllerServiceClient
NewControllerServiceClient constructs a client for the xyz.block.ftl.v1.ControllerService 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 ControllerServiceHandler ¶
type ControllerServiceHandler interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // List "processes" running on the cluster. ProcessList(context.Context, *connect.Request[v1.ProcessListRequest]) (*connect.Response[v1.ProcessListResponse], error) Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error) // Runner will initially call this to have the controller sign its public key. GetCertification(context.Context, *connect.Request[v1.GetCertificationRequest]) (*connect.Response[v1.GetCertificationResponse], error) // Get list of artefacts that differ between the server and client. GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error) // Upload an artefact to the server. UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], error) // Create a deployment. CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error) // Get the schema and artefact metadata for a deployment. GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error) // Stream deployment artefacts from the server. // // Each artefact is streamed one after the other as a sequence of max 1MB // chunks. GetDeploymentArtefacts(context.Context, *connect.Request[v1.GetDeploymentArtefactsRequest], *connect.ServerStream[v1.GetDeploymentArtefactsResponse]) error // Register a Runner with the Controller. // // Each runner issue a RegisterRunnerRequest to the ControllerService // every 10 seconds to maintain its heartbeat. RegisterRunner(context.Context, *connect.ClientStream[v1.RegisterRunnerRequest]) (*connect.Response[v1.RegisterRunnerResponse], error) // Update an existing deployment. UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error) // Gradually replace an existing deployment with a new one. // // If a deployment already exists for the module of the new deployment, // it will be scaled down and replaced by the new one. ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error) // Stream logs from a deployment StreamDeploymentLogs(context.Context, *connect.ClientStream[v1.StreamDeploymentLogsRequest]) (*connect.Response[v1.StreamDeploymentLogsResponse], error) // Reset the cursor for a subscription to the head of its topic. ResetSubscription(context.Context, *connect.Request[v1.ResetSubscriptionRequest]) (*connect.Response[v1.ResetSubscriptionResponse], error) }
ControllerServiceHandler is an implementation of the xyz.block.ftl.v1.ControllerService service.
type ModuleServiceClient ¶ added in v0.360.0
type ModuleServiceClient interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // Get configuration state for the module GetModuleContext(context.Context, *connect.Request[v1.GetModuleContextRequest]) (*connect.ServerStreamForClient[v1.GetModuleContextResponse], error) // Acquire (and renew) a lease for a deployment. // // Returns ResourceExhausted if the lease is held. AcquireLease(context.Context) *connect.BidiStreamForClient[v1.AcquireLeaseRequest, v1.AcquireLeaseResponse] // Publish an event to a topic. PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[v1.PublishEventResponse], error) }
ModuleServiceClient is a client for the xyz.block.ftl.v1.ModuleService service.
func NewModuleServiceClient ¶ added in v0.360.0
func NewModuleServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ModuleServiceClient
NewModuleServiceClient constructs a client for the xyz.block.ftl.v1.ModuleService 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 ModuleServiceHandler ¶ added in v0.360.0
type ModuleServiceHandler interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // Get configuration state for the module GetModuleContext(context.Context, *connect.Request[v1.GetModuleContextRequest], *connect.ServerStream[v1.GetModuleContextResponse]) error // Acquire (and renew) a lease for a deployment. // // Returns ResourceExhausted if the lease is held. AcquireLease(context.Context, *connect.BidiStream[v1.AcquireLeaseRequest, v1.AcquireLeaseResponse]) error // Publish an event to a topic. PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[v1.PublishEventResponse], error) }
ModuleServiceHandler is an implementation of the xyz.block.ftl.v1.ModuleService service.
type SchemaServiceClient ¶ added in v0.398.0
type SchemaServiceClient interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // Get the full schema. GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error) // Pull schema changes from the Controller. // // Note that if there are no deployments this will block indefinitely, making it unsuitable for // just retrieving the schema. Use GetSchema for that. PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest]) (*connect.ServerStreamForClient[v1.PullSchemaResponse], error) }
SchemaServiceClient is a client for the xyz.block.ftl.v1.SchemaService service.
func NewSchemaServiceClient ¶ added in v0.398.0
func NewSchemaServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SchemaServiceClient
NewSchemaServiceClient constructs a client for the xyz.block.ftl.v1.SchemaService 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 SchemaServiceHandler ¶ added in v0.398.0
type SchemaServiceHandler interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // Get the full schema. GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error) // Pull schema changes from the Controller. // // Note that if there are no deployments this will block indefinitely, making it unsuitable for // just retrieving the schema. Use GetSchema for that. PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest], *connect.ServerStream[v1.PullSchemaResponse]) error }
SchemaServiceHandler is an implementation of the xyz.block.ftl.v1.SchemaService service.
type UnimplementedAdminServiceHandler ¶ added in v0.240.0
type UnimplementedAdminServiceHandler struct{}
UnimplementedAdminServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedAdminServiceHandler) ConfigGet ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) ConfigGet(context.Context, *connect.Request[v1.ConfigGetRequest]) (*connect.Response[v1.ConfigGetResponse], error)
func (UnimplementedAdminServiceHandler) ConfigList ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) ConfigList(context.Context, *connect.Request[v1.ConfigListRequest]) (*connect.Response[v1.ConfigListResponse], error)
func (UnimplementedAdminServiceHandler) ConfigSet ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) ConfigSet(context.Context, *connect.Request[v1.ConfigSetRequest]) (*connect.Response[v1.ConfigSetResponse], error)
func (UnimplementedAdminServiceHandler) ConfigUnset ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) ConfigUnset(context.Context, *connect.Request[v1.ConfigUnsetRequest]) (*connect.Response[v1.ConfigUnsetResponse], error)
func (UnimplementedAdminServiceHandler) Ping ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
func (UnimplementedAdminServiceHandler) SecretGet ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) SecretGet(context.Context, *connect.Request[v1.SecretGetRequest]) (*connect.Response[v1.SecretGetResponse], error)
func (UnimplementedAdminServiceHandler) SecretSet ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) SecretSet(context.Context, *connect.Request[v1.SecretSetRequest]) (*connect.Response[v1.SecretSetResponse], error)
func (UnimplementedAdminServiceHandler) SecretUnset ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) SecretUnset(context.Context, *connect.Request[v1.SecretUnsetRequest]) (*connect.Response[v1.SecretUnsetResponse], error)
func (UnimplementedAdminServiceHandler) SecretsList ¶ added in v0.240.0
func (UnimplementedAdminServiceHandler) SecretsList(context.Context, *connect.Request[v1.SecretsListRequest]) (*connect.Response[v1.SecretsListResponse], error)
type UnimplementedControllerServiceHandler ¶
type UnimplementedControllerServiceHandler struct{}
UnimplementedControllerServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedControllerServiceHandler) CreateDeployment ¶
func (UnimplementedControllerServiceHandler) CreateDeployment(context.Context, *connect.Request[v1.CreateDeploymentRequest]) (*connect.Response[v1.CreateDeploymentResponse], error)
func (UnimplementedControllerServiceHandler) GetArtefactDiffs ¶
func (UnimplementedControllerServiceHandler) GetArtefactDiffs(context.Context, *connect.Request[v1.GetArtefactDiffsRequest]) (*connect.Response[v1.GetArtefactDiffsResponse], error)
func (UnimplementedControllerServiceHandler) GetCertification ¶ added in v0.376.0
func (UnimplementedControllerServiceHandler) GetCertification(context.Context, *connect.Request[v1.GetCertificationRequest]) (*connect.Response[v1.GetCertificationResponse], error)
func (UnimplementedControllerServiceHandler) GetDeployment ¶
func (UnimplementedControllerServiceHandler) GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error)
func (UnimplementedControllerServiceHandler) GetDeploymentArtefacts ¶
func (UnimplementedControllerServiceHandler) GetDeploymentArtefacts(context.Context, *connect.Request[v1.GetDeploymentArtefactsRequest], *connect.ServerStream[v1.GetDeploymentArtefactsResponse]) error
func (UnimplementedControllerServiceHandler) Ping ¶
func (UnimplementedControllerServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
func (UnimplementedControllerServiceHandler) ProcessList ¶
func (UnimplementedControllerServiceHandler) ProcessList(context.Context, *connect.Request[v1.ProcessListRequest]) (*connect.Response[v1.ProcessListResponse], error)
func (UnimplementedControllerServiceHandler) RegisterRunner ¶
func (UnimplementedControllerServiceHandler) RegisterRunner(context.Context, *connect.ClientStream[v1.RegisterRunnerRequest]) (*connect.Response[v1.RegisterRunnerResponse], error)
func (UnimplementedControllerServiceHandler) ReplaceDeploy ¶
func (UnimplementedControllerServiceHandler) ReplaceDeploy(context.Context, *connect.Request[v1.ReplaceDeployRequest]) (*connect.Response[v1.ReplaceDeployResponse], error)
func (UnimplementedControllerServiceHandler) ResetSubscription ¶ added in v0.312.0
func (UnimplementedControllerServiceHandler) ResetSubscription(context.Context, *connect.Request[v1.ResetSubscriptionRequest]) (*connect.Response[v1.ResetSubscriptionResponse], error)
func (UnimplementedControllerServiceHandler) Status ¶
func (UnimplementedControllerServiceHandler) Status(context.Context, *connect.Request[v1.StatusRequest]) (*connect.Response[v1.StatusResponse], error)
func (UnimplementedControllerServiceHandler) StreamDeploymentLogs ¶
func (UnimplementedControllerServiceHandler) StreamDeploymentLogs(context.Context, *connect.ClientStream[v1.StreamDeploymentLogsRequest]) (*connect.Response[v1.StreamDeploymentLogsResponse], error)
func (UnimplementedControllerServiceHandler) UpdateDeploy ¶
func (UnimplementedControllerServiceHandler) UpdateDeploy(context.Context, *connect.Request[v1.UpdateDeployRequest]) (*connect.Response[v1.UpdateDeployResponse], error)
func (UnimplementedControllerServiceHandler) UploadArtefact ¶
func (UnimplementedControllerServiceHandler) UploadArtefact(context.Context, *connect.Request[v1.UploadArtefactRequest]) (*connect.Response[v1.UploadArtefactResponse], error)
type UnimplementedModuleServiceHandler ¶ added in v0.360.0
type UnimplementedModuleServiceHandler struct{}
UnimplementedModuleServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedModuleServiceHandler) AcquireLease ¶ added in v0.360.0
func (UnimplementedModuleServiceHandler) AcquireLease(context.Context, *connect.BidiStream[v1.AcquireLeaseRequest, v1.AcquireLeaseResponse]) error
func (UnimplementedModuleServiceHandler) GetModuleContext ¶ added in v0.360.0
func (UnimplementedModuleServiceHandler) GetModuleContext(context.Context, *connect.Request[v1.GetModuleContextRequest], *connect.ServerStream[v1.GetModuleContextResponse]) error
func (UnimplementedModuleServiceHandler) Ping ¶ added in v0.360.0
func (UnimplementedModuleServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
func (UnimplementedModuleServiceHandler) PublishEvent ¶ added in v0.360.0
func (UnimplementedModuleServiceHandler) PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[v1.PublishEventResponse], error)
type UnimplementedSchemaServiceHandler ¶ added in v0.398.0
type UnimplementedSchemaServiceHandler struct{}
UnimplementedSchemaServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedSchemaServiceHandler) GetSchema ¶ added in v0.398.0
func (UnimplementedSchemaServiceHandler) GetSchema(context.Context, *connect.Request[v1.GetSchemaRequest]) (*connect.Response[v1.GetSchemaResponse], error)
func (UnimplementedSchemaServiceHandler) Ping ¶ added in v0.398.0
func (UnimplementedSchemaServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
func (UnimplementedSchemaServiceHandler) PullSchema ¶ added in v0.398.0
func (UnimplementedSchemaServiceHandler) PullSchema(context.Context, *connect.Request[v1.PullSchemaRequest], *connect.ServerStream[v1.PullSchemaResponse]) error
type UnimplementedVerbServiceHandler ¶
type UnimplementedVerbServiceHandler struct{}
UnimplementedVerbServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedVerbServiceHandler) Call ¶
func (UnimplementedVerbServiceHandler) Call(context.Context, *connect.Request[v1.CallRequest]) (*connect.Response[v1.CallResponse], error)
func (UnimplementedVerbServiceHandler) Ping ¶
func (UnimplementedVerbServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
type VerbServiceClient ¶
type VerbServiceClient interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // Issue a synchronous call to a Verb. Call(context.Context, *connect.Request[v1.CallRequest]) (*connect.Response[v1.CallResponse], error) }
VerbServiceClient is a client for the xyz.block.ftl.v1.VerbService service.
func NewVerbServiceClient ¶
func NewVerbServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) VerbServiceClient
NewVerbServiceClient constructs a client for the xyz.block.ftl.v1.VerbService 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 VerbServiceHandler ¶
type VerbServiceHandler interface { // Ping service for readiness. Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error) // Issue a synchronous call to a Verb. Call(context.Context, *connect.Request[v1.CallRequest]) (*connect.Response[v1.CallResponse], error) }
VerbServiceHandler is an implementation of the xyz.block.ftl.v1.VerbService service.