connectionsv1connect

Documentation

Index

• Constants
• func NewConnectionsServiceHandler(svc ConnectionsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• type ConnectionsServiceClient
  • func NewConnectionsServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ConnectionsServiceClient
• type ConnectionsServiceHandler
• type UnimplementedConnectionsServiceHandler
  • func (UnimplementedConnectionsServiceHandler) Create(context.Context, *connect.Request[v1.CreateRequest]) (*connect.Response[v1.CreateResponse], error)
  • func (UnimplementedConnectionsServiceHandler) Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)
  • func (UnimplementedConnectionsServiceHandler) Get(context.Context, *connect.Request[v1.GetRequest]) (*connect.Response[v1.GetResponse], error)
  • func (UnimplementedConnectionsServiceHandler) List(context.Context, *connect.Request[v1.ListRequest]) (*connect.Response[v1.ListResponse], error)
  • func (UnimplementedConnectionsServiceHandler) RefreshStatus(context.Context, *connect.Request[v1.RefreshStatusRequest]) (*connect.Response[v1.RefreshStatusResponse], error)
  • func (UnimplementedConnectionsServiceHandler) Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)
  • func (UnimplementedConnectionsServiceHandler) Update(context.Context, *connect.Request[v1.UpdateRequest]) (*connect.Response[v1.UpdateResponse], error)

Constants

const (
	// ConnectionsServiceCreateProcedure is the fully-qualified name of the ConnectionsService's Create
	// RPC.
	ConnectionsServiceCreateProcedure = "/autokitteh.connections.v1.ConnectionsService/Create"
	// ConnectionsServiceDeleteProcedure is the fully-qualified name of the ConnectionsService's Delete
	// RPC.
	ConnectionsServiceDeleteProcedure = "/autokitteh.connections.v1.ConnectionsService/Delete"
	// ConnectionsServiceUpdateProcedure is the fully-qualified name of the ConnectionsService's Update
	// RPC.
	ConnectionsServiceUpdateProcedure = "/autokitteh.connections.v1.ConnectionsService/Update"
	// ConnectionsServiceGetProcedure is the fully-qualified name of the ConnectionsService's Get RPC.
	ConnectionsServiceGetProcedure = "/autokitteh.connections.v1.ConnectionsService/Get"
	// ConnectionsServiceListProcedure is the fully-qualified name of the ConnectionsService's List RPC.
	ConnectionsServiceListProcedure = "/autokitteh.connections.v1.ConnectionsService/List"
	// ConnectionsServiceTestProcedure is the fully-qualified name of the ConnectionsService's Test RPC.
	ConnectionsServiceTestProcedure = "/autokitteh.connections.v1.ConnectionsService/Test"
	// ConnectionsServiceRefreshStatusProcedure is the fully-qualified name of the ConnectionsService's
	// RefreshStatus RPC.
	ConnectionsServiceRefreshStatusProcedure = "/autokitteh.connections.v1.ConnectionsService/RefreshStatus"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	// ConnectionsServiceName is the fully-qualified name of the ConnectionsService service.
	ConnectionsServiceName = "autokitteh.connections.v1.ConnectionsService"
)

Functions

func NewConnectionsServiceHandler

func NewConnectionsServiceHandler(svc ConnectionsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewConnectionsServiceHandler 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 ConnectionsServiceClient

type ConnectionsServiceClient interface {
	// Initiated indirectly by an autokitteh user, based on an registered integration.
	Create(context.Context, *connect.Request[v1.CreateRequest]) (*connect.Response[v1.CreateResponse], error)
	Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)
	Update(context.Context, *connect.Request[v1.UpdateRequest]) (*connect.Response[v1.UpdateResponse], error)
	Get(context.Context, *connect.Request[v1.GetRequest]) (*connect.Response[v1.GetResponse], error)
	List(context.Context, *connect.Request[v1.ListRequest]) (*connect.Response[v1.ListResponse], error)
	// Test actively performs an integration test using a connection's configuration.
	// (This in turn calls Integration.TestConnection).
	Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)
	// RefreshStatus makes the connection query the integration regarding the
	// current connection status. This checks that the connection is configured correctly,
	// but does not perform any actual data transfer.
	// (This in turn calls Integration.GetConnectionStatus).
	RefreshStatus(context.Context, *connect.Request[v1.RefreshStatusRequest]) (*connect.Response[v1.RefreshStatusResponse], error)
}

ConnectionsServiceClient is a client for the autokitteh.connections.v1.ConnectionsService service.

func NewConnectionsServiceClient

func NewConnectionsServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ConnectionsServiceClient

NewConnectionsServiceClient constructs a client for the autokitteh.connections.v1.ConnectionsService 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 ConnectionsServiceHandler

type ConnectionsServiceHandler interface {
	// Initiated indirectly by an autokitteh user, based on an registered integration.
	Create(context.Context, *connect.Request[v1.CreateRequest]) (*connect.Response[v1.CreateResponse], error)
	Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)
	Update(context.Context, *connect.Request[v1.UpdateRequest]) (*connect.Response[v1.UpdateResponse], error)
	Get(context.Context, *connect.Request[v1.GetRequest]) (*connect.Response[v1.GetResponse], error)
	List(context.Context, *connect.Request[v1.ListRequest]) (*connect.Response[v1.ListResponse], error)
	// Test actively performs an integration test using a connection's configuration.
	// (This in turn calls Integration.TestConnection).
	Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)
	// RefreshStatus makes the connection query the integration regarding the
	// current connection status. This checks that the connection is configured correctly,
	// but does not perform any actual data transfer.
	// (This in turn calls Integration.GetConnectionStatus).
	RefreshStatus(context.Context, *connect.Request[v1.RefreshStatusRequest]) (*connect.Response[v1.RefreshStatusResponse], error)
}

ConnectionsServiceHandler is an implementation of the autokitteh.connections.v1.ConnectionsService service.

type UnimplementedConnectionsServiceHandler

type UnimplementedConnectionsServiceHandler struct{}

UnimplementedConnectionsServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedConnectionsServiceHandler) Create

func (UnimplementedConnectionsServiceHandler) Create(context.Context, *connect.Request[v1.CreateRequest]) (*connect.Response[v1.CreateResponse], error)

func (UnimplementedConnectionsServiceHandler) Delete

func (UnimplementedConnectionsServiceHandler) Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)

func (UnimplementedConnectionsServiceHandler) Get

func (UnimplementedConnectionsServiceHandler) Get(context.Context, *connect.Request[v1.GetRequest]) (*connect.Response[v1.GetResponse], error)

func (UnimplementedConnectionsServiceHandler) List

func (UnimplementedConnectionsServiceHandler) List(context.Context, *connect.Request[v1.ListRequest]) (*connect.Response[v1.ListResponse], error)

func (UnimplementedConnectionsServiceHandler) RefreshStatus

func (UnimplementedConnectionsServiceHandler) RefreshStatus(context.Context, *connect.Request[v1.RefreshStatusRequest]) (*connect.Response[v1.RefreshStatusResponse], error)

func (UnimplementedConnectionsServiceHandler) Test

func (UnimplementedConnectionsServiceHandler) Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)

func (UnimplementedConnectionsServiceHandler) Update

func (UnimplementedConnectionsServiceHandler) Update(context.Context, *connect.Request[v1.UpdateRequest]) (*connect.Response[v1.UpdateResponse], error)