apiv1connect

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ClusterServiceCreateProcedure is the fully-qualified name of the ClusterService's Create RPC.
	ClusterServiceCreateProcedure = "/api.v1.ClusterService/Create"
	// ClusterServiceGetProcedure is the fully-qualified name of the ClusterService's Get RPC.
	ClusterServiceGetProcedure = "/api.v1.ClusterService/Get"
	// ClusterServiceListProcedure is the fully-qualified name of the ClusterService's List RPC.
	ClusterServiceListProcedure = "/api.v1.ClusterService/List"
	// ClusterServiceWatchStatusProcedure is the fully-qualified name of the ClusterService's
	// WatchStatus RPC.
	ClusterServiceWatchStatusProcedure = "/api.v1.ClusterService/WatchStatus"
	// ClusterServiceDeleteProcedure is the fully-qualified name of the ClusterService's Delete RPC.
	ClusterServiceDeleteProcedure = "/api.v1.ClusterService/Delete"
	// ClusterServiceUpdateProcedure is the fully-qualified name of the ClusterService's Update RPC.
	ClusterServiceUpdateProcedure = "/api.v1.ClusterService/Update"
	// ClusterServiceGetCredentialsProcedure is the fully-qualified name of the ClusterService's
	// GetCredentials RPC.
	ClusterServiceGetCredentialsProcedure = "/api.v1.ClusterService/GetCredentials"
	// ClusterServiceOperateProcedure is the fully-qualified name of the ClusterService's Operate RPC.
	ClusterServiceOperateProcedure = "/api.v1.ClusterService/Operate"
)

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 (
	// IPServiceGetProcedure is the fully-qualified name of the IPService's Get RPC.
	IPServiceGetProcedure = "/api.v1.IPService/Get"
	// IPServiceAllocateProcedure is the fully-qualified name of the IPService's Allocate RPC.
	IPServiceAllocateProcedure = "/api.v1.IPService/Allocate"
	// IPServiceUpdateProcedure is the fully-qualified name of the IPService's Update RPC.
	IPServiceUpdateProcedure = "/api.v1.IPService/Update"
	// IPServiceListProcedure is the fully-qualified name of the IPService's List RPC.
	IPServiceListProcedure = "/api.v1.IPService/List"
	// IPServiceDeleteProcedure is the fully-qualified name of the IPService's Delete RPC.
	IPServiceDeleteProcedure = "/api.v1.IPService/Delete"
)

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 (
	// MethodServiceListProcedure is the fully-qualified name of the MethodService's List RPC.
	MethodServiceListProcedure = "/api.v1.MethodService/List"
	// MethodServiceTokenScopedListProcedure is the fully-qualified name of the MethodService's
	// TokenScopedList RPC.
	MethodServiceTokenScopedListProcedure = "/api.v1.MethodService/TokenScopedList"
)

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 (
	// PaymentServiceCreateOrUpdateCustomerProcedure is the fully-qualified name of the PaymentService's
	// CreateOrUpdateCustomer RPC.
	PaymentServiceCreateOrUpdateCustomerProcedure = "/api.v1.PaymentService/CreateOrUpdateCustomer"
	// PaymentServiceGetCustomerProcedure is the fully-qualified name of the PaymentService's
	// GetCustomer RPC.
	PaymentServiceGetCustomerProcedure = "/api.v1.PaymentService/GetCustomer"
	// PaymentServiceGetCustomerWithLoginProcedure is the fully-qualified name of the PaymentService's
	// GetCustomerWithLogin RPC.
	PaymentServiceGetCustomerWithLoginProcedure = "/api.v1.PaymentService/GetCustomerWithLogin"
	// PaymentServiceCheckIfCustomerExistsProcedure is the fully-qualified name of the PaymentService's
	// CheckIfCustomerExists RPC.
	PaymentServiceCheckIfCustomerExistsProcedure = "/api.v1.PaymentService/CheckIfCustomerExists"
	// PaymentServiceHasPaymentMethodProcedure is the fully-qualified name of the PaymentService's
	// HasPaymentMethod RPC.
	PaymentServiceHasPaymentMethodProcedure = "/api.v1.PaymentService/HasPaymentMethod"
	// PaymentServiceDeletePaymentMethodProcedure is the fully-qualified name of the PaymentService's
	// DeletePaymentMethod RPC.
	PaymentServiceDeletePaymentMethodProcedure = "/api.v1.PaymentService/DeletePaymentMethod"
	// PaymentServiceGetSubscriptionUsageProcedure is the fully-qualified name of the PaymentService's
	// GetSubscriptionUsage RPC.
	PaymentServiceGetSubscriptionUsageProcedure = "/api.v1.PaymentService/GetSubscriptionUsage"
	// PaymentServiceGetInvoicesProcedure is the fully-qualified name of the PaymentService's
	// GetInvoices RPC.
	PaymentServiceGetInvoicesProcedure = "/api.v1.PaymentService/GetInvoices"
	// PaymentServiceGetDefaultPricesProcedure is the fully-qualified name of the PaymentService's
	// GetDefaultPrices RPC.
	PaymentServiceGetDefaultPricesProcedure = "/api.v1.PaymentService/GetDefaultPrices"
	// PaymentServiceCheckAdmittedProcedure is the fully-qualified name of the PaymentService's
	// CheckAdmitted RPC.
	PaymentServiceCheckAdmittedProcedure = "/api.v1.PaymentService/CheckAdmitted"
	// PaymentServiceRequestAdmissionProcedure is the fully-qualified name of the PaymentService's
	// RequestAdmission RPC.
	PaymentServiceRequestAdmissionProcedure = "/api.v1.PaymentService/RequestAdmission"
	// PaymentServiceHasChargeableResourcesProcedure is the fully-qualified name of the PaymentService's
	// HasChargeableResources RPC.
	PaymentServiceHasChargeableResourcesProcedure = "/api.v1.PaymentService/HasChargeableResources"
)

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 (
	// ProjectServiceListProcedure is the fully-qualified name of the ProjectService's List RPC.
	ProjectServiceListProcedure = "/api.v1.ProjectService/List"
	// ProjectServiceGetProcedure is the fully-qualified name of the ProjectService's Get RPC.
	ProjectServiceGetProcedure = "/api.v1.ProjectService/Get"
)

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 (
	// TenantServiceCreateProcedure is the fully-qualified name of the TenantService's Create RPC.
	TenantServiceCreateProcedure = "/api.v1.TenantService/Create"
	// TenantServiceCreateOrUpdateProcedure is the fully-qualified name of the TenantService's
	// CreateOrUpdate RPC.
	TenantServiceCreateOrUpdateProcedure = "/api.v1.TenantService/CreateOrUpdate"
	// TenantServiceGetProcedure is the fully-qualified name of the TenantService's Get RPC.
	TenantServiceGetProcedure = "/api.v1.TenantService/Get"
	// TenantServiceUpdateProcedure is the fully-qualified name of the TenantService's Update RPC.
	TenantServiceUpdateProcedure = "/api.v1.TenantService/Update"
	// TenantServiceDeleteProcedure is the fully-qualified name of the TenantService's Delete RPC.
	TenantServiceDeleteProcedure = "/api.v1.TenantService/Delete"
)

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 (
	// TokenServiceCreateProcedure is the fully-qualified name of the TokenService's Create RPC.
	TokenServiceCreateProcedure = "/api.v1.TokenService/Create"
	// TokenServiceListProcedure is the fully-qualified name of the TokenService's List RPC.
	TokenServiceListProcedure = "/api.v1.TokenService/List"
	// TokenServiceRevokeProcedure is the fully-qualified name of the TokenService's Revoke RPC.
	TokenServiceRevokeProcedure = "/api.v1.TokenService/Revoke"
)

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 (
	// VolumeServiceName is the fully-qualified name of the VolumeService service.
	VolumeServiceName = "api.v1.VolumeService"
	// SnapshotServiceName is the fully-qualified name of the SnapshotService service.
	SnapshotServiceName = "api.v1.SnapshotService"
)
View Source 
const (
	// VolumeServiceGetProcedure is the fully-qualified name of the VolumeService's Get RPC.
	VolumeServiceGetProcedure = "/api.v1.VolumeService/Get"
	// VolumeServiceListProcedure is the fully-qualified name of the VolumeService's List RPC.
	VolumeServiceListProcedure = "/api.v1.VolumeService/List"
	// VolumeServiceDeleteProcedure is the fully-qualified name of the VolumeService's Delete RPC.
	VolumeServiceDeleteProcedure = "/api.v1.VolumeService/Delete"
	// SnapshotServiceGetProcedure is the fully-qualified name of the SnapshotService's Get RPC.
	SnapshotServiceGetProcedure = "/api.v1.SnapshotService/Get"
	// SnapshotServiceListProcedure is the fully-qualified name of the SnapshotService's List RPC.
	SnapshotServiceListProcedure = "/api.v1.SnapshotService/List"
	// SnapshotServiceDeleteProcedure is the fully-qualified name of the SnapshotService's Delete RPC.
	SnapshotServiceDeleteProcedure = "/api.v1.SnapshotService/Delete"
)

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 (
	// AssetServiceListProcedure is the fully-qualified name of the AssetService's List RPC.
	AssetServiceListProcedure = "/api.v1.AssetService/List"
)

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 (
	// AssetServiceName is the fully-qualified name of the AssetService service.
	AssetServiceName = "api.v1.AssetService"
)
View Source 
const (
	// ClusterServiceName is the fully-qualified name of the ClusterService service.
	ClusterServiceName = "api.v1.ClusterService"
)
View Source 
const (
	// HealthServiceGetProcedure is the fully-qualified name of the HealthService's Get RPC.
	HealthServiceGetProcedure = "/api.v1.HealthService/Get"
)

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 (
	// HealthServiceName is the fully-qualified name of the HealthService service.
	HealthServiceName = "api.v1.HealthService"
)
View Source 
const (
	// IPServiceName is the fully-qualified name of the IPService service.
	IPServiceName = "api.v1.IPService"
)
View Source 
const (
	// MethodServiceName is the fully-qualified name of the MethodService service.
	MethodServiceName = "api.v1.MethodService"
)
View Source 
const (
	// PaymentServiceName is the fully-qualified name of the PaymentService service.
	PaymentServiceName = "api.v1.PaymentService"
)
View Source 
const (
	// ProjectServiceName is the fully-qualified name of the ProjectService service.
	ProjectServiceName = "api.v1.ProjectService"
)
View Source 
const (
	// TenantServiceName is the fully-qualified name of the TenantService service.
	TenantServiceName = "api.v1.TenantService"
)
View Source 
const (
	// TokenServiceName is the fully-qualified name of the TokenService service.
	TokenServiceName = "api.v1.TokenService"
)
View Source 
const (
	// VersionServiceGetProcedure is the fully-qualified name of the VersionService's Get RPC.
	VersionServiceGetProcedure = "/api.v1.VersionService/Get"
)

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 (
	// VersionServiceName is the fully-qualified name of the VersionService service.
	VersionServiceName = "api.v1.VersionService"
)

Variables

This section is empty.

Functions

func NewAssetServiceHandler 

func NewAssetServiceHandler(svc AssetServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAssetServiceHandler 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 NewClusterServiceHandler 

func NewClusterServiceHandler(svc ClusterServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewClusterServiceHandler 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 NewHealthServiceHandler 

func NewHealthServiceHandler(svc HealthServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewHealthServiceHandler 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 NewIPServiceHandler 

func NewIPServiceHandler(svc IPServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewIPServiceHandler 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 NewMethodServiceHandler 

func NewMethodServiceHandler(svc MethodServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMethodServiceHandler 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 NewPaymentServiceHandler 

func NewPaymentServiceHandler(svc PaymentServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewPaymentServiceHandler 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 NewProjectServiceHandler 

func NewProjectServiceHandler(svc ProjectServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewProjectServiceHandler 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 NewSnapshotServiceHandler 

func NewSnapshotServiceHandler(svc SnapshotServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewSnapshotServiceHandler 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 

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 NewTokenServiceHandler 

func NewTokenServiceHandler(svc TokenServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTokenServiceHandler 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 NewVersionServiceHandler 

func NewVersionServiceHandler(svc VersionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewVersionServiceHandler 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 NewVolumeServiceHandler 

func NewVolumeServiceHandler(svc VolumeServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewVolumeServiceHandler 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 AssetServiceClient 

type AssetServiceClient interface {
	// List available assets
	List(context.Context, *connect.Request[v1.AssetServiceListRequest]) (*connect.Response[v1.AssetServiceListResponse], error)
}

AssetServiceClient is a client for the api.v1.AssetService service.

func NewAssetServiceClient 

func NewAssetServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AssetServiceClient

NewAssetServiceClient constructs a client for the api.v1.AssetService 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 AssetServiceHandler 

type AssetServiceHandler interface {
	// List available assets
	List(context.Context, *connect.Request[v1.AssetServiceListRequest]) (*connect.Response[v1.AssetServiceListResponse], error)
}

AssetServiceHandler is an implementation of the api.v1.AssetService service.

type ClusterServiceClient 

type ClusterServiceClient interface {
	// Create a cluster
	Create(context.Context, *connect.Request[v1.ClusterServiceCreateRequest]) (*connect.Response[v1.ClusterServiceCreateResponse], error)
	// Get a cluster
	Get(context.Context, *connect.Request[v1.ClusterServiceGetRequest]) (*connect.Response[v1.ClusterServiceGetResponse], error)
	// List clusters
	List(context.Context, *connect.Request[v1.ClusterServiceListRequest]) (*connect.Response[v1.ClusterServiceListResponse], error)
	// WatchStatus of a cluster
	WatchStatus(context.Context, *connect.Request[v1.ClusterServiceWatchStatusRequest]) (*connect.ServerStreamForClient[v1.ClusterServiceWatchStatusResponse], error)
	// Delete a cluster
	Delete(context.Context, *connect.Request[v1.ClusterServiceDeleteRequest]) (*connect.Response[v1.ClusterServiceDeleteResponse], error)
	// Update a cluster
	Update(context.Context, *connect.Request[v1.ClusterServiceUpdateRequest]) (*connect.Response[v1.ClusterServiceUpdateResponse], error)
	// GetCredentials of a cluster
	GetCredentials(context.Context, *connect.Request[v1.ClusterServiceGetCredentialsRequest]) (*connect.Response[v1.ClusterServiceGetCredentialsResponse], error)
	// Operate on a cluster
	Operate(context.Context, *connect.Request[v1.ClusterServiceOperateRequest]) (*connect.Response[v1.ClusterServiceOperateResponse], error)
}

ClusterServiceClient is a client for the api.v1.ClusterService service.

func NewClusterServiceClient 

func NewClusterServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ClusterServiceClient

NewClusterServiceClient constructs a client for the api.v1.ClusterService 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 ClusterServiceHandler 

type ClusterServiceHandler interface {
	// Create a cluster
	Create(context.Context, *connect.Request[v1.ClusterServiceCreateRequest]) (*connect.Response[v1.ClusterServiceCreateResponse], error)
	// Get a cluster
	Get(context.Context, *connect.Request[v1.ClusterServiceGetRequest]) (*connect.Response[v1.ClusterServiceGetResponse], error)
	// List clusters
	List(context.Context, *connect.Request[v1.ClusterServiceListRequest]) (*connect.Response[v1.ClusterServiceListResponse], error)
	// WatchStatus of a cluster
	WatchStatus(context.Context, *connect.Request[v1.ClusterServiceWatchStatusRequest], *connect.ServerStream[v1.ClusterServiceWatchStatusResponse]) error
	// Delete a cluster
	Delete(context.Context, *connect.Request[v1.ClusterServiceDeleteRequest]) (*connect.Response[v1.ClusterServiceDeleteResponse], error)
	// Update a cluster
	Update(context.Context, *connect.Request[v1.ClusterServiceUpdateRequest]) (*connect.Response[v1.ClusterServiceUpdateResponse], error)
	// GetCredentials of a cluster
	GetCredentials(context.Context, *connect.Request[v1.ClusterServiceGetCredentialsRequest]) (*connect.Response[v1.ClusterServiceGetCredentialsResponse], error)
	// Operate on a cluster
	Operate(context.Context, *connect.Request[v1.ClusterServiceOperateRequest]) (*connect.Response[v1.ClusterServiceOperateResponse], error)
}

ClusterServiceHandler is an implementation of the api.v1.ClusterService service.

type HealthServiceClient 

type HealthServiceClient interface {
	// Get the health of the platform
	Get(context.Context, *connect.Request[v1.HealthServiceGetRequest]) (*connect.Response[v1.HealthServiceGetResponse], error)
}

HealthServiceClient is a client for the api.v1.HealthService service.

func NewHealthServiceClient 

func NewHealthServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) HealthServiceClient

NewHealthServiceClient constructs a client for the api.v1.HealthService 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 HealthServiceHandler 

type HealthServiceHandler interface {
	// Get the health of the platform
	Get(context.Context, *connect.Request[v1.HealthServiceGetRequest]) (*connect.Response[v1.HealthServiceGetResponse], error)
}

HealthServiceHandler is an implementation of the api.v1.HealthService service.

type IPServiceClient 

type IPServiceClient interface {
	// Get a ip
	Get(context.Context, *connect.Request[v1.IPServiceGetRequest]) (*connect.Response[v1.IPServiceGetResponse], error)
	// Allocate a ip
	Allocate(context.Context, *connect.Request[v1.IPServiceAllocateRequest]) (*connect.Response[v1.IPServiceAllocateResponse], error)
	// Update a ip
	Update(context.Context, *connect.Request[v1.IPServiceUpdateRequest]) (*connect.Response[v1.IPServiceUpdateResponse], error)
	// List all ips
	List(context.Context, *connect.Request[v1.IPServiceListRequest]) (*connect.Response[v1.IPServiceListResponse], error)
	// Delete a ip
	Delete(context.Context, *connect.Request[v1.IPServiceDeleteRequest]) (*connect.Response[v1.IPServiceDeleteResponse], error)
}

IPServiceClient is a client for the api.v1.IPService service.

func NewIPServiceClient 

func NewIPServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) IPServiceClient

NewIPServiceClient constructs a client for the api.v1.IPService 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 IPServiceHandler 

type IPServiceHandler interface {
	// Get a ip
	Get(context.Context, *connect.Request[v1.IPServiceGetRequest]) (*connect.Response[v1.IPServiceGetResponse], error)
	// Allocate a ip
	Allocate(context.Context, *connect.Request[v1.IPServiceAllocateRequest]) (*connect.Response[v1.IPServiceAllocateResponse], error)
	// Update a ip
	Update(context.Context, *connect.Request[v1.IPServiceUpdateRequest]) (*connect.Response[v1.IPServiceUpdateResponse], error)
	// List all ips
	List(context.Context, *connect.Request[v1.IPServiceListRequest]) (*connect.Response[v1.IPServiceListResponse], error)
	// Delete a ip
	Delete(context.Context, *connect.Request[v1.IPServiceDeleteRequest]) (*connect.Response[v1.IPServiceDeleteResponse], error)
}

IPServiceHandler is an implementation of the api.v1.IPService service.

type MethodServiceClient 

type MethodServiceClient interface {
	// List all public visible methods
	List(context.Context, *connect.Request[v1.MethodServiceListRequest]) (*connect.Response[v1.MethodServiceListResponse], error)
	// TokenScopedList all methods callable with the token present in the request
	TokenScopedList(context.Context, *connect.Request[v1.MethodServiceTokenScopedListRequest]) (*connect.Response[v1.MethodServiceTokenScopedListResponse], error)
}

MethodServiceClient is a client for the api.v1.MethodService service.

func NewMethodServiceClient 

func NewMethodServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MethodServiceClient

NewMethodServiceClient constructs a client for the api.v1.MethodService 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 MethodServiceHandler 

type MethodServiceHandler interface {
	// List all public visible methods
	List(context.Context, *connect.Request[v1.MethodServiceListRequest]) (*connect.Response[v1.MethodServiceListResponse], error)
	// TokenScopedList all methods callable with the token present in the request
	TokenScopedList(context.Context, *connect.Request[v1.MethodServiceTokenScopedListRequest]) (*connect.Response[v1.MethodServiceTokenScopedListResponse], error)
}

MethodServiceHandler is an implementation of the api.v1.MethodService service.

type PaymentServiceClient 

type PaymentServiceClient interface {
	// CreateOrUpdateCustomer the payment data on the payment processor
	CreateOrUpdateCustomer(context.Context, *connect.Request[v1.PaymentServiceCreateOrUpdateCustomerRequest]) (*connect.Response[v1.PaymentServiceCreateOrUpdateCustomerResponse], error)
	// GetCustomer from the payment processor
	GetCustomer(context.Context, *connect.Request[v1.PaymentServiceGetCustomerRequest]) (*connect.Response[v1.PaymentServiceGetCustomerResponse], error)
	// GetCustomerWithLogin from the payment processor
	GetCustomerWithLogin(context.Context, *connect.Request[v1.PaymentServiceGetCustomerWithLoginRequest]) (*connect.Response[v1.PaymentServiceGetCustomerWithLoginResponse], error)
	// CheckIfCustomerExists at the payment processor
	CheckIfCustomerExists(context.Context, *connect.Request[v1.PaymentServiceCheckIfCustomerExistsRequest]) (*connect.Response[v1.PaymentServiceCheckIfCustomerExistsResponse], error)
	// HasPaymentMethod check if the customer has a payment method provided
	HasPaymentMethod(context.Context, *connect.Request[v1.PaymentServiceHasPaymentMethodRequest]) (*connect.Response[v1.PaymentServiceHasPaymentMethodResponse], error)
	// DeletePaymentMethod of the customer
	DeletePaymentMethod(context.Context, *connect.Request[v1.PaymentServiceDeletePaymentMethodRequest]) (*connect.Response[v1.PaymentServiceDeletePaymentMethodResponse], error)
	// GetSubscriptionUsage of the customer
	GetSubscriptionUsage(context.Context, *connect.Request[v1.PaymentServiceGetSubscriptionUsageRequest]) (*connect.Response[v1.PaymentServiceGetSubscriptionUsageResponse], error)
	// GetInvoices of the customer
	GetInvoices(context.Context, *connect.Request[v1.PaymentServiceGetInvoicesRequest]) (*connect.Response[v1.PaymentServiceGetInvoicesResponse], error)
	// GetDefaultPrices of the products on the platform
	GetDefaultPrices(context.Context, *connect.Request[v1.PaymentServiceGetDefaultPricesRequest]) (*connect.Response[v1.PaymentServiceGetDefaultPricesResponse], error)
	// CheckAdmitted if the customer is allowed to use the service on the platform
	CheckAdmitted(context.Context, *connect.Request[v1.PaymentServiceCheckAdmittedRequest]) (*connect.Response[v1.PaymentServiceCheckAdmittedResponse], error)
	// RequestAdmission for a customer to get allowed to used the service
	RequestAdmission(context.Context, *connect.Request[v1.PaymentServiceRequestAdmissionRequest]) (*connect.Response[v1.PaymentServiceRequestAdmissionResponse], error)
	// HasChargeableResources checks if the customer has resources actually consumed which are chargeable
	HasChargeableResources(context.Context, *connect.Request[v1.PaymentServiceHasChargeableResourcesRequest]) (*connect.Response[v1.PaymentServiceHasChargeableResourcesResponse], error)
}

PaymentServiceClient is a client for the api.v1.PaymentService service.

func NewPaymentServiceClient 

func NewPaymentServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PaymentServiceClient

NewPaymentServiceClient constructs a client for the api.v1.PaymentService 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 PaymentServiceHandler 

type PaymentServiceHandler interface {
	// CreateOrUpdateCustomer the payment data on the payment processor
	CreateOrUpdateCustomer(context.Context, *connect.Request[v1.PaymentServiceCreateOrUpdateCustomerRequest]) (*connect.Response[v1.PaymentServiceCreateOrUpdateCustomerResponse], error)
	// GetCustomer from the payment processor
	GetCustomer(context.Context, *connect.Request[v1.PaymentServiceGetCustomerRequest]) (*connect.Response[v1.PaymentServiceGetCustomerResponse], error)
	// GetCustomerWithLogin from the payment processor
	GetCustomerWithLogin(context.Context, *connect.Request[v1.PaymentServiceGetCustomerWithLoginRequest]) (*connect.Response[v1.PaymentServiceGetCustomerWithLoginResponse], error)
	// CheckIfCustomerExists at the payment processor
	CheckIfCustomerExists(context.Context, *connect.Request[v1.PaymentServiceCheckIfCustomerExistsRequest]) (*connect.Response[v1.PaymentServiceCheckIfCustomerExistsResponse], error)
	// HasPaymentMethod check if the customer has a payment method provided
	HasPaymentMethod(context.Context, *connect.Request[v1.PaymentServiceHasPaymentMethodRequest]) (*connect.Response[v1.PaymentServiceHasPaymentMethodResponse], error)
	// DeletePaymentMethod of the customer
	DeletePaymentMethod(context.Context, *connect.Request[v1.PaymentServiceDeletePaymentMethodRequest]) (*connect.Response[v1.PaymentServiceDeletePaymentMethodResponse], error)
	// GetSubscriptionUsage of the customer
	GetSubscriptionUsage(context.Context, *connect.Request[v1.PaymentServiceGetSubscriptionUsageRequest]) (*connect.Response[v1.PaymentServiceGetSubscriptionUsageResponse], error)
	// GetInvoices of the customer
	GetInvoices(context.Context, *connect.Request[v1.PaymentServiceGetInvoicesRequest]) (*connect.Response[v1.PaymentServiceGetInvoicesResponse], error)
	// GetDefaultPrices of the products on the platform
	GetDefaultPrices(context.Context, *connect.Request[v1.PaymentServiceGetDefaultPricesRequest]) (*connect.Response[v1.PaymentServiceGetDefaultPricesResponse], error)
	// CheckAdmitted if the customer is allowed to use the service on the platform
	CheckAdmitted(context.Context, *connect.Request[v1.PaymentServiceCheckAdmittedRequest]) (*connect.Response[v1.PaymentServiceCheckAdmittedResponse], error)
	// RequestAdmission for a customer to get allowed to used the service
	RequestAdmission(context.Context, *connect.Request[v1.PaymentServiceRequestAdmissionRequest]) (*connect.Response[v1.PaymentServiceRequestAdmissionResponse], error)
	// HasChargeableResources checks if the customer has resources actually consumed which are chargeable
	HasChargeableResources(context.Context, *connect.Request[v1.PaymentServiceHasChargeableResourcesRequest]) (*connect.Response[v1.PaymentServiceHasChargeableResourcesResponse], error)
}

PaymentServiceHandler is an implementation of the api.v1.PaymentService service.

type ProjectServiceClient 

type ProjectServiceClient interface {
	// List all accessible projects
	List(context.Context, *connect.Request[v1.ProjectServiceListRequest]) (*connect.Response[v1.ProjectServiceListResponse], error)
	// Get a project
	Get(context.Context, *connect.Request[v1.ProjectServiceGetRequest]) (*connect.Response[v1.ProjectServiceGetResponse], error)
}

ProjectServiceClient is a client for the api.v1.ProjectService service.

func NewProjectServiceClient 

func NewProjectServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProjectServiceClient

NewProjectServiceClient constructs a client for the api.v1.ProjectService 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 ProjectServiceHandler 

type ProjectServiceHandler interface {
	// List all accessible projects
	List(context.Context, *connect.Request[v1.ProjectServiceListRequest]) (*connect.Response[v1.ProjectServiceListResponse], error)
	// Get a project
	Get(context.Context, *connect.Request[v1.ProjectServiceGetRequest]) (*connect.Response[v1.ProjectServiceGetResponse], error)
}

ProjectServiceHandler is an implementation of the api.v1.ProjectService service.

type SnapshotServiceClient 

type SnapshotServiceClient interface {
	// Get a snapshot
	Get(context.Context, *connect.Request[v1.SnapshotServiceGetRequest]) (*connect.Response[v1.SnapshotServiceGetResponse], error)
	// List snapshots
	List(context.Context, *connect.Request[v1.SnapshotServiceListRequest]) (*connect.Response[v1.SnapshotServiceListResponse], error)
	// Delete a snapshot
	Delete(context.Context, *connect.Request[v1.SnapshotServiceDeleteRequest]) (*connect.Response[v1.SnapshotServiceDeleteResponse], error)
}

SnapshotServiceClient is a client for the api.v1.SnapshotService service.

func NewSnapshotServiceClient 

func NewSnapshotServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SnapshotServiceClient

NewSnapshotServiceClient constructs a client for the api.v1.SnapshotService 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 SnapshotServiceHandler 

type SnapshotServiceHandler interface {
	// Get a snapshot
	Get(context.Context, *connect.Request[v1.SnapshotServiceGetRequest]) (*connect.Response[v1.SnapshotServiceGetResponse], error)
	// List snapshots
	List(context.Context, *connect.Request[v1.SnapshotServiceListRequest]) (*connect.Response[v1.SnapshotServiceListResponse], error)
	// Delete a snapshot
	Delete(context.Context, *connect.Request[v1.SnapshotServiceDeleteRequest]) (*connect.Response[v1.SnapshotServiceDeleteResponse], error)
}

SnapshotServiceHandler is an implementation of the api.v1.SnapshotService service.

type TenantServiceClient 

type TenantServiceClient interface {
	// Create a tenant
	Create(context.Context, *connect.Request[v1.TenantServiceCreateRequest]) (*connect.Response[v1.TenantServiceCreateResponse], error)
	// CreateOrUpdate should only be used from within the application
	// will check if tenant already exists and updates if necessary, otherwise create a new tenant
	CreateOrUpdate(context.Context, *connect.Request[v1.TenantServiceCreateOrUpdateRequest]) (*connect.Response[v1.TenantServiceCreateOrUpdateResponse], error)
	// Get a tenant
	Get(context.Context, *connect.Request[v1.TenantServiceGetRequest]) (*connect.Response[v1.TenantServiceGetResponse], error)
	// Update a tenant
	Update(context.Context, *connect.Request[v1.TenantServiceUpdateRequest]) (*connect.Response[v1.TenantServiceUpdateResponse], error)
	// Delete a tenant
	Delete(context.Context, *connect.Request[v1.TenantServiceDeleteRequest]) (*connect.Response[v1.TenantServiceDeleteResponse], error)
}

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

func NewTenantServiceClient 

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

NewTenantServiceClient constructs a client for the api.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 

type TenantServiceHandler interface {
	// Create a tenant
	Create(context.Context, *connect.Request[v1.TenantServiceCreateRequest]) (*connect.Response[v1.TenantServiceCreateResponse], error)
	// CreateOrUpdate should only be used from within the application
	// will check if tenant already exists and updates if necessary, otherwise create a new tenant
	CreateOrUpdate(context.Context, *connect.Request[v1.TenantServiceCreateOrUpdateRequest]) (*connect.Response[v1.TenantServiceCreateOrUpdateResponse], error)
	// Get a tenant
	Get(context.Context, *connect.Request[v1.TenantServiceGetRequest]) (*connect.Response[v1.TenantServiceGetResponse], error)
	// Update a tenant
	Update(context.Context, *connect.Request[v1.TenantServiceUpdateRequest]) (*connect.Response[v1.TenantServiceUpdateResponse], error)
	// Delete a tenant
	Delete(context.Context, *connect.Request[v1.TenantServiceDeleteRequest]) (*connect.Response[v1.TenantServiceDeleteResponse], error)
}

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

type TokenServiceClient 

type TokenServiceClient interface {
	// Create a token to authenticate against the platform, the secret will be only visible in the response
	Create(context.Context, *connect.Request[v1.TokenServiceCreateRequest]) (*connect.Response[v1.TokenServiceCreateResponse], error)
	// List all your tokens
	List(context.Context, *connect.Request[v1.TokenServiceListRequest]) (*connect.Response[v1.TokenServiceListResponse], error)
	// Revoke a token, no further usage is possible afterwards
	Revoke(context.Context, *connect.Request[v1.TokenServiceRevokeRequest]) (*connect.Response[v1.TokenServiceRevokeResponse], error)
}

TokenServiceClient is a client for the api.v1.TokenService service.

func NewTokenServiceClient 

func NewTokenServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TokenServiceClient

NewTokenServiceClient constructs a client for the api.v1.TokenService 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 TokenServiceHandler 

type TokenServiceHandler interface {
	// Create a token to authenticate against the platform, the secret will be only visible in the response
	Create(context.Context, *connect.Request[v1.TokenServiceCreateRequest]) (*connect.Response[v1.TokenServiceCreateResponse], error)
	// List all your tokens
	List(context.Context, *connect.Request[v1.TokenServiceListRequest]) (*connect.Response[v1.TokenServiceListResponse], error)
	// Revoke a token, no further usage is possible afterwards
	Revoke(context.Context, *connect.Request[v1.TokenServiceRevokeRequest]) (*connect.Response[v1.TokenServiceRevokeResponse], error)
}

TokenServiceHandler is an implementation of the api.v1.TokenService service.

type UnimplementedAssetServiceHandler 

type UnimplementedAssetServiceHandler struct{}

UnimplementedAssetServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAssetServiceHandler) List 

func (UnimplementedAssetServiceHandler) List(context.Context, *connect.Request[v1.AssetServiceListRequest]) (*connect.Response[v1.AssetServiceListResponse], error)

type UnimplementedClusterServiceHandler 

type UnimplementedClusterServiceHandler struct{}

UnimplementedClusterServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedClusterServiceHandler) Create 

func (UnimplementedClusterServiceHandler) Create(context.Context, *connect.Request[v1.ClusterServiceCreateRequest]) (*connect.Response[v1.ClusterServiceCreateResponse], error)

func (UnimplementedClusterServiceHandler) Delete 

func (UnimplementedClusterServiceHandler) Delete(context.Context, *connect.Request[v1.ClusterServiceDeleteRequest]) (*connect.Response[v1.ClusterServiceDeleteResponse], error)

func (UnimplementedClusterServiceHandler) Get 

func (UnimplementedClusterServiceHandler) Get(context.Context, *connect.Request[v1.ClusterServiceGetRequest]) (*connect.Response[v1.ClusterServiceGetResponse], error)

func (UnimplementedClusterServiceHandler) GetCredentials 

func (UnimplementedClusterServiceHandler) GetCredentials(context.Context, *connect.Request[v1.ClusterServiceGetCredentialsRequest]) (*connect.Response[v1.ClusterServiceGetCredentialsResponse], error)

func (UnimplementedClusterServiceHandler) List 

func (UnimplementedClusterServiceHandler) List(context.Context, *connect.Request[v1.ClusterServiceListRequest]) (*connect.Response[v1.ClusterServiceListResponse], error)

func (UnimplementedClusterServiceHandler) Operate added in v0.7.1 

func (UnimplementedClusterServiceHandler) Operate(context.Context, *connect.Request[v1.ClusterServiceOperateRequest]) (*connect.Response[v1.ClusterServiceOperateResponse], error)

func (UnimplementedClusterServiceHandler) Update 

func (UnimplementedClusterServiceHandler) Update(context.Context, *connect.Request[v1.ClusterServiceUpdateRequest]) (*connect.Response[v1.ClusterServiceUpdateResponse], error)

func (UnimplementedClusterServiceHandler) WatchStatus 

func (UnimplementedClusterServiceHandler) WatchStatus(context.Context, *connect.Request[v1.ClusterServiceWatchStatusRequest], *connect.ServerStream[v1.ClusterServiceWatchStatusResponse]) error

type UnimplementedHealthServiceHandler 

type UnimplementedHealthServiceHandler struct{}

UnimplementedHealthServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedHealthServiceHandler) Get 

func (UnimplementedHealthServiceHandler) Get(context.Context, *connect.Request[v1.HealthServiceGetRequest]) (*connect.Response[v1.HealthServiceGetResponse], error)

type UnimplementedIPServiceHandler 

type UnimplementedIPServiceHandler struct{}

UnimplementedIPServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedIPServiceHandler) Allocate 

func (UnimplementedIPServiceHandler) Allocate(context.Context, *connect.Request[v1.IPServiceAllocateRequest]) (*connect.Response[v1.IPServiceAllocateResponse], error)

func (UnimplementedIPServiceHandler) Delete 

func (UnimplementedIPServiceHandler) Delete(context.Context, *connect.Request[v1.IPServiceDeleteRequest]) (*connect.Response[v1.IPServiceDeleteResponse], error)

func (UnimplementedIPServiceHandler) Get 

func (UnimplementedIPServiceHandler) Get(context.Context, *connect.Request[v1.IPServiceGetRequest]) (*connect.Response[v1.IPServiceGetResponse], error)

func (UnimplementedIPServiceHandler) List 

func (UnimplementedIPServiceHandler) List(context.Context, *connect.Request[v1.IPServiceListRequest]) (*connect.Response[v1.IPServiceListResponse], error)

func (UnimplementedIPServiceHandler) Update 

func (UnimplementedIPServiceHandler) Update(context.Context, *connect.Request[v1.IPServiceUpdateRequest]) (*connect.Response[v1.IPServiceUpdateResponse], error)

type UnimplementedMethodServiceHandler 

type UnimplementedMethodServiceHandler struct{}

UnimplementedMethodServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMethodServiceHandler) List 

func (UnimplementedMethodServiceHandler) List(context.Context, *connect.Request[v1.MethodServiceListRequest]) (*connect.Response[v1.MethodServiceListResponse], error)

func (UnimplementedMethodServiceHandler) TokenScopedList 

func (UnimplementedMethodServiceHandler) TokenScopedList(context.Context, *connect.Request[v1.MethodServiceTokenScopedListRequest]) (*connect.Response[v1.MethodServiceTokenScopedListResponse], error)

type UnimplementedPaymentServiceHandler 

type UnimplementedPaymentServiceHandler struct{}

UnimplementedPaymentServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedPaymentServiceHandler) CheckAdmitted 

func (UnimplementedPaymentServiceHandler) CheckAdmitted(context.Context, *connect.Request[v1.PaymentServiceCheckAdmittedRequest]) (*connect.Response[v1.PaymentServiceCheckAdmittedResponse], error)

func (UnimplementedPaymentServiceHandler) CheckIfCustomerExists 

func (UnimplementedPaymentServiceHandler) CheckIfCustomerExists(context.Context, *connect.Request[v1.PaymentServiceCheckIfCustomerExistsRequest]) (*connect.Response[v1.PaymentServiceCheckIfCustomerExistsResponse], error)

func (UnimplementedPaymentServiceHandler) CreateOrUpdateCustomer 

func (UnimplementedPaymentServiceHandler) CreateOrUpdateCustomer(context.Context, *connect.Request[v1.PaymentServiceCreateOrUpdateCustomerRequest]) (*connect.Response[v1.PaymentServiceCreateOrUpdateCustomerResponse], error)

func (UnimplementedPaymentServiceHandler) DeletePaymentMethod 

func (UnimplementedPaymentServiceHandler) DeletePaymentMethod(context.Context, *connect.Request[v1.PaymentServiceDeletePaymentMethodRequest]) (*connect.Response[v1.PaymentServiceDeletePaymentMethodResponse], error)

func (UnimplementedPaymentServiceHandler) GetCustomer 

func (UnimplementedPaymentServiceHandler) GetCustomer(context.Context, *connect.Request[v1.PaymentServiceGetCustomerRequest]) (*connect.Response[v1.PaymentServiceGetCustomerResponse], error)

func (UnimplementedPaymentServiceHandler) GetCustomerWithLogin 

func (UnimplementedPaymentServiceHandler) GetCustomerWithLogin(context.Context, *connect.Request[v1.PaymentServiceGetCustomerWithLoginRequest]) (*connect.Response[v1.PaymentServiceGetCustomerWithLoginResponse], error)

func (UnimplementedPaymentServiceHandler) GetDefaultPrices 

func (UnimplementedPaymentServiceHandler) GetDefaultPrices(context.Context, *connect.Request[v1.PaymentServiceGetDefaultPricesRequest]) (*connect.Response[v1.PaymentServiceGetDefaultPricesResponse], error)

func (UnimplementedPaymentServiceHandler) GetInvoices 

func (UnimplementedPaymentServiceHandler) GetInvoices(context.Context, *connect.Request[v1.PaymentServiceGetInvoicesRequest]) (*connect.Response[v1.PaymentServiceGetInvoicesResponse], error)

func (UnimplementedPaymentServiceHandler) GetSubscriptionUsage 

func (UnimplementedPaymentServiceHandler) GetSubscriptionUsage(context.Context, *connect.Request[v1.PaymentServiceGetSubscriptionUsageRequest]) (*connect.Response[v1.PaymentServiceGetSubscriptionUsageResponse], error)

func (UnimplementedPaymentServiceHandler) HasChargeableResources 

func (UnimplementedPaymentServiceHandler) HasChargeableResources(context.Context, *connect.Request[v1.PaymentServiceHasChargeableResourcesRequest]) (*connect.Response[v1.PaymentServiceHasChargeableResourcesResponse], error)

func (UnimplementedPaymentServiceHandler) HasPaymentMethod 

func (UnimplementedPaymentServiceHandler) HasPaymentMethod(context.Context, *connect.Request[v1.PaymentServiceHasPaymentMethodRequest]) (*connect.Response[v1.PaymentServiceHasPaymentMethodResponse], error)

func (UnimplementedPaymentServiceHandler) RequestAdmission 

func (UnimplementedPaymentServiceHandler) RequestAdmission(context.Context, *connect.Request[v1.PaymentServiceRequestAdmissionRequest]) (*connect.Response[v1.PaymentServiceRequestAdmissionResponse], error)

type UnimplementedProjectServiceHandler 

type UnimplementedProjectServiceHandler struct{}

UnimplementedProjectServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProjectServiceHandler) Get 

func (UnimplementedProjectServiceHandler) Get(context.Context, *connect.Request[v1.ProjectServiceGetRequest]) (*connect.Response[v1.ProjectServiceGetResponse], error)

func (UnimplementedProjectServiceHandler) List 

func (UnimplementedProjectServiceHandler) List(context.Context, *connect.Request[v1.ProjectServiceListRequest]) (*connect.Response[v1.ProjectServiceListResponse], error)

type UnimplementedSnapshotServiceHandler 

type UnimplementedSnapshotServiceHandler struct{}

UnimplementedSnapshotServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedSnapshotServiceHandler) Delete 

func (UnimplementedSnapshotServiceHandler) Delete(context.Context, *connect.Request[v1.SnapshotServiceDeleteRequest]) (*connect.Response[v1.SnapshotServiceDeleteResponse], error)

func (UnimplementedSnapshotServiceHandler) Get 

func (UnimplementedSnapshotServiceHandler) Get(context.Context, *connect.Request[v1.SnapshotServiceGetRequest]) (*connect.Response[v1.SnapshotServiceGetResponse], error)

func (UnimplementedSnapshotServiceHandler) List 

func (UnimplementedSnapshotServiceHandler) List(context.Context, *connect.Request[v1.SnapshotServiceListRequest]) (*connect.Response[v1.SnapshotServiceListResponse], error)

type UnimplementedTenantServiceHandler 

type UnimplementedTenantServiceHandler struct{}

UnimplementedTenantServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTenantServiceHandler) Create 

func (UnimplementedTenantServiceHandler) Create(context.Context, *connect.Request[v1.TenantServiceCreateRequest]) (*connect.Response[v1.TenantServiceCreateResponse], error)

func (UnimplementedTenantServiceHandler) CreateOrUpdate 

func (UnimplementedTenantServiceHandler) CreateOrUpdate(context.Context, *connect.Request[v1.TenantServiceCreateOrUpdateRequest]) (*connect.Response[v1.TenantServiceCreateOrUpdateResponse], error)

func (UnimplementedTenantServiceHandler) Delete 

func (UnimplementedTenantServiceHandler) Delete(context.Context, *connect.Request[v1.TenantServiceDeleteRequest]) (*connect.Response[v1.TenantServiceDeleteResponse], error)

func (UnimplementedTenantServiceHandler) Get 

func (UnimplementedTenantServiceHandler) Get(context.Context, *connect.Request[v1.TenantServiceGetRequest]) (*connect.Response[v1.TenantServiceGetResponse], error)

func (UnimplementedTenantServiceHandler) Update 

func (UnimplementedTenantServiceHandler) Update(context.Context, *connect.Request[v1.TenantServiceUpdateRequest]) (*connect.Response[v1.TenantServiceUpdateResponse], error)

type UnimplementedTokenServiceHandler 

type UnimplementedTokenServiceHandler struct{}

UnimplementedTokenServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTokenServiceHandler) Create 

func (UnimplementedTokenServiceHandler) Create(context.Context, *connect.Request[v1.TokenServiceCreateRequest]) (*connect.Response[v1.TokenServiceCreateResponse], error)

func (UnimplementedTokenServiceHandler) List 

func (UnimplementedTokenServiceHandler) List(context.Context, *connect.Request[v1.TokenServiceListRequest]) (*connect.Response[v1.TokenServiceListResponse], error)

func (UnimplementedTokenServiceHandler) Revoke 

func (UnimplementedTokenServiceHandler) Revoke(context.Context, *connect.Request[v1.TokenServiceRevokeRequest]) (*connect.Response[v1.TokenServiceRevokeResponse], error)

type UnimplementedVersionServiceHandler 

type UnimplementedVersionServiceHandler struct{}

UnimplementedVersionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedVersionServiceHandler) Get 

func (UnimplementedVersionServiceHandler) Get(context.Context, *connect.Request[v1.VersionServiceGetRequest]) (*connect.Response[v1.VersionServiceGetResponse], error)

type UnimplementedVolumeServiceHandler 

type UnimplementedVolumeServiceHandler struct{}

UnimplementedVolumeServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedVolumeServiceHandler) Delete 

func (UnimplementedVolumeServiceHandler) Delete(context.Context, *connect.Request[v1.VolumeServiceDeleteRequest]) (*connect.Response[v1.VolumeServiceDeleteResponse], error)

func (UnimplementedVolumeServiceHandler) Get 

func (UnimplementedVolumeServiceHandler) Get(context.Context, *connect.Request[v1.VolumeServiceGetRequest]) (*connect.Response[v1.VolumeServiceGetResponse], error)

func (UnimplementedVolumeServiceHandler) List 

func (UnimplementedVolumeServiceHandler) List(context.Context, *connect.Request[v1.VolumeServiceListRequest]) (*connect.Response[v1.VolumeServiceListResponse], error)

type VersionServiceClient 

type VersionServiceClient interface {
	// Get the version
	Get(context.Context, *connect.Request[v1.VersionServiceGetRequest]) (*connect.Response[v1.VersionServiceGetResponse], error)
}

VersionServiceClient is a client for the api.v1.VersionService service.

func NewVersionServiceClient 

func NewVersionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) VersionServiceClient

NewVersionServiceClient constructs a client for the api.v1.VersionService 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 VersionServiceHandler 

type VersionServiceHandler interface {
	// Get the version
	Get(context.Context, *connect.Request[v1.VersionServiceGetRequest]) (*connect.Response[v1.VersionServiceGetResponse], error)
}

VersionServiceHandler is an implementation of the api.v1.VersionService service.

type VolumeServiceClient 

type VolumeServiceClient interface {
	// Get a volume
	Get(context.Context, *connect.Request[v1.VolumeServiceGetRequest]) (*connect.Response[v1.VolumeServiceGetResponse], error)
	// List the volumes
	List(context.Context, *connect.Request[v1.VolumeServiceListRequest]) (*connect.Response[v1.VolumeServiceListResponse], error)
	// Delete a volume
	Delete(context.Context, *connect.Request[v1.VolumeServiceDeleteRequest]) (*connect.Response[v1.VolumeServiceDeleteResponse], error)
}

VolumeServiceClient is a client for the api.v1.VolumeService service.

func NewVolumeServiceClient 

func NewVolumeServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) VolumeServiceClient

NewVolumeServiceClient constructs a client for the api.v1.VolumeService 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 VolumeServiceHandler 

type VolumeServiceHandler interface {
	// Get a volume
	Get(context.Context, *connect.Request[v1.VolumeServiceGetRequest]) (*connect.Response[v1.VolumeServiceGetResponse], error)
	// List the volumes
	List(context.Context, *connect.Request[v1.VolumeServiceListRequest]) (*connect.Response[v1.VolumeServiceListResponse], error)
	// Delete a volume
	Delete(context.Context, *connect.Request[v1.VolumeServiceDeleteRequest]) (*connect.Response[v1.VolumeServiceDeleteResponse], error)
}

VolumeServiceHandler is an implementation of the api.v1.VolumeService service.

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.