netapp

Documentation

Index

• func AddRemoteTunnel(ctx context.Context, daemonConn net.Conn, entry *AppEntry) error
• func DelRemoteTunnel(ctx context.Context, daemonConn net.Conn, entry *AppEntry) error
• type AppEntry
  • func ListRemoteTunnel(ctx context.Context, daemonConn net.Conn) ([]*AppEntry, error)
  • func (p *AppEntry) Clone() *AppEntry
• type AppEntryRequest
• type AppEntryResponse
• type Context
  • func NewContext(IdleUDPTimeout time.Duration, xConfig *xconn.Config, EnableGRO bool) *Context
  • func (c *Context) Clone() *Context
  • func (tunnelContext *Context) Serve(ctx context.Context, srcURL, dstURL *url.URL) error
  • func (tunnelContext *Context) ServeDaemon(ctx context.Context, lis net.Listener, provider EntryProvider) error
• type EntryProvider
• type TunnelTrackerFunc

Functions

func AddRemoteTunnel

func AddRemoteTunnel(ctx context.Context, daemonConn net.Conn, entry *AppEntry) error

does not own `daemonConn`.

func DelRemoteTunnel

func DelRemoteTunnel(ctx context.Context, daemonConn net.Conn, entry *AppEntry) error

Types

type AppEntry

type AppEntry struct {
	SrcURL, DstURL *url.URL
	Temporary      bool
}

func ListRemoteTunnel

func ListRemoteTunnel(ctx context.Context, daemonConn net.Conn) ([]*AppEntry, error)

func (*AppEntry) Clone

func (p *AppEntry) Clone() *AppEntry

type AppEntryRequest

type AppEntryRequest struct {
	Action   string
	AppEntry *AppEntry
}

type AppEntryResponse

type AppEntryResponse struct {
	Entries []*AppEntry
}

type Context

type Context struct {
	Transport         *transport.Transport
	HTTPHandler       map[string]http.HandlerFunc
	TunnelDeviceTable map[string]*tuntable.PeerTable
	TunnelTracker     TunnelTrackerFunc

	// For Android library
	Device tun.Device
}

func NewContext

func NewContext(IdleUDPTimeout time.Duration, xConfig *xconn.Config, EnableGRO bool) *Context

func (*Context) Clone

func (c *Context) Clone() *Context

func (*Context) Serve

func (tunnelContext *Context) Serve(ctx context.Context, srcURL, dstURL *url.URL) error

func (*Context) ServeDaemon

func (tunnelContext *Context) ServeDaemon(ctx context.Context, lis net.Listener, provider EntryProvider) error

type EntryProvider

type EntryProvider interface {
	Load() ([]*AppEntry, error)
	Save([]*AppEntry) error
}

type TunnelTrackerFunc

type TunnelTrackerFunc func(SourceURL *url.URL, DestinationURLs []*url.URL) io.Closer