integrationv1alpha1connect

package
v1.69.1 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// IntegrationServiceCreateIntegrationProcedure is the fully-qualified name of the
	// IntegrationService's CreateIntegration RPC.
	IntegrationServiceCreateIntegrationProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/CreateIntegration"
	// IntegrationServiceUpdateIntegrationProcedure is the fully-qualified name of the
	// IntegrationService's UpdateIntegration RPC.
	IntegrationServiceUpdateIntegrationProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/UpdateIntegration"
	// IntegrationServiceGetIntegrationProcedure is the fully-qualified name of the IntegrationService's
	// GetIntegration RPC.
	IntegrationServiceGetIntegrationProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/GetIntegration"
	// IntegrationServiceDeleteIntegrationProcedure is the fully-qualified name of the
	// IntegrationService's DeleteIntegration RPC.
	IntegrationServiceDeleteIntegrationProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/DeleteIntegration"
	// IntegrationServiceListSyncsForIntegrationProcedure is the fully-qualified name of the
	// IntegrationService's ListSyncsForIntegration RPC.
	IntegrationServiceListSyncsForIntegrationProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/ListSyncsForIntegration"
	// IntegrationServiceSyncIntegrationProcedure is the fully-qualified name of the
	// IntegrationService's SyncIntegration RPC.
	IntegrationServiceSyncIntegrationProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/SyncIntegration"
	// IntegrationServiceListIntegrationsProcedure is the fully-qualified name of the
	// IntegrationService's ListIntegrations RPC.
	IntegrationServiceListIntegrationsProcedure = "/commonfate.control.integration.v1alpha1.IntegrationService/ListIntegrations"
)

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 (
	// ProxyServiceCreateProxyRdsResourceProcedure is the fully-qualified name of the ProxyService's
	// CreateProxyRdsResource RPC.
	ProxyServiceCreateProxyRdsResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/CreateProxyRdsResource"
	// ProxyServiceUpdateProxyRdsResourceProcedure is the fully-qualified name of the ProxyService's
	// UpdateProxyRdsResource RPC.
	ProxyServiceUpdateProxyRdsResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/UpdateProxyRdsResource"
	// ProxyServiceDeleteProxyRdsResourceProcedure is the fully-qualified name of the ProxyService's
	// DeleteProxyRdsResource RPC.
	ProxyServiceDeleteProxyRdsResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/DeleteProxyRdsResource"
	// ProxyServiceGetProxyRdsResourceProcedure is the fully-qualified name of the ProxyService's
	// GetProxyRdsResource RPC.
	ProxyServiceGetProxyRdsResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/GetProxyRdsResource"
	// ProxyServiceCreateProxyEksClusterResourceProcedure is the fully-qualified name of the
	// ProxyService's CreateProxyEksClusterResource RPC.
	ProxyServiceCreateProxyEksClusterResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/CreateProxyEksClusterResource"
	// ProxyServiceUpdateProxyEksClusterResourceProcedure is the fully-qualified name of the
	// ProxyService's UpdateProxyEksClusterResource RPC.
	ProxyServiceUpdateProxyEksClusterResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/UpdateProxyEksClusterResource"
	// ProxyServiceDeleteProxyEksClusterResourceProcedure is the fully-qualified name of the
	// ProxyService's DeleteProxyEksClusterResource RPC.
	ProxyServiceDeleteProxyEksClusterResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/DeleteProxyEksClusterResource"
	// ProxyServiceGetProxyEksClusterResourceProcedure is the fully-qualified name of the ProxyService's
	// GetProxyEksClusterResource RPC.
	ProxyServiceGetProxyEksClusterResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/GetProxyEksClusterResource"
	// ProxyServiceCreateProxyEksServiceAccountResourceProcedure is the fully-qualified name of the
	// ProxyService's CreateProxyEksServiceAccountResource RPC.
	ProxyServiceCreateProxyEksServiceAccountResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/CreateProxyEksServiceAccountResource"
	// ProxyServiceUpdateProxyEksServiceAccountResourceProcedure is the fully-qualified name of the
	// ProxyService's UpdateProxyEksServiceAccountResource RPC.
	ProxyServiceUpdateProxyEksServiceAccountResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/UpdateProxyEksServiceAccountResource"
	// ProxyServiceDeleteProxyEksServiceAccountResourceProcedure is the fully-qualified name of the
	// ProxyService's DeleteProxyEksServiceAccountResource RPC.
	ProxyServiceDeleteProxyEksServiceAccountResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/DeleteProxyEksServiceAccountResource"
	// ProxyServiceGetProxyEksServiceAccountResourceProcedure is the fully-qualified name of the
	// ProxyService's GetProxyEksServiceAccountResource RPC.
	ProxyServiceGetProxyEksServiceAccountResourceProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/GetProxyEksServiceAccountResource"
	// ProxyServiceCreateProxyProcedure is the fully-qualified name of the ProxyService's CreateProxy
	// RPC.
	ProxyServiceCreateProxyProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/CreateProxy"
	// ProxyServiceUpdateProxyProcedure is the fully-qualified name of the ProxyService's UpdateProxy
	// RPC.
	ProxyServiceUpdateProxyProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/UpdateProxy"
	// ProxyServiceDeleteProxyProcedure is the fully-qualified name of the ProxyService's DeleteProxy
	// RPC.
	ProxyServiceDeleteProxyProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/DeleteProxy"
	// ProxyServiceGetProxyProcedure is the fully-qualified name of the ProxyService's GetProxy RPC.
	ProxyServiceGetProxyProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/GetProxy"
	// ProxyServiceListProxyResourcesProcedure is the fully-qualified name of the ProxyService's
	// ListProxyResources RPC.
	ProxyServiceListProxyResourcesProcedure = "/commonfate.control.integration.v1alpha1.ProxyService/ListProxyResources"
)

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 (
	// SecretServiceCreateSecretProcedure is the fully-qualified name of the SecretService's
	// CreateSecret RPC.
	SecretServiceCreateSecretProcedure = "/commonfate.control.integration.v1alpha1.SecretService/CreateSecret"
	// SecretServiceUpdateSecretProcedure is the fully-qualified name of the SecretService's
	// UpdateSecret RPC.
	SecretServiceUpdateSecretProcedure = "/commonfate.control.integration.v1alpha1.SecretService/UpdateSecret"
	// SecretServiceDeleteSecretProcedure is the fully-qualified name of the SecretService's
	// DeleteSecret RPC.
	SecretServiceDeleteSecretProcedure = "/commonfate.control.integration.v1alpha1.SecretService/DeleteSecret"
	// SecretServiceListSecretsProcedure is the fully-qualified name of the SecretService's ListSecrets
	// RPC.
	SecretServiceListSecretsProcedure = "/commonfate.control.integration.v1alpha1.SecretService/ListSecrets"
)

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 (
	// IntegrationServiceName is the fully-qualified name of the IntegrationService service.
	IntegrationServiceName = "commonfate.control.integration.v1alpha1.IntegrationService"
)
View Source 
const (
	// ProxyHealthCheckServiceName is the fully-qualified name of the ProxyHealthCheckService service.
	ProxyHealthCheckServiceName = "commonfate.control.integration.v1alpha1.ProxyHealthCheckService"
)
View Source 
const (
	// ProxyHealthCheckServicePingProcedure is the fully-qualified name of the ProxyHealthCheckService's
	// Ping RPC.
	ProxyHealthCheckServicePingProcedure = "/commonfate.control.integration.v1alpha1.ProxyHealthCheckService/Ping"
)

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 (
	// ProxyServiceName is the fully-qualified name of the ProxyService service.
	ProxyServiceName = "commonfate.control.integration.v1alpha1.ProxyService"
)
View Source 
const (
	// SecretServiceName is the fully-qualified name of the SecretService service.
	SecretServiceName = "commonfate.control.integration.v1alpha1.SecretService"
)

Variables

This section is empty.

Functions

func NewIntegrationServiceHandler 

func NewIntegrationServiceHandler(svc IntegrationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewIntegrationServiceHandler 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 NewProxyHealthCheckServiceHandler added in v1.55.0 

func NewProxyHealthCheckServiceHandler(svc ProxyHealthCheckServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewProxyHealthCheckServiceHandler 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 NewProxyServiceHandler added in v1.55.0 

func NewProxyServiceHandler(svc ProxyServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewProxyServiceHandler 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 NewSecretServiceHandler added in v1.55.0 

func NewSecretServiceHandler(svc SecretServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewSecretServiceHandler 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 IntegrationServiceClient 

type IntegrationServiceClient interface {
	CreateIntegration(context.Context, *connect.Request[v1alpha1.CreateIntegrationRequest]) (*connect.Response[v1alpha1.CreateIntegrationResponse], error)
	UpdateIntegration(context.Context, *connect.Request[v1alpha1.UpdateIntegrationRequest]) (*connect.Response[v1alpha1.UpdateIntegrationResponse], error)
	GetIntegration(context.Context, *connect.Request[v1alpha1.GetIntegrationRequest]) (*connect.Response[v1alpha1.GetIntegrationResponse], error)
	DeleteIntegration(context.Context, *connect.Request[v1alpha1.DeleteIntegrationRequest]) (*connect.Response[v1alpha1.DeleteIntegrationResponse], error)
	// integration sync
	ListSyncsForIntegration(context.Context, *connect.Request[v1alpha1.ListSyncsForIntegrationRequest]) (*connect.Response[v1alpha1.ListSyncsForIntegrationResponse], error)
	SyncIntegration(context.Context, *connect.Request[v1alpha1.SyncIntegrationRequest]) (*connect.Response[v1alpha1.SyncIntegrationResponse], error)
	ListIntegrations(context.Context, *connect.Request[v1alpha1.ListIntegrationsRequest]) (*connect.Response[v1alpha1.ListIntegrationsResponse], error)
}

IntegrationServiceClient is a client for the commonfate.control.integration.v1alpha1.IntegrationService service.

func NewIntegrationServiceClient 

func NewIntegrationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) IntegrationServiceClient

NewIntegrationServiceClient constructs a client for the commonfate.control.integration.v1alpha1.IntegrationService 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 IntegrationServiceHandler 

type IntegrationServiceHandler interface {
	CreateIntegration(context.Context, *connect.Request[v1alpha1.CreateIntegrationRequest]) (*connect.Response[v1alpha1.CreateIntegrationResponse], error)
	UpdateIntegration(context.Context, *connect.Request[v1alpha1.UpdateIntegrationRequest]) (*connect.Response[v1alpha1.UpdateIntegrationResponse], error)
	GetIntegration(context.Context, *connect.Request[v1alpha1.GetIntegrationRequest]) (*connect.Response[v1alpha1.GetIntegrationResponse], error)
	DeleteIntegration(context.Context, *connect.Request[v1alpha1.DeleteIntegrationRequest]) (*connect.Response[v1alpha1.DeleteIntegrationResponse], error)
	// integration sync
	ListSyncsForIntegration(context.Context, *connect.Request[v1alpha1.ListSyncsForIntegrationRequest]) (*connect.Response[v1alpha1.ListSyncsForIntegrationResponse], error)
	SyncIntegration(context.Context, *connect.Request[v1alpha1.SyncIntegrationRequest]) (*connect.Response[v1alpha1.SyncIntegrationResponse], error)
	ListIntegrations(context.Context, *connect.Request[v1alpha1.ListIntegrationsRequest]) (*connect.Response[v1alpha1.ListIntegrationsResponse], error)
}

IntegrationServiceHandler is an implementation of the commonfate.control.integration.v1alpha1.IntegrationService service.

type ProxyHealthCheckServiceClient added in v1.55.0 

type ProxyHealthCheckServiceClient interface {
	// Ping the healthcheck service.
	Ping(context.Context, *connect.Request[v1alpha1.PingRequest]) (*connect.Response[v1alpha1.PingResponse], error)
}

ProxyHealthCheckServiceClient is a client for the commonfate.control.integration.v1alpha1.ProxyHealthCheckService service.

func NewProxyHealthCheckServiceClient added in v1.55.0 

func NewProxyHealthCheckServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProxyHealthCheckServiceClient

NewProxyHealthCheckServiceClient constructs a client for the commonfate.control.integration.v1alpha1.ProxyHealthCheckService 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 ProxyHealthCheckServiceHandler added in v1.55.0 

type ProxyHealthCheckServiceHandler interface {
	// Ping the healthcheck service.
	Ping(context.Context, *connect.Request[v1alpha1.PingRequest]) (*connect.Response[v1alpha1.PingResponse], error)
}

ProxyHealthCheckServiceHandler is an implementation of the commonfate.control.integration.v1alpha1.ProxyHealthCheckService service.

type ProxyServiceClient added in v1.55.0 

type ProxyServiceClient interface {
	// CRUD operations for proxy resource terraform provider resource
	CreateProxyRdsResource(context.Context, *connect.Request[v1alpha1.CreateProxyRdsResourceRequest]) (*connect.Response[v1alpha1.CreateProxyRdsResourceResponse], error)
	UpdateProxyRdsResource(context.Context, *connect.Request[v1alpha1.UpdateProxyRdsResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyRdsResourceResponse], error)
	DeleteProxyRdsResource(context.Context, *connect.Request[v1alpha1.DeleteProxyRdsResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyRdsResourceResponse], error)
	GetProxyRdsResource(context.Context, *connect.Request[v1alpha1.GetProxyRdsResourceRequest]) (*connect.Response[v1alpha1.GetProxyRdsResourceResponse], error)
	CreateProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.CreateProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.CreateProxyEksClusterResourceResponse], error)
	UpdateProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.UpdateProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyEksClusterResourceResponse], error)
	DeleteProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.DeleteProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyEksClusterResourceResponse], error)
	GetProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.GetProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.GetProxyEksClusterResourceResponse], error)
	CreateProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.CreateProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.CreateProxyEksServiceAccountResourceResponse], error)
	UpdateProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.UpdateProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyEksServiceAccountResourceResponse], error)
	DeleteProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.DeleteProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyEksServiceAccountResourceResponse], error)
	GetProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.GetProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.GetProxyEksServiceAccountResourceResponse], error)
	// CRUD operations for proxy terraform provider resource
	CreateProxy(context.Context, *connect.Request[v1alpha1.CreateProxyRequest]) (*connect.Response[v1alpha1.CreateProxyResponse], error)
	UpdateProxy(context.Context, *connect.Request[v1alpha1.UpdateProxyRequest]) (*connect.Response[v1alpha1.UpdateProxyResponse], error)
	DeleteProxy(context.Context, *connect.Request[v1alpha1.DeleteProxyRequest]) (*connect.Response[v1alpha1.DeleteProxyResponse], error)
	GetProxy(context.Context, *connect.Request[v1alpha1.GetProxyRequest]) (*connect.Response[v1alpha1.GetProxyResponse], error)
	// Used by the proxy to get resources
	ListProxyResources(context.Context, *connect.Request[v1alpha1.ListProxyResourcesRequest]) (*connect.Response[v1alpha1.ListProxyResourcesResponse], error)
}

ProxyServiceClient is a client for the commonfate.control.integration.v1alpha1.ProxyService service.

func NewProxyServiceClient added in v1.55.0 

func NewProxyServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProxyServiceClient

NewProxyServiceClient constructs a client for the commonfate.control.integration.v1alpha1.ProxyService 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 ProxyServiceHandler added in v1.55.0 

type ProxyServiceHandler interface {
	// CRUD operations for proxy resource terraform provider resource
	CreateProxyRdsResource(context.Context, *connect.Request[v1alpha1.CreateProxyRdsResourceRequest]) (*connect.Response[v1alpha1.CreateProxyRdsResourceResponse], error)
	UpdateProxyRdsResource(context.Context, *connect.Request[v1alpha1.UpdateProxyRdsResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyRdsResourceResponse], error)
	DeleteProxyRdsResource(context.Context, *connect.Request[v1alpha1.DeleteProxyRdsResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyRdsResourceResponse], error)
	GetProxyRdsResource(context.Context, *connect.Request[v1alpha1.GetProxyRdsResourceRequest]) (*connect.Response[v1alpha1.GetProxyRdsResourceResponse], error)
	CreateProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.CreateProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.CreateProxyEksClusterResourceResponse], error)
	UpdateProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.UpdateProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyEksClusterResourceResponse], error)
	DeleteProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.DeleteProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyEksClusterResourceResponse], error)
	GetProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.GetProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.GetProxyEksClusterResourceResponse], error)
	CreateProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.CreateProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.CreateProxyEksServiceAccountResourceResponse], error)
	UpdateProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.UpdateProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyEksServiceAccountResourceResponse], error)
	DeleteProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.DeleteProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyEksServiceAccountResourceResponse], error)
	GetProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.GetProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.GetProxyEksServiceAccountResourceResponse], error)
	// CRUD operations for proxy terraform provider resource
	CreateProxy(context.Context, *connect.Request[v1alpha1.CreateProxyRequest]) (*connect.Response[v1alpha1.CreateProxyResponse], error)
	UpdateProxy(context.Context, *connect.Request[v1alpha1.UpdateProxyRequest]) (*connect.Response[v1alpha1.UpdateProxyResponse], error)
	DeleteProxy(context.Context, *connect.Request[v1alpha1.DeleteProxyRequest]) (*connect.Response[v1alpha1.DeleteProxyResponse], error)
	GetProxy(context.Context, *connect.Request[v1alpha1.GetProxyRequest]) (*connect.Response[v1alpha1.GetProxyResponse], error)
	// Used by the proxy to get resources
	ListProxyResources(context.Context, *connect.Request[v1alpha1.ListProxyResourcesRequest]) (*connect.Response[v1alpha1.ListProxyResourcesResponse], error)
}

ProxyServiceHandler is an implementation of the commonfate.control.integration.v1alpha1.ProxyService service.

type SecretServiceClient added in v1.55.0 

type SecretServiceClient interface {
	CreateSecret(context.Context, *connect.Request[v1alpha1.CreateSecretRequest]) (*connect.Response[v1alpha1.CreateSecretResponse], error)
	UpdateSecret(context.Context, *connect.Request[v1alpha1.UpdateSecretRequest]) (*connect.Response[v1alpha1.UpdateSecretResponse], error)
	DeleteSecret(context.Context, *connect.Request[v1alpha1.DeleteSecretRequest]) (*connect.Response[v1alpha1.DeleteSecretResponse], error)
	ListSecrets(context.Context, *connect.Request[v1alpha1.ListSecretsRequest]) (*connect.Response[v1alpha1.ListSecretsResponse], error)
}

SecretServiceClient is a client for the commonfate.control.integration.v1alpha1.SecretService service.

func NewSecretServiceClient added in v1.55.0 

func NewSecretServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) SecretServiceClient

NewSecretServiceClient constructs a client for the commonfate.control.integration.v1alpha1.SecretService 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 SecretServiceHandler added in v1.55.0 

type SecretServiceHandler interface {
	CreateSecret(context.Context, *connect.Request[v1alpha1.CreateSecretRequest]) (*connect.Response[v1alpha1.CreateSecretResponse], error)
	UpdateSecret(context.Context, *connect.Request[v1alpha1.UpdateSecretRequest]) (*connect.Response[v1alpha1.UpdateSecretResponse], error)
	DeleteSecret(context.Context, *connect.Request[v1alpha1.DeleteSecretRequest]) (*connect.Response[v1alpha1.DeleteSecretResponse], error)
	ListSecrets(context.Context, *connect.Request[v1alpha1.ListSecretsRequest]) (*connect.Response[v1alpha1.ListSecretsResponse], error)
}

SecretServiceHandler is an implementation of the commonfate.control.integration.v1alpha1.SecretService service.

type UnimplementedIntegrationServiceHandler 

type UnimplementedIntegrationServiceHandler struct{}

UnimplementedIntegrationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedIntegrationServiceHandler) CreateIntegration 

func (UnimplementedIntegrationServiceHandler) CreateIntegration(context.Context, *connect.Request[v1alpha1.CreateIntegrationRequest]) (*connect.Response[v1alpha1.CreateIntegrationResponse], error)

func (UnimplementedIntegrationServiceHandler) DeleteIntegration 

func (UnimplementedIntegrationServiceHandler) DeleteIntegration(context.Context, *connect.Request[v1alpha1.DeleteIntegrationRequest]) (*connect.Response[v1alpha1.DeleteIntegrationResponse], error)

func (UnimplementedIntegrationServiceHandler) GetIntegration 

func (UnimplementedIntegrationServiceHandler) GetIntegration(context.Context, *connect.Request[v1alpha1.GetIntegrationRequest]) (*connect.Response[v1alpha1.GetIntegrationResponse], error)

func (UnimplementedIntegrationServiceHandler) ListIntegrations 

func (UnimplementedIntegrationServiceHandler) ListIntegrations(context.Context, *connect.Request[v1alpha1.ListIntegrationsRequest]) (*connect.Response[v1alpha1.ListIntegrationsResponse], error)

func (UnimplementedIntegrationServiceHandler) ListSyncsForIntegration added in v1.58.0 

func (UnimplementedIntegrationServiceHandler) ListSyncsForIntegration(context.Context, *connect.Request[v1alpha1.ListSyncsForIntegrationRequest]) (*connect.Response[v1alpha1.ListSyncsForIntegrationResponse], error)

func (UnimplementedIntegrationServiceHandler) SyncIntegration added in v1.58.0 

func (UnimplementedIntegrationServiceHandler) SyncIntegration(context.Context, *connect.Request[v1alpha1.SyncIntegrationRequest]) (*connect.Response[v1alpha1.SyncIntegrationResponse], error)

func (UnimplementedIntegrationServiceHandler) UpdateIntegration 

func (UnimplementedIntegrationServiceHandler) UpdateIntegration(context.Context, *connect.Request[v1alpha1.UpdateIntegrationRequest]) (*connect.Response[v1alpha1.UpdateIntegrationResponse], error)

type UnimplementedProxyHealthCheckServiceHandler added in v1.55.0 

type UnimplementedProxyHealthCheckServiceHandler struct{}

UnimplementedProxyHealthCheckServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProxyHealthCheckServiceHandler) Ping added in v1.55.0 

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

type UnimplementedProxyServiceHandler added in v1.55.0 

type UnimplementedProxyServiceHandler struct{}

UnimplementedProxyServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProxyServiceHandler) CreateProxy added in v1.55.0 

func (UnimplementedProxyServiceHandler) CreateProxy(context.Context, *connect.Request[v1alpha1.CreateProxyRequest]) (*connect.Response[v1alpha1.CreateProxyResponse], error)

func (UnimplementedProxyServiceHandler) CreateProxyEksClusterResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) CreateProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.CreateProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.CreateProxyEksClusterResourceResponse], error)

func (UnimplementedProxyServiceHandler) CreateProxyEksServiceAccountResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) CreateProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.CreateProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.CreateProxyEksServiceAccountResourceResponse], error)

func (UnimplementedProxyServiceHandler) CreateProxyRdsResource added in v1.55.0 

func (UnimplementedProxyServiceHandler) CreateProxyRdsResource(context.Context, *connect.Request[v1alpha1.CreateProxyRdsResourceRequest]) (*connect.Response[v1alpha1.CreateProxyRdsResourceResponse], error)

func (UnimplementedProxyServiceHandler) DeleteProxy added in v1.55.0 

func (UnimplementedProxyServiceHandler) DeleteProxy(context.Context, *connect.Request[v1alpha1.DeleteProxyRequest]) (*connect.Response[v1alpha1.DeleteProxyResponse], error)

func (UnimplementedProxyServiceHandler) DeleteProxyEksClusterResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) DeleteProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.DeleteProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyEksClusterResourceResponse], error)

func (UnimplementedProxyServiceHandler) DeleteProxyEksServiceAccountResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) DeleteProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.DeleteProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyEksServiceAccountResourceResponse], error)

func (UnimplementedProxyServiceHandler) DeleteProxyRdsResource added in v1.55.0 

func (UnimplementedProxyServiceHandler) DeleteProxyRdsResource(context.Context, *connect.Request[v1alpha1.DeleteProxyRdsResourceRequest]) (*connect.Response[v1alpha1.DeleteProxyRdsResourceResponse], error)

func (UnimplementedProxyServiceHandler) GetProxy added in v1.55.0 

func (UnimplementedProxyServiceHandler) GetProxy(context.Context, *connect.Request[v1alpha1.GetProxyRequest]) (*connect.Response[v1alpha1.GetProxyResponse], error)

func (UnimplementedProxyServiceHandler) GetProxyEksClusterResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) GetProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.GetProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.GetProxyEksClusterResourceResponse], error)

func (UnimplementedProxyServiceHandler) GetProxyEksServiceAccountResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) GetProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.GetProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.GetProxyEksServiceAccountResourceResponse], error)

func (UnimplementedProxyServiceHandler) GetProxyRdsResource added in v1.55.0 

func (UnimplementedProxyServiceHandler) GetProxyRdsResource(context.Context, *connect.Request[v1alpha1.GetProxyRdsResourceRequest]) (*connect.Response[v1alpha1.GetProxyRdsResourceResponse], error)

func (UnimplementedProxyServiceHandler) ListProxyResources added in v1.55.0 

func (UnimplementedProxyServiceHandler) ListProxyResources(context.Context, *connect.Request[v1alpha1.ListProxyResourcesRequest]) (*connect.Response[v1alpha1.ListProxyResourcesResponse], error)

func (UnimplementedProxyServiceHandler) UpdateProxy added in v1.55.0 

func (UnimplementedProxyServiceHandler) UpdateProxy(context.Context, *connect.Request[v1alpha1.UpdateProxyRequest]) (*connect.Response[v1alpha1.UpdateProxyResponse], error)

func (UnimplementedProxyServiceHandler) UpdateProxyEksClusterResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) UpdateProxyEksClusterResource(context.Context, *connect.Request[v1alpha1.UpdateProxyEksClusterResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyEksClusterResourceResponse], error)

func (UnimplementedProxyServiceHandler) UpdateProxyEksServiceAccountResource added in v1.67.0 

func (UnimplementedProxyServiceHandler) UpdateProxyEksServiceAccountResource(context.Context, *connect.Request[v1alpha1.UpdateProxyEksServiceAccountResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyEksServiceAccountResourceResponse], error)

func (UnimplementedProxyServiceHandler) UpdateProxyRdsResource added in v1.55.0 

func (UnimplementedProxyServiceHandler) UpdateProxyRdsResource(context.Context, *connect.Request[v1alpha1.UpdateProxyRdsResourceRequest]) (*connect.Response[v1alpha1.UpdateProxyRdsResourceResponse], error)

type UnimplementedSecretServiceHandler added in v1.55.0 

type UnimplementedSecretServiceHandler struct{}

UnimplementedSecretServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedSecretServiceHandler) CreateSecret added in v1.55.0 

func (UnimplementedSecretServiceHandler) CreateSecret(context.Context, *connect.Request[v1alpha1.CreateSecretRequest]) (*connect.Response[v1alpha1.CreateSecretResponse], error)

func (UnimplementedSecretServiceHandler) DeleteSecret added in v1.55.0 

func (UnimplementedSecretServiceHandler) DeleteSecret(context.Context, *connect.Request[v1alpha1.DeleteSecretRequest]) (*connect.Response[v1alpha1.DeleteSecretResponse], error)

func (UnimplementedSecretServiceHandler) ListSecrets added in v1.55.0 

func (UnimplementedSecretServiceHandler) ListSecrets(context.Context, *connect.Request[v1alpha1.ListSecretsRequest]) (*connect.Response[v1alpha1.ListSecretsResponse], error)

func (UnimplementedSecretServiceHandler) UpdateSecret added in v1.55.0 

func (UnimplementedSecretServiceHandler) UpdateSecret(context.Context, *connect.Request[v1alpha1.UpdateSecretRequest]) (*connect.Response[v1alpha1.UpdateSecretResponse], 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.