forwarder

Documentation

Overview

Package forwarder provides interpose endpoint implementation for ovs forwarder which provides kernel and smartnic endpoints

Index

• func NewKernelServer(ctx context.Context, tokenGenerator token.GeneratorFunc, tunnelIPCidr net.IP, ...) (endpoint.Endpoint, error)
• func NewSriovServer(ctx context.Context, tokenGenerator token.GeneratorFunc, tunnelIPCidr net.IP, ...) (endpoint.Endpoint, error)
• type Option
  • func WithAuthorizeMonitorConnectionServer(authorizeMonitorConnectionServer networkservice.MonitorConnectionServer) Option
  • func WithAuthorizeServer(authorizeServer networkservice.NetworkServiceServer) Option
  • func WithBridgeName(bridgeName string) Option
  • func WithClientURL(clientURL *url.URL) Option
  • func WithDialOptions(opts ...grpc.DialOption) Option
  • func WithDialTimeout(dialTimeout time.Duration) Option
  • func WithName(name string) Option
  • func WithResourcePoolClient(resourcePoolClient networkservice.NetworkServiceClient) Option
  • func WithResourcePoolServer(resourcePoolServer networkservice.NetworkServiceServer) Option
  • func WithVxlanOptions(opts ...vxlan.Option) Option

Functions

func NewKernelServer

func NewKernelServer(ctx context.Context, tokenGenerator token.GeneratorFunc, tunnelIPCidr net.IP,
	l2Connections map[string]*ovsutil.L2ConnectionPoint, options ...Option,
) (endpoint.Endpoint, error)

NewKernelServer - returns kernel implementation of the ovsconnectns network service

func NewSriovServer

func NewSriovServer(ctx context.Context, tokenGenerator token.GeneratorFunc, tunnelIPCidr net.IP,
	pciPool resourcepool.PCIPool, resourcePool resourcepool.ResourcePool, sriovConfig *config.Config,
	l2Connections map[string]*ovsutil.L2ConnectionPoint, options ...Option,
) (endpoint.Endpoint, error)

NewSriovServer - returns sriov implementation of the ovsconnectns network service

Types

type Option

type Option func(o *forwarderOptions)

Option is an option pattern for forwarder chain elements

func WithAuthorizeMonitorConnectionServer

func WithAuthorizeMonitorConnectionServer(authorizeMonitorConnectionServer networkservice.MonitorConnectionServer) Option

WithAuthorizeMonitorConnectionServer sets authorization server chain element

func WithAuthorizeServer

func WithAuthorizeServer(authorizeServer networkservice.NetworkServiceServer) Option

WithAuthorizeServer sets authorization server chain element

func WithBridgeName

func WithBridgeName(bridgeName string) Option

WithBridgeName sets bridge name

func WithClientURL

func WithClientURL(clientURL *url.URL) Option

WithClientURL sets clientURL.

func WithDialOptions

func WithDialOptions(opts ...grpc.DialOption) Option

WithDialOptions sets dial options

func WithDialTimeout

func WithDialTimeout(dialTimeout time.Duration) Option

WithDialTimeout sets dial timeout for the client

func WithName

func WithName(name string) Option

WithName sets forwarder name

func WithResourcePoolClient

func WithResourcePoolClient(resourcePoolClient networkservice.NetworkServiceClient) Option

WithResourcePoolClient sets resource pool client

func WithResourcePoolServer

func WithResourcePoolServer(resourcePoolServer networkservice.NetworkServiceServer) Option

WithResourcePoolServer sets resource pool server

func WithVxlanOptions

func WithVxlanOptions(opts ...vxlan.Option) Option

WithVxlanOptions sets vxlan option