forwarder

Documentation

Overview

Package forwarder provides an endpoint implementing xconnectns

Index

• func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, vppConn Connection, ...) endpoint.Endpoint
• type Connection
• type Option
  • func WithAuthorizeMonitorConnectionServer(authorizeMonitorConnectionServer networkservice.MonitorConnectionServer) Option
  • func WithAuthorizeServer(authorizeServer networkservice.NetworkServiceServer) Option
  • func WithCleanupOptions(opts ...cleanup.Option) Option
  • func WithClientAdditionalFunctionality(additionalFunctionality ...networkservice.NetworkServiceClient) Option
  • func WithClientURL(clientURL *url.URL) Option
  • func WithDialOptions(opts ...grpc.DialOption) Option
  • func WithDialTimeout(dialTimeout time.Duration) Option
  • func WithMechanismPriority(priorityList []string) Option
  • func WithName(name string) Option
  • func WithStatsOptions(opts ...stats.Option) Option
  • func WithVlanDomain2Device(domain2Device map[string]string) Option
  • func WithVxlanOptions(opts ...vxlan.Option) Option

Functions

func NewServer

func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, vppConn Connection, tunnelIP net.IP, options ...Option) endpoint.Endpoint

NewServer - returns an implementation of the xconnectns network service

Types

type Connection

type Connection interface {
	api.Connection
	api.ChannelProvider
}

Connection aggregates the api.Connection and api.ChannelProvider interfaces

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 WithCleanupOptions

func WithCleanupOptions(opts ...cleanup.Option) Option

WithCleanupOptions sets cleanup options

func WithClientAdditionalFunctionality

func WithClientAdditionalFunctionality(additionalFunctionality ...networkservice.NetworkServiceClient) Option

WithClientAdditionalFunctionality sets client additional functionality

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 WithMechanismPriority

func WithMechanismPriority(priorityList []string) Option

WithMechanismPriority sets mechanismpriority option

func WithName

func WithName(name string) Option

WithName - set a forwarder name

func WithStatsOptions

func WithStatsOptions(opts ...stats.Option) Option

WithStatsOptions sets stats options

func WithVlanDomain2Device

func WithVlanDomain2Device(domain2Device map[string]string) Option

WithVlanDomain2Device sets vlan option

func WithVxlanOptions

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

WithVxlanOptions sets vxlan options