node

package

v0.3.1-rc.2 Latest Latest Go to latest Published: Nov 1, 2022 License: MIT Imports: 26 Imported by: 0

Details

This section is empty.

This section is empty.

func NewLink(outbound *outbound, manager *manager, links map[string]*node.NodeLink) *link

func NewManager(m *node.Manager) *manager

func NewOutbound(tcp, udp *node.Point, mamanager *manager) *outbound

type Nodes struct {
	grpcnode.UnimplementedNodeManagerServer
	// contains filtered or unexported fields
}

func NewNodes(configPath string) *Nodes

func (o Nodes) Conn(host proxy.Address) (_ net.Conn, err error)

func (n *Nodes) DeleteLinks(_ context.Context, s *grpcnode.LinkReq) (*emptypb.Empty, error)

func (n *Nodes) DeleteNode(_ context.Context, s *wrapperspb.StringValue) (*emptypb.Empty, error)

func (o Nodes) Do(req *http.Request) (*http.Response, error)

func (n *Nodes) GetLinks(ctx context.Context, in *emptypb.Empty) (*grpcnode.GetLinksResp, error)

func (n *Nodes) GetManager(context.Context, *wrapperspb.StringValue) (*node.Manager, error)

func (n *Nodes) GetNode(_ context.Context, s *wrapperspb.StringValue) (*node.Point, error)

func (n *Nodes) Latency(c context.Context, req *grpcnode.LatencyReq) (*grpcnode.LatencyResp, error)

func (n *Nodes) Now(_ context.Context, r *grpcnode.NowReq) (*node.Point, error)

func (o Nodes) PacketConn(host proxy.Address) (_ net.PacketConn, err error)

func (o Nodes) Point(udp bool) *node.Point

func (o Nodes) Save(p *node.Point, udp bool)

func (n *Nodes) SaveLinks(_ context.Context, l *grpcnode.SaveLinkReq) (*emptypb.Empty, error)

func (n *Nodes) SaveNode(c context.Context, p *node.Point) (*node.Point, error)

func (n *Nodes) UpdateLinks(c context.Context, req *grpcnode.LinkReq) (*emptypb.Empty, error)

func (n *Nodes) Use(c context.Context, s *grpcnode.UseReq) (*node.Point, error)

Path	Synopsis
parser
register