kernelforwarder

Documentation

Index

• func ClearInterfaceSetup(ifaceName string, conn *connection.Connection) (string, error)
• func SetupInterface(ifaceName string, conn *connection.Connection, isDst bool) (string, error)
• type KernelForwarder
  • func CreateKernelForwarder() *KernelForwarder
  • func (k *KernelForwarder) Close(ctx context.Context, crossConnect *crossconnect.CrossConnect) (*empty.Empty, error)
  • func (k *KernelForwarder) CreateForwarderServer(config *common.ForwarderConfig) forwarder.ForwarderServer
  • func (k *KernelForwarder) Init(common *common.ForwarderConfig) error
  • func (k *KernelForwarder) MonitorMechanisms(empty *empty.Empty, ...) error
  • func (k *KernelForwarder) Request(ctx context.Context, crossConnect *crossconnect.CrossConnect) (*crossconnect.CrossConnect, error)

Functions

func ClearInterfaceSetup

func ClearInterfaceSetup(ifaceName string, conn *connection.Connection) (string, error)

ClearInterfaceSetup - deletes interface setup

func SetupInterface

func SetupInterface(ifaceName string, conn *connection.Connection, isDst bool) (string, error)

SetupInterface - setup interface to namespace

Types

type KernelForwarder

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

KernelForwarder instance

func CreateKernelForwarder

func CreateKernelForwarder() *KernelForwarder

CreateKernelForwarder creates an instance of the KernelForwarder

func (*KernelForwarder) Close

func (k *KernelForwarder) Close(ctx context.Context, crossConnect *crossconnect.CrossConnect) (*empty.Empty, error)

Close handler for connections

func (*KernelForwarder) CreateForwarderServer

func (k *KernelForwarder) CreateForwarderServer(config *common.ForwarderConfig) forwarder.ForwarderServer

CreateForwarderServer creates an instance of ForwarderServer

func (*KernelForwarder) Init

func (k *KernelForwarder) Init(common *common.ForwarderConfig) error

Init initializes the Kernel forwarding plane

func (*KernelForwarder) MonitorMechanisms

func (k *KernelForwarder) MonitorMechanisms(empty *empty.Empty, updateSrv forwarder.MechanismsMonitor_MonitorMechanismsServer) error

MonitorMechanisms handler

func (*KernelForwarder) Request

func (k *KernelForwarder) Request(ctx context.Context, crossConnect *crossconnect.CrossConnect) (*crossconnect.CrossConnect, error)

Request handler for connections