v1connect

package
v0.0.21 Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// DevloopGatewayServiceName is the fully-qualified name of the DevloopGatewayService service.
	DevloopGatewayServiceName = "devloop_gateway.v1.DevloopGatewayService"
	// GatewayClientServiceName is the fully-qualified name of the GatewayClientService service.
	GatewayClientServiceName = "devloop_gateway.v1.GatewayClientService"
)
View Source 
const (
	// DevloopGatewayServiceCommunicateProcedure is the fully-qualified name of the
	// DevloopGatewayService's Communicate RPC.
	DevloopGatewayServiceCommunicateProcedure = "/devloop_gateway.v1.DevloopGatewayService/Communicate"
	// GatewayClientServiceListProjectsProcedure is the fully-qualified name of the
	// GatewayClientService's ListProjects RPC.
	GatewayClientServiceListProjectsProcedure = "/devloop_gateway.v1.GatewayClientService/ListProjects"
	// GatewayClientServiceGetConfigProcedure is the fully-qualified name of the GatewayClientService's
	// GetConfig RPC.
	GatewayClientServiceGetConfigProcedure = "/devloop_gateway.v1.GatewayClientService/GetConfig"
	// GatewayClientServiceGetRuleStatusProcedure is the fully-qualified name of the
	// GatewayClientService's GetRuleStatus RPC.
	GatewayClientServiceGetRuleStatusProcedure = "/devloop_gateway.v1.GatewayClientService/GetRuleStatus"
	// GatewayClientServiceTriggerRuleClientProcedure is the fully-qualified name of the
	// GatewayClientService's TriggerRuleClient RPC.
	GatewayClientServiceTriggerRuleClientProcedure = "/devloop_gateway.v1.GatewayClientService/TriggerRuleClient"
	// GatewayClientServiceListWatchedPathsProcedure is the fully-qualified name of the
	// GatewayClientService's ListWatchedPaths RPC.
	GatewayClientServiceListWatchedPathsProcedure = "/devloop_gateway.v1.GatewayClientService/ListWatchedPaths"
	// GatewayClientServiceReadFileContentProcedure is the fully-qualified name of the
	// GatewayClientService's ReadFileContent RPC.
	GatewayClientServiceReadFileContentProcedure = "/devloop_gateway.v1.GatewayClientService/ReadFileContent"
	// GatewayClientServiceStreamLogsClientProcedure is the fully-qualified name of the
	// GatewayClientService's StreamLogsClient RPC.
	GatewayClientServiceStreamLogsClientProcedure = "/devloop_gateway.v1.GatewayClientService/StreamLogsClient"
	// GatewayClientServiceGetHistoricalLogsClientProcedure is the fully-qualified name of the
	// GatewayClientService's GetHistoricalLogsClient RPC.
	GatewayClientServiceGetHistoricalLogsClientProcedure = "/devloop_gateway.v1.GatewayClientService/GetHistoricalLogsClient"
)

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.

Variables

This section is empty.

Functions

func NewDevloopGatewayServiceHandler 

func NewDevloopGatewayServiceHandler(svc DevloopGatewayServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDevloopGatewayServiceHandler 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 NewGatewayClientServiceHandler 

func NewGatewayClientServiceHandler(svc GatewayClientServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewGatewayClientServiceHandler 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 DevloopGatewayServiceClient 

type DevloopGatewayServiceClient interface {
	// Communicate handles all bidirectional communication between devloop and the gateway.
	Communicate(context.Context) *connect.BidiStreamForClient[v1.DevloopMessage, v1.DevloopMessage]
}

DevloopGatewayServiceClient is a client for the devloop_gateway.v1.DevloopGatewayService service.

func NewDevloopGatewayServiceClient 

func NewDevloopGatewayServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DevloopGatewayServiceClient

NewDevloopGatewayServiceClient constructs a client for the devloop_gateway.v1.DevloopGatewayService 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 DevloopGatewayServiceHandler 

type DevloopGatewayServiceHandler interface {
	// Communicate handles all bidirectional communication between devloop and the gateway.
	Communicate(context.Context, *connect.BidiStream[v1.DevloopMessage, v1.DevloopMessage]) error
}

DevloopGatewayServiceHandler is an implementation of the devloop_gateway.v1.DevloopGatewayService service.

type GatewayClientServiceClient 

type GatewayClientServiceClient interface {
	// List all registered devloop projects.
	ListProjects(context.Context, *connect.Request[v1.ListProjectsRequest]) (*connect.Response[v1.ListProjectsResponse], error)
	// Get the configuration for a specific devloop project.
	GetConfig(context.Context, *connect.Request[v1.GetConfigRequest]) (*connect.Response[v1.GetConfigResponse], error)
	// Get the detailed status of a specific rule within a project.
	GetRuleStatus(context.Context, *connect.Request[v1.GetRuleStatusRequest]) (*connect.Response[v1.GetRuleStatusResponse], error)
	// Manually trigger a specific rule in a devloop project.
	TriggerRuleClient(context.Context, *connect.Request[v1.TriggerRuleClientRequest]) (*connect.Response[v1.TriggerRuleClientResponse], error)
	// List all glob patterns being watched by a specific devloop project.
	ListWatchedPaths(context.Context, *connect.Request[v1.ListWatchedPathsRequest]) (*connect.Response[v1.ListWatchedPathsResponse], error)
	// Read and return the content of a specific file within a devloop project.
	ReadFileContent(context.Context, *connect.Request[v1.ReadFileContentRequest]) (*connect.Response[v1.ReadFileContentResponse], error)
	// Stream real-time logs for a specific rule in a project.
	StreamLogsClient(context.Context, *connect.Request[v1.StreamLogsClientRequest]) (*connect.ServerStreamForClient[v1.LogLine], error)
	// Retrieve historical logs for a specific rule, with optional time filtering.
	GetHistoricalLogsClient(context.Context, *connect.Request[v1.GetHistoricalLogsClientRequest]) (*connect.ServerStreamForClient[v1.LogLine], error)
}

GatewayClientServiceClient is a client for the devloop_gateway.v1.GatewayClientService service.

func NewGatewayClientServiceClient 

func NewGatewayClientServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) GatewayClientServiceClient

NewGatewayClientServiceClient constructs a client for the devloop_gateway.v1.GatewayClientService 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 GatewayClientServiceHandler 

type GatewayClientServiceHandler interface {
	// List all registered devloop projects.
	ListProjects(context.Context, *connect.Request[v1.ListProjectsRequest]) (*connect.Response[v1.ListProjectsResponse], error)
	// Get the configuration for a specific devloop project.
	GetConfig(context.Context, *connect.Request[v1.GetConfigRequest]) (*connect.Response[v1.GetConfigResponse], error)
	// Get the detailed status of a specific rule within a project.
	GetRuleStatus(context.Context, *connect.Request[v1.GetRuleStatusRequest]) (*connect.Response[v1.GetRuleStatusResponse], error)
	// Manually trigger a specific rule in a devloop project.
	TriggerRuleClient(context.Context, *connect.Request[v1.TriggerRuleClientRequest]) (*connect.Response[v1.TriggerRuleClientResponse], error)
	// List all glob patterns being watched by a specific devloop project.
	ListWatchedPaths(context.Context, *connect.Request[v1.ListWatchedPathsRequest]) (*connect.Response[v1.ListWatchedPathsResponse], error)
	// Read and return the content of a specific file within a devloop project.
	ReadFileContent(context.Context, *connect.Request[v1.ReadFileContentRequest]) (*connect.Response[v1.ReadFileContentResponse], error)
	// Stream real-time logs for a specific rule in a project.
	StreamLogsClient(context.Context, *connect.Request[v1.StreamLogsClientRequest], *connect.ServerStream[v1.LogLine]) error
	// Retrieve historical logs for a specific rule, with optional time filtering.
	GetHistoricalLogsClient(context.Context, *connect.Request[v1.GetHistoricalLogsClientRequest], *connect.ServerStream[v1.LogLine]) error
}

GatewayClientServiceHandler is an implementation of the devloop_gateway.v1.GatewayClientService service.

type UnimplementedDevloopGatewayServiceHandler 

type UnimplementedDevloopGatewayServiceHandler struct{}

UnimplementedDevloopGatewayServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDevloopGatewayServiceHandler) Communicate 

func (UnimplementedDevloopGatewayServiceHandler) Communicate(context.Context, *connect.BidiStream[v1.DevloopMessage, v1.DevloopMessage]) error

type UnimplementedGatewayClientServiceHandler 

type UnimplementedGatewayClientServiceHandler struct{}

UnimplementedGatewayClientServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedGatewayClientServiceHandler) GetConfig 

func (UnimplementedGatewayClientServiceHandler) GetConfig(context.Context, *connect.Request[v1.GetConfigRequest]) (*connect.Response[v1.GetConfigResponse], error)

func (UnimplementedGatewayClientServiceHandler) GetHistoricalLogsClient 

func (UnimplementedGatewayClientServiceHandler) GetHistoricalLogsClient(context.Context, *connect.Request[v1.GetHistoricalLogsClientRequest], *connect.ServerStream[v1.LogLine]) error

func (UnimplementedGatewayClientServiceHandler) GetRuleStatus 

func (UnimplementedGatewayClientServiceHandler) GetRuleStatus(context.Context, *connect.Request[v1.GetRuleStatusRequest]) (*connect.Response[v1.GetRuleStatusResponse], error)

func (UnimplementedGatewayClientServiceHandler) ListProjects 

func (UnimplementedGatewayClientServiceHandler) ListProjects(context.Context, *connect.Request[v1.ListProjectsRequest]) (*connect.Response[v1.ListProjectsResponse], error)

func (UnimplementedGatewayClientServiceHandler) ListWatchedPaths 

func (UnimplementedGatewayClientServiceHandler) ListWatchedPaths(context.Context, *connect.Request[v1.ListWatchedPathsRequest]) (*connect.Response[v1.ListWatchedPathsResponse], error)

func (UnimplementedGatewayClientServiceHandler) ReadFileContent 

func (UnimplementedGatewayClientServiceHandler) ReadFileContent(context.Context, *connect.Request[v1.ReadFileContentRequest]) (*connect.Response[v1.ReadFileContentResponse], error)

func (UnimplementedGatewayClientServiceHandler) StreamLogsClient 

func (UnimplementedGatewayClientServiceHandler) StreamLogsClient(context.Context, *connect.Request[v1.StreamLogsClientRequest], *connect.ServerStream[v1.LogLine]) error

func (UnimplementedGatewayClientServiceHandler) TriggerRuleClient 

func (UnimplementedGatewayClientServiceHandler) TriggerRuleClient(context.Context, *connect.Request[v1.TriggerRuleClientRequest]) (*connect.Response[v1.TriggerRuleClientResponse], 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.