tunnel

Documentation

Index

• func AppDataToMap(appData []byte) (map[string]interface{}, error)
• func DialAndRun(provider FabricProvider, service string, clientConn net.Conn, halfClose bool)
• func Run(zitiConn net.Conn, clientConn net.Conn, halfClose bool)
• type FabricProvider
  • func NewContextProvider(context ziti.Context) FabricProvider
• type HostControl
• type HostingContext

Functions

func AppDataToMap

func AppDataToMap(appData []byte) (map[string]interface{}, error)

func DialAndRun

func DialAndRun(provider FabricProvider, service string, clientConn net.Conn, halfClose bool)

func Run

func Run(zitiConn net.Conn, clientConn net.Conn, halfClose bool)

Types

type FabricProvider

type FabricProvider interface {
	PrepForUse(serviceId string)
	GetCurrentIdentity() (*edge.CurrentIdentity, error)
	TunnelService(conn net.Conn, service string, halfClose bool) error
	HostService(hostCtx HostingContext) (HostControl, error)
}

func NewContextProvider

func NewContextProvider(context ziti.Context) FabricProvider

type HostControl

type HostControl interface {
	io.Closer
	UpdateCost(cost uint16) error
	UpdatePrecedence(precedence edge.Precedence) error
	UpdateCostAndPrecedence(cost uint16, precedence edge.Precedence) error
}

type HostingContext

type HostingContext interface {
	ServiceName() string
	ListenOptions() *ziti.ListenOptions
	Dial(options map[string]interface{}) (net.Conn, error)
	SupportHalfClose() bool
	OnClose()
}