protoconnect

Documentation

Index

• Constants
• func NewAgentServiceHandler(svc AgentServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler)
• func NewProxyServiceHandler(svc ProxyServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler)
• type AgentServiceClient
  • func NewAgentServiceClient(httpClient connect_go.HTTPClient, baseURL string, ...) AgentServiceClient
• type AgentServiceHandler
• type ProxyServiceClient
  • func NewProxyServiceClient(httpClient connect_go.HTTPClient, baseURL string, ...) ProxyServiceClient
• type ProxyServiceHandler
• type UnimplementedAgentServiceHandler
  • func (UnimplementedAgentServiceHandler) Connect(context.Context, *connect_go.BidiStream[proto.Packet, proto.Packet]) error
• type UnimplementedProxyServiceHandler
  • func (UnimplementedProxyServiceHandler) Proxy(context.Context, *connect_go.BidiStream[proto.Packet, proto.Packet]) error

Constants

const (
	// ProxyServiceName is the fully-qualified name of the ProxyService service.
	ProxyServiceName = "ProxyService"
	// AgentServiceName is the fully-qualified name of the AgentService service.
	AgentServiceName = "AgentService"
)

Functions

func NewAgentServiceHandler

func NewAgentServiceHandler(svc AgentServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler)

NewAgentServiceHandler 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

func NewProxyServiceHandler(svc ProxyServiceHandler, opts ...connect_go.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.

Types

type AgentServiceClient

type AgentServiceClient interface {
	// Agent Identifier?
	Connect(context.Context) *connect_go.BidiStreamForClient[proto.Packet, proto.Packet]
}

AgentServiceClient is a client for the AgentService service.

func NewAgentServiceClient

func NewAgentServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) AgentServiceClient

NewAgentServiceClient constructs a client for the AgentService 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 AgentServiceHandler

type AgentServiceHandler interface {
	// Agent Identifier?
	Connect(context.Context, *connect_go.BidiStream[proto.Packet, proto.Packet]) error
}

AgentServiceHandler is an implementation of the AgentService service.

type ProxyServiceClient

type ProxyServiceClient interface {
	Proxy(context.Context) *connect_go.BidiStreamForClient[proto.Packet, proto.Packet]
}

ProxyServiceClient is a client for the ProxyService service.

func NewProxyServiceClient

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

NewProxyServiceClient constructs a client for the 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

type ProxyServiceHandler interface {
	Proxy(context.Context, *connect_go.BidiStream[proto.Packet, proto.Packet]) error
}

ProxyServiceHandler is an implementation of the ProxyService service.

type UnimplementedAgentServiceHandler

type UnimplementedAgentServiceHandler struct{}

UnimplementedAgentServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAgentServiceHandler) Connect

func (UnimplementedAgentServiceHandler) Connect(context.Context, *connect_go.BidiStream[proto.Packet, proto.Packet]) error

type UnimplementedProxyServiceHandler

type UnimplementedProxyServiceHandler struct{}

UnimplementedProxyServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProxyServiceHandler) Proxy

func (UnimplementedProxyServiceHandler) Proxy(context.Context, *connect_go.BidiStream[proto.Packet, proto.Packet]) error