adminv1connect

package
v0.9.3 Latest Latest
Warning

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

 Go to latest Published: May 10, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ClusterServiceGetProcedure is the fully-qualified name of the ClusterService's Get RPC.
	ClusterServiceGetProcedure = "/admin.v1.ClusterService/Get"
	// ClusterServiceListProcedure is the fully-qualified name of the ClusterService's List RPC.
	ClusterServiceListProcedure = "/admin.v1.ClusterService/List"
	// ClusterServiceCredentialsProcedure is the fully-qualified name of the ClusterService's
	// Credentials RPC.
	ClusterServiceCredentialsProcedure = "/admin.v1.ClusterService/Credentials"
)

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 (
	// PaymentServiceListCouponsProcedure is the fully-qualified name of the PaymentService's
	// ListCoupons RPC.
	PaymentServiceListCouponsProcedure = "/admin.v1.PaymentService/ListCoupons"
	// PaymentServiceAddCouponToCustomerProcedure is the fully-qualified name of the PaymentService's
	// AddCouponToCustomer RPC.
	PaymentServiceAddCouponToCustomerProcedure = "/admin.v1.PaymentService/AddCouponToCustomer"
	// PaymentServiceAddBalanceToCustomerProcedure is the fully-qualified name of the PaymentService's
	// AddBalanceToCustomer RPC.
	PaymentServiceAddBalanceToCustomerProcedure = "/admin.v1.PaymentService/AddBalanceToCustomer"
)

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 (
	// StorageServiceClusterInfoProcedure is the fully-qualified name of the StorageService's
	// ClusterInfo RPC.
	StorageServiceClusterInfoProcedure = "/admin.v1.StorageService/ClusterInfo"
	// StorageServiceListVolumesProcedure is the fully-qualified name of the StorageService's
	// ListVolumes RPC.
	StorageServiceListVolumesProcedure = "/admin.v1.StorageService/ListVolumes"
	// StorageServiceListSnapshotsProcedure is the fully-qualified name of the StorageService's
	// ListSnapshots RPC.
	StorageServiceListSnapshotsProcedure = "/admin.v1.StorageService/ListSnapshots"
)

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 (
	// TenantServiceListProcedure is the fully-qualified name of the TenantService's List RPC.
	TenantServiceListProcedure = "/admin.v1.TenantService/List"
	// TenantServiceAdmitProcedure is the fully-qualified name of the TenantService's Admit RPC.
	TenantServiceAdmitProcedure = "/admin.v1.TenantService/Admit"
	// TenantServiceRevokeProcedure is the fully-qualified name of the TenantService's Revoke RPC.
	TenantServiceRevokeProcedure = "/admin.v1.TenantService/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 (
	// TokenServiceListProcedure is the fully-qualified name of the TokenService's List RPC.
	TokenServiceListProcedure = "/admin.v1.TokenService/List"
	// TokenServiceRevokeProcedure is the fully-qualified name of the TokenService's Revoke RPC.
	TokenServiceRevokeProcedure = "/admin.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 (
	// ClusterServiceName is the fully-qualified name of the ClusterService service.
	ClusterServiceName = "admin.v1.ClusterService"
)
View Source 
const (
	// PaymentServiceName is the fully-qualified name of the PaymentService service.
	PaymentServiceName = "admin.v1.PaymentService"
)
View Source 
const (
	// StorageServiceName is the fully-qualified name of the StorageService service.
	StorageServiceName = "admin.v1.StorageService"
)
View Source 
const (
	// TenantServiceName is the fully-qualified name of the TenantService service.
	TenantServiceName = "admin.v1.TenantService"
)
View Source 
const (
	// TokenServiceName is the fully-qualified name of the TokenService service.
	TokenServiceName = "admin.v1.TokenService"
)

Variables

This section is empty.

Functions

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 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 NewStorageServiceHandler 

func NewStorageServiceHandler(svc StorageServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

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

Types

type ClusterServiceClient 

type ClusterServiceClient interface {
	// 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)
	// Credentials of a cluster
	Credentials(context.Context, *connect.Request[v1.ClusterServiceCredentialsRequest]) (*connect.Response[v1.ClusterServiceCredentialsResponse], error)
}

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

func NewClusterServiceClient 

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

NewClusterServiceClient constructs a client for the admin.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 {
	// 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)
	// Credentials of a cluster
	Credentials(context.Context, *connect.Request[v1.ClusterServiceCredentialsRequest]) (*connect.Response[v1.ClusterServiceCredentialsResponse], error)
}

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

type PaymentServiceClient 

type PaymentServiceClient interface {
	// ListCoupons list all available coupons
	ListCoupons(context.Context, *connect.Request[v1.PaymentServiceListCouponsRequest]) (*connect.Response[v1.PaymentServiceListCouponsResponse], error)
	// AddCouponToCustomer adds a coupon to a customer
	AddCouponToCustomer(context.Context, *connect.Request[v1.PaymentServiceAddCouponToCustomerRequest]) (*connect.Response[v1.PaymentServiceAddCouponToCustomerResponse], error)
	// AddBalanceToCustomer adds balance to a customer
	AddBalanceToCustomer(context.Context, *connect.Request[v1.PaymentServiceAddBalanceToCustomerRequest]) (*connect.Response[v1.PaymentServiceAddBalanceToCustomerResponse], error)
}

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

func NewPaymentServiceClient 

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

NewPaymentServiceClient constructs a client for the admin.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 {
	// ListCoupons list all available coupons
	ListCoupons(context.Context, *connect.Request[v1.PaymentServiceListCouponsRequest]) (*connect.Response[v1.PaymentServiceListCouponsResponse], error)
	// AddCouponToCustomer adds a coupon to a customer
	AddCouponToCustomer(context.Context, *connect.Request[v1.PaymentServiceAddCouponToCustomerRequest]) (*connect.Response[v1.PaymentServiceAddCouponToCustomerResponse], error)
	// AddBalanceToCustomer adds balance to a customer
	AddBalanceToCustomer(context.Context, *connect.Request[v1.PaymentServiceAddBalanceToCustomerRequest]) (*connect.Response[v1.PaymentServiceAddBalanceToCustomerResponse], error)
}

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

type StorageServiceClient 

type StorageServiceClient interface {
	// ClusterInfo returns overall statistics of the storage system
	ClusterInfo(context.Context, *connect.Request[v1.StorageServiceClusterInfoRequest]) (*connect.Response[v1.StorageServiceClusterInfoResponse], error)
	// ListVolumes list all volumes
	ListVolumes(context.Context, *connect.Request[v1.StorageServiceListVolumesRequest]) (*connect.Response[v1.StorageServiceListVolumesResponse], error)
	// ListSnapshots list all snapshots
	ListSnapshots(context.Context, *connect.Request[v1.StorageServiceListSnapshotsRequest]) (*connect.Response[v1.StorageServiceListSnapshotsResponse], error)
}

StorageServiceClient is a client for the admin.v1.StorageService service.

func NewStorageServiceClient 

func NewStorageServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) StorageServiceClient

NewStorageServiceClient constructs a client for the admin.v1.StorageService 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 StorageServiceHandler 

type StorageServiceHandler interface {
	// ClusterInfo returns overall statistics of the storage system
	ClusterInfo(context.Context, *connect.Request[v1.StorageServiceClusterInfoRequest]) (*connect.Response[v1.StorageServiceClusterInfoResponse], error)
	// ListVolumes list all volumes
	ListVolumes(context.Context, *connect.Request[v1.StorageServiceListVolumesRequest]) (*connect.Response[v1.StorageServiceListVolumesResponse], error)
	// ListSnapshots list all snapshots
	ListSnapshots(context.Context, *connect.Request[v1.StorageServiceListSnapshotsRequest]) (*connect.Response[v1.StorageServiceListSnapshotsResponse], error)
}

StorageServiceHandler is an implementation of the admin.v1.StorageService service.

type TenantServiceClient 

type TenantServiceClient interface {
	// List tenants
	List(context.Context, *connect.Request[v1.TenantServiceListRequest]) (*connect.Response[v1.TenantServiceListResponse], error)
	// Admit a tenant
	Admit(context.Context, *connect.Request[v1.TenantServiceAdmitRequest]) (*connect.Response[v1.TenantServiceAdmitResponse], error)
	// Revoke a tenant
	Revoke(context.Context, *connect.Request[v1.TenantServiceRevokeRequest]) (*connect.Response[v1.TenantServiceRevokeResponse], error)
}

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

func NewTenantServiceClient 

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

NewTenantServiceClient constructs a client for the admin.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 {
	// List tenants
	List(context.Context, *connect.Request[v1.TenantServiceListRequest]) (*connect.Response[v1.TenantServiceListResponse], error)
	// Admit a tenant
	Admit(context.Context, *connect.Request[v1.TenantServiceAdmitRequest]) (*connect.Response[v1.TenantServiceAdmitResponse], error)
	// Revoke a tenant
	Revoke(context.Context, *connect.Request[v1.TenantServiceRevokeRequest]) (*connect.Response[v1.TenantServiceRevokeResponse], error)
}

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

type TokenServiceClient 

type TokenServiceClient interface {
	// List tokens
	List(context.Context, *connect.Request[v1.TokenServiceListRequest]) (*connect.Response[v1.TokenServiceListResponse], error)
	// Revoke a token
	Revoke(context.Context, *connect.Request[v1.TokenServiceRevokeRequest]) (*connect.Response[v1.TokenServiceRevokeResponse], error)
}

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

func NewTokenServiceClient 

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

NewTokenServiceClient constructs a client for the admin.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 {
	// List tokens
	List(context.Context, *connect.Request[v1.TokenServiceListRequest]) (*connect.Response[v1.TokenServiceListResponse], error)
	// Revoke a token
	Revoke(context.Context, *connect.Request[v1.TokenServiceRevokeRequest]) (*connect.Response[v1.TokenServiceRevokeResponse], error)
}

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

type UnimplementedClusterServiceHandler 

type UnimplementedClusterServiceHandler struct{}

UnimplementedClusterServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedClusterServiceHandler) Credentials 

func (UnimplementedClusterServiceHandler) Credentials(context.Context, *connect.Request[v1.ClusterServiceCredentialsRequest]) (*connect.Response[v1.ClusterServiceCredentialsResponse], error)

func (UnimplementedClusterServiceHandler) Get 

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

func (UnimplementedClusterServiceHandler) List 

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

type UnimplementedPaymentServiceHandler 

type UnimplementedPaymentServiceHandler struct{}

UnimplementedPaymentServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedPaymentServiceHandler) AddBalanceToCustomer 

func (UnimplementedPaymentServiceHandler) AddBalanceToCustomer(context.Context, *connect.Request[v1.PaymentServiceAddBalanceToCustomerRequest]) (*connect.Response[v1.PaymentServiceAddBalanceToCustomerResponse], error)

func (UnimplementedPaymentServiceHandler) AddCouponToCustomer 

func (UnimplementedPaymentServiceHandler) AddCouponToCustomer(context.Context, *connect.Request[v1.PaymentServiceAddCouponToCustomerRequest]) (*connect.Response[v1.PaymentServiceAddCouponToCustomerResponse], error)

func (UnimplementedPaymentServiceHandler) ListCoupons 

func (UnimplementedPaymentServiceHandler) ListCoupons(context.Context, *connect.Request[v1.PaymentServiceListCouponsRequest]) (*connect.Response[v1.PaymentServiceListCouponsResponse], error)

type UnimplementedStorageServiceHandler 

type UnimplementedStorageServiceHandler struct{}

UnimplementedStorageServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedStorageServiceHandler) ClusterInfo 

func (UnimplementedStorageServiceHandler) ClusterInfo(context.Context, *connect.Request[v1.StorageServiceClusterInfoRequest]) (*connect.Response[v1.StorageServiceClusterInfoResponse], error)

func (UnimplementedStorageServiceHandler) ListSnapshots 

func (UnimplementedStorageServiceHandler) ListSnapshots(context.Context, *connect.Request[v1.StorageServiceListSnapshotsRequest]) (*connect.Response[v1.StorageServiceListSnapshotsResponse], error)

func (UnimplementedStorageServiceHandler) ListVolumes 

func (UnimplementedStorageServiceHandler) ListVolumes(context.Context, *connect.Request[v1.StorageServiceListVolumesRequest]) (*connect.Response[v1.StorageServiceListVolumesResponse], error)

type UnimplementedTenantServiceHandler 

type UnimplementedTenantServiceHandler struct{}

UnimplementedTenantServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTenantServiceHandler) Admit 

func (UnimplementedTenantServiceHandler) Admit(context.Context, *connect.Request[v1.TenantServiceAdmitRequest]) (*connect.Response[v1.TenantServiceAdmitResponse], error)

func (UnimplementedTenantServiceHandler) List 

func (UnimplementedTenantServiceHandler) List(context.Context, *connect.Request[v1.TenantServiceListRequest]) (*connect.Response[v1.TenantServiceListResponse], error)

func (UnimplementedTenantServiceHandler) Revoke 

func (UnimplementedTenantServiceHandler) Revoke(context.Context, *connect.Request[v1.TenantServiceRevokeRequest]) (*connect.Response[v1.TenantServiceRevokeResponse], error)

type UnimplementedTokenServiceHandler 

type UnimplementedTokenServiceHandler struct{}

UnimplementedTokenServiceHandler returns CodeUnimplemented from all methods.

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)

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.