tunnel

Documentation

Index

• Constants
• 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

Constants

const (
	DestinationProtocolKey = "dst_protocol"
	DestinationIpKey       = "dst_ip"
	DestinationPortKey     = "dst_port"
	SourceAddrKey          = "source_addr"
)

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
	SendHealthEvent(pass bool) error
}

type HostingContext

type HostingContext interface {
	ServiceName() string
	ListenOptions() *ziti.ListenOptions
	Dial(options map[string]interface{}) (net.Conn, error)
	SupportHalfClose() bool
	GetHealthChecks() []health.CheckDefinition
	GetInitialHealthState() (ziti.Precedence, uint16)
	OnClose()
	SetCloseCallback(func())
}