Versions in this module Expand all Collapse all v0 v0.1.0 Oct 14, 2024 Changes in this version + type Client struct + func NewClient(ctx context.Context, cfg *config.ServiceDialer) *Client + func (c *Client) AgentList(ctx context.Context) (map[string]*pb.Agent, error) + func (c *Client) AgentRemove(ctx context.Context, agentId string) error + func (c *Client) ProxyStart(ctx context.Context, proxyAddr string) ([]byte, error) + func (c *Client) ProxyStop(ctx context.Context) error + func (c *Client) TunnelAddRoute(ctx context.Context, agentId string, routes []string) error + func (c *Client) TunnelList(ctx context.Context) ([]*pb.Tunnel, error) + func (c *Client) TunnelPause(ctx context.Context, agentId string) error + func (c *Client) TunnelRemoveRoute(ctx context.Context, agentId string, routes []string) error + func (c *Client) TunnelResume(ctx context.Context, agentId string) error + func (c *Client) TunnelStart(ctx context.Context, agentId string, routes []string) error + func (c *Client) TunnelStop(ctx context.Context, agentId string) error + type ClientKey struct + type Server struct + func NewServer(ctx context.Context, cfg *config.ServiceServer) *Server + func (s *Server) Run(listener net.Listener) error + func (s *Server) ShutDownGracefully() error + type ServiceHandler struct + func (s *ServiceHandler) AgentList(ctx context.Context, req *connect.Request[pb.Empty]) (*connect.Response[pb.AgentListResponse], error) + func (s *ServiceHandler) AgentRemove(ctx context.Context, req *connect.Request[pb.AgentRemoveRequest]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) ProxyStart(ctx context.Context, req *connect.Request[pb.ProxyStartRequest]) (*connect.Response[pb.ProxyStartResponse], error) + func (s *ServiceHandler) ProxyStop(ctx context.Context, req *connect.Request[pb.Empty]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) TunnelAddRoute(ctx context.Context, req *connect.Request[pb.TunnelAddRouteRequest]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) TunnelList(ctx context.Context, req *connect.Request[pb.Empty]) (*connect.Response[pb.TunnelListResponse], error) + func (s *ServiceHandler) TunnelPause(ctx context.Context, req *connect.Request[pb.TunnelPauseRequest]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) TunnelRemoveRoute(ctx context.Context, req *connect.Request[pb.TunnelRemoveRouteRequest]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) TunnelResume(ctx context.Context, req *connect.Request[pb.TunnelResumeRequest]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) TunnelStart(ctx context.Context, req *connect.Request[pb.TunnelStartRequest]) (*connect.Response[pb.Empty], error) + func (s *ServiceHandler) TunnelStop(ctx context.Context, req *connect.Request[pb.TunnelStopRequest]) (*connect.Response[pb.Empty], error)
Go to main page