app

Documentation

Index

• type Client
  • 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
• type Server
  • func NewServer(ctx context.Context, cfg *config.ServiceServer) *Server
  • func (s *Server) Run(listener net.Listener) error
  • func (s *Server) ShutDownGracefully() error
• type ServiceHandler
  • 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)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, cfg *config.ServiceDialer) *Client

func (*Client) AgentList

func (c *Client) AgentList(ctx context.Context) (map[string]*pb.Agent, error)

func (*Client) AgentRemove

func (c *Client) AgentRemove(ctx context.Context, agentId string) error

func (*Client) ProxyStart

func (c *Client) ProxyStart(ctx context.Context, proxyAddr string) ([]byte, error)

func (*Client) ProxyStop

func (c *Client) ProxyStop(ctx context.Context) error

func (*Client) TunnelAddRoute

func (c *Client) TunnelAddRoute(ctx context.Context, agentId string, routes []string) error

func (*Client) TunnelList

func (c *Client) TunnelList(ctx context.Context) ([]*pb.Tunnel, error)

func (*Client) TunnelPause

func (c *Client) TunnelPause(ctx context.Context, agentId string) error

func (*Client) TunnelRemoveRoute

func (c *Client) TunnelRemoveRoute(ctx context.Context, agentId string, routes []string) error

func (*Client) TunnelResume

func (c *Client) TunnelResume(ctx context.Context, agentId string) error

func (*Client) TunnelStart

func (c *Client) TunnelStart(ctx context.Context, agentId string, routes []string) error

func (*Client) TunnelStop

func (c *Client) TunnelStop(ctx context.Context, agentId string) error

type ClientKey

type ClientKey struct{}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, cfg *config.ServiceServer) *Server

func (*Server) Run

func (s *Server) Run(listener net.Listener) error

func (*Server) ShutDownGracefully

func (s *Server) ShutDownGracefully() error

type ServiceHandler

type ServiceHandler struct {
	serviceconnect.UnimplementedRaidoServiceHandler
	// contains filtered or unexported fields
}

func (*ServiceHandler) AgentList

func (s *ServiceHandler) AgentList(ctx context.Context, req *connect.Request[pb.Empty]) (*connect.Response[pb.AgentListResponse], error)

func (*ServiceHandler) AgentRemove

func (s *ServiceHandler) AgentRemove(ctx context.Context, req *connect.Request[pb.AgentRemoveRequest]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) ProxyStart

func (s *ServiceHandler) ProxyStart(ctx context.Context, req *connect.Request[pb.ProxyStartRequest]) (*connect.Response[pb.ProxyStartResponse], error)

func (*ServiceHandler) ProxyStop

func (s *ServiceHandler) ProxyStop(ctx context.Context, req *connect.Request[pb.Empty]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) TunnelAddRoute

func (s *ServiceHandler) TunnelAddRoute(ctx context.Context, req *connect.Request[pb.TunnelAddRouteRequest]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) TunnelList

func (s *ServiceHandler) TunnelList(ctx context.Context, req *connect.Request[pb.Empty]) (*connect.Response[pb.TunnelListResponse], error)

func (*ServiceHandler) TunnelPause

func (s *ServiceHandler) TunnelPause(ctx context.Context, req *connect.Request[pb.TunnelPauseRequest]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) TunnelRemoveRoute

func (s *ServiceHandler) TunnelRemoveRoute(ctx context.Context, req *connect.Request[pb.TunnelRemoveRouteRequest]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) TunnelResume

func (s *ServiceHandler) TunnelResume(ctx context.Context, req *connect.Request[pb.TunnelResumeRequest]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) TunnelStart

func (s *ServiceHandler) TunnelStart(ctx context.Context, req *connect.Request[pb.TunnelStartRequest]) (*connect.Response[pb.Empty], error)

func (*ServiceHandler) TunnelStop

func (s *ServiceHandler) TunnelStop(ctx context.Context, req *connect.Request[pb.TunnelStopRequest]) (*connect.Response[pb.Empty], error)