net

Documentation

Index

• type Config
• type DialerSource
  • func NewDialerSource(c Config) (*DialerSource, error)
  • func (s *DialerSource) GrpcContextDialer() func(context.Context, string) (net.Conn, error)
  • func (s *DialerSource) Update(c Config) error
• type LogEventHandler
  • func NewLogEventHandler(logger *zap.Logger) LogEventHandler
  • func (l LogEventHandler) DialPerformed(sourceIP net.Addr, _, address string, err error)
• type Subnet

Types

type Config

type Config struct {
	Enabled       bool
	Subnets       []Subnet
	Balancer      string
	Restrict      bool
	FallbackDelay time.Duration
	EventHandler  multinet.EventHandler
}

type DialerSource

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

func NewDialerSource

func NewDialerSource(c Config) (*DialerSource, error)

func (*DialerSource) GrpcContextDialer

func (s *DialerSource) GrpcContextDialer() func(context.Context, string) (net.Conn, error)

GrpcContextDialer returns grpc.WithContextDialer func. Returns nil if multinet disabled.

func (*DialerSource) Update

func (s *DialerSource) Update(c Config) error

type LogEventHandler

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

func NewLogEventHandler

func NewLogEventHandler(logger *zap.Logger) LogEventHandler

func (LogEventHandler) DialPerformed

func (l LogEventHandler) DialPerformed(sourceIP net.Addr, _, address string, err error)

type Subnet

type Subnet struct {
	Prefix    string
	SourceIPs []string
}