connectionsconnect

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ConnectionServiceGetProvidersProcedure is the fully-qualified name of the ConnectionService's
	// GetProviders RPC.
	ConnectionServiceGetProvidersProcedure = "/scalekit.v1.connections.ConnectionService/GetProviders"
	// ConnectionServiceCreateEnvironmentConnectionProcedure is the fully-qualified name of the
	// ConnectionService's CreateEnvironmentConnection RPC.
	ConnectionServiceCreateEnvironmentConnectionProcedure = "/scalekit.v1.connections.ConnectionService/CreateEnvironmentConnection"
	// ConnectionServiceCreateConnectionProcedure is the fully-qualified name of the ConnectionService's
	// CreateConnection RPC.
	ConnectionServiceCreateConnectionProcedure = "/scalekit.v1.connections.ConnectionService/CreateConnection"
	// ConnectionServiceGetEnvironmentConnectionProcedure is the fully-qualified name of the
	// ConnectionService's GetEnvironmentConnection RPC.
	ConnectionServiceGetEnvironmentConnectionProcedure = "/scalekit.v1.connections.ConnectionService/GetEnvironmentConnection"
	// ConnectionServiceGetConnectionProcedure is the fully-qualified name of the ConnectionService's
	// GetConnection RPC.
	ConnectionServiceGetConnectionProcedure = "/scalekit.v1.connections.ConnectionService/GetConnection"
	// ConnectionServiceListConnectionsProcedure is the fully-qualified name of the ConnectionService's
	// ListConnections RPC.
	ConnectionServiceListConnectionsProcedure = "/scalekit.v1.connections.ConnectionService/ListConnections"
	// ConnectionServiceUpdateEnvironmentConnectionProcedure is the fully-qualified name of the
	// ConnectionService's UpdateEnvironmentConnection RPC.
	ConnectionServiceUpdateEnvironmentConnectionProcedure = "/scalekit.v1.connections.ConnectionService/UpdateEnvironmentConnection"
	// ConnectionServiceUpdateConnectionProcedure is the fully-qualified name of the ConnectionService's
	// UpdateConnection RPC.
	ConnectionServiceUpdateConnectionProcedure = "/scalekit.v1.connections.ConnectionService/UpdateConnection"
	// ConnectionServiceDeleteEnvironmentConnectionProcedure is the fully-qualified name of the
	// ConnectionService's DeleteEnvironmentConnection RPC.
	ConnectionServiceDeleteEnvironmentConnectionProcedure = "/scalekit.v1.connections.ConnectionService/DeleteEnvironmentConnection"
	// ConnectionServiceDeleteConnectionProcedure is the fully-qualified name of the ConnectionService's
	// DeleteConnection RPC.
	ConnectionServiceDeleteConnectionProcedure = "/scalekit.v1.connections.ConnectionService/DeleteConnection"
	// ConnectionServiceEnableEnvironmentConnectionProcedure is the fully-qualified name of the
	// ConnectionService's EnableEnvironmentConnection RPC.
	ConnectionServiceEnableEnvironmentConnectionProcedure = "/scalekit.v1.connections.ConnectionService/EnableEnvironmentConnection"
	// ConnectionServiceEnableConnectionProcedure is the fully-qualified name of the ConnectionService's
	// EnableConnection RPC.
	ConnectionServiceEnableConnectionProcedure = "/scalekit.v1.connections.ConnectionService/EnableConnection"
	// ConnectionServiceDisableEnvironmentConnectionProcedure is the fully-qualified name of the
	// ConnectionService's DisableEnvironmentConnection RPC.
	ConnectionServiceDisableEnvironmentConnectionProcedure = "/scalekit.v1.connections.ConnectionService/DisableEnvironmentConnection"
	// ConnectionServiceDisableConnectionProcedure is the fully-qualified name of the
	// ConnectionService's DisableConnection RPC.
	ConnectionServiceDisableConnectionProcedure = "/scalekit.v1.connections.ConnectionService/DisableConnection"
)

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 (
	// ConnectionServiceName is the fully-qualified name of the ConnectionService service.
	ConnectionServiceName = "scalekit.v1.connections.ConnectionService"
)

Variables

This section is empty.

Functions

func NewConnectionServiceHandler 

func NewConnectionServiceHandler(svc ConnectionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewConnectionServiceHandler 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 ConnectionServiceClient 

type ConnectionServiceClient interface {
	GetProviders(context.Context, *connect.Request[connections.GetProvidersRequest]) (*connect.Response[connections.GetProvidersResponse], error)
	CreateEnvironmentConnection(context.Context, *connect.Request[connections.CreateEnvironmentConnectionRequest]) (*connect.Response[connections.CreateConnectionResponse], error)
	CreateConnection(context.Context, *connect.Request[connections.CreateConnectionRequest]) (*connect.Response[connections.CreateConnectionResponse], error)
	GetEnvironmentConnection(context.Context, *connect.Request[connections.GetEnvironmentConnectionRequest]) (*connect.Response[connections.GetConnectionResponse], error)
	GetConnection(context.Context, *connect.Request[connections.GetConnectionRequest]) (*connect.Response[connections.GetConnectionResponse], error)
	ListConnections(context.Context, *connect.Request[connections.ListConnectionsRequest]) (*connect.Response[connections.ListConnectionsResponse], error)
	UpdateEnvironmentConnection(context.Context, *connect.Request[connections.UpdateEnvironmentConnectionRequest]) (*connect.Response[connections.UpdateConnectionResponse], error)
	UpdateConnection(context.Context, *connect.Request[connections.UpdateConnectionRequest]) (*connect.Response[connections.UpdateConnectionResponse], error)
	DeleteEnvironmentConnection(context.Context, *connect.Request[connections.DeleteEnvironmentConnectionRequest]) (*connect.Response[emptypb.Empty], error)
	DeleteConnection(context.Context, *connect.Request[connections.DeleteConnectionRequest]) (*connect.Response[emptypb.Empty], error)
	EnableEnvironmentConnection(context.Context, *connect.Request[connections.ToggleEnvironmentConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
	EnableConnection(context.Context, *connect.Request[connections.ToggleConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
	DisableEnvironmentConnection(context.Context, *connect.Request[connections.ToggleEnvironmentConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
	DisableConnection(context.Context, *connect.Request[connections.ToggleConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
}

ConnectionServiceClient is a client for the scalekit.v1.connections.ConnectionService service.

func NewConnectionServiceClient 

func NewConnectionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ConnectionServiceClient

NewConnectionServiceClient constructs a client for the scalekit.v1.connections.ConnectionService 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 ConnectionServiceHandler 

type ConnectionServiceHandler interface {
	GetProviders(context.Context, *connect.Request[connections.GetProvidersRequest]) (*connect.Response[connections.GetProvidersResponse], error)
	CreateEnvironmentConnection(context.Context, *connect.Request[connections.CreateEnvironmentConnectionRequest]) (*connect.Response[connections.CreateConnectionResponse], error)
	CreateConnection(context.Context, *connect.Request[connections.CreateConnectionRequest]) (*connect.Response[connections.CreateConnectionResponse], error)
	GetEnvironmentConnection(context.Context, *connect.Request[connections.GetEnvironmentConnectionRequest]) (*connect.Response[connections.GetConnectionResponse], error)
	GetConnection(context.Context, *connect.Request[connections.GetConnectionRequest]) (*connect.Response[connections.GetConnectionResponse], error)
	ListConnections(context.Context, *connect.Request[connections.ListConnectionsRequest]) (*connect.Response[connections.ListConnectionsResponse], error)
	UpdateEnvironmentConnection(context.Context, *connect.Request[connections.UpdateEnvironmentConnectionRequest]) (*connect.Response[connections.UpdateConnectionResponse], error)
	UpdateConnection(context.Context, *connect.Request[connections.UpdateConnectionRequest]) (*connect.Response[connections.UpdateConnectionResponse], error)
	DeleteEnvironmentConnection(context.Context, *connect.Request[connections.DeleteEnvironmentConnectionRequest]) (*connect.Response[emptypb.Empty], error)
	DeleteConnection(context.Context, *connect.Request[connections.DeleteConnectionRequest]) (*connect.Response[emptypb.Empty], error)
	EnableEnvironmentConnection(context.Context, *connect.Request[connections.ToggleEnvironmentConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
	EnableConnection(context.Context, *connect.Request[connections.ToggleConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
	DisableEnvironmentConnection(context.Context, *connect.Request[connections.ToggleEnvironmentConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
	DisableConnection(context.Context, *connect.Request[connections.ToggleConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)
}

ConnectionServiceHandler is an implementation of the scalekit.v1.connections.ConnectionService service.

type UnimplementedConnectionServiceHandler 

type UnimplementedConnectionServiceHandler struct{}

UnimplementedConnectionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedConnectionServiceHandler) CreateConnection 

func (UnimplementedConnectionServiceHandler) CreateConnection(context.Context, *connect.Request[connections.CreateConnectionRequest]) (*connect.Response[connections.CreateConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) CreateEnvironmentConnection 

func (UnimplementedConnectionServiceHandler) CreateEnvironmentConnection(context.Context, *connect.Request[connections.CreateEnvironmentConnectionRequest]) (*connect.Response[connections.CreateConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) DeleteConnection 

func (UnimplementedConnectionServiceHandler) DeleteConnection(context.Context, *connect.Request[connections.DeleteConnectionRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedConnectionServiceHandler) DeleteEnvironmentConnection 

func (UnimplementedConnectionServiceHandler) DeleteEnvironmentConnection(context.Context, *connect.Request[connections.DeleteEnvironmentConnectionRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedConnectionServiceHandler) DisableConnection 

func (UnimplementedConnectionServiceHandler) DisableConnection(context.Context, *connect.Request[connections.ToggleConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) DisableEnvironmentConnection 

func (UnimplementedConnectionServiceHandler) DisableEnvironmentConnection(context.Context, *connect.Request[connections.ToggleEnvironmentConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) EnableConnection 

func (UnimplementedConnectionServiceHandler) EnableConnection(context.Context, *connect.Request[connections.ToggleConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) EnableEnvironmentConnection 

func (UnimplementedConnectionServiceHandler) EnableEnvironmentConnection(context.Context, *connect.Request[connections.ToggleEnvironmentConnectionRequest]) (*connect.Response[connections.ToggleConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) GetConnection 

func (UnimplementedConnectionServiceHandler) GetConnection(context.Context, *connect.Request[connections.GetConnectionRequest]) (*connect.Response[connections.GetConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) GetEnvironmentConnection 

func (UnimplementedConnectionServiceHandler) GetEnvironmentConnection(context.Context, *connect.Request[connections.GetEnvironmentConnectionRequest]) (*connect.Response[connections.GetConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) GetProviders 

func (UnimplementedConnectionServiceHandler) GetProviders(context.Context, *connect.Request[connections.GetProvidersRequest]) (*connect.Response[connections.GetProvidersResponse], error)

func (UnimplementedConnectionServiceHandler) ListConnections 

func (UnimplementedConnectionServiceHandler) ListConnections(context.Context, *connect.Request[connections.ListConnectionsRequest]) (*connect.Response[connections.ListConnectionsResponse], error)

func (UnimplementedConnectionServiceHandler) UpdateConnection 

func (UnimplementedConnectionServiceHandler) UpdateConnection(context.Context, *connect.Request[connections.UpdateConnectionRequest]) (*connect.Response[connections.UpdateConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) UpdateEnvironmentConnection 

func (UnimplementedConnectionServiceHandler) UpdateEnvironmentConnection(context.Context, *connect.Request[connections.UpdateEnvironmentConnectionRequest]) (*connect.Response[connections.UpdateConnectionResponse], 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.