loadbalancer

Documentation

Index

• Constants
• type Backend
• type BackendStatus
  • func (b BackendStatus) String() string
• type ConnectionState
  • func (c ConnectionState) String() string
• type ConntrackEntry
• type LbBackendManager
  • func New(vip netip.Addr, upstreamIface string, entry *ebpf.Program, ...) (*LbBackendManager, error)
  • func (l *LbBackendManager) Delete(id uint32) error
  • func (l *LbBackendManager) DeleteAll() error
  • func (l *LbBackendManager) Drain(id uint32) error
  • func (l *LbBackendManager) Get() ([]Backend, error)
  • func (l *LbBackendManager) GetConntrackEntries() ([]ConntrackEntry, error)
  • func (l *LbBackendManager) Run(ctx context.Context) error
  • func (l *LbBackendManager) Set(backend *Backend) error
• type Upstream

Constants

const (
	ConnectionStateNotTcp      = ConnectionState(0)
	ConnectionStateOpening     = ConnectionState(1)
	ConnectionStateEstablished = ConnectionState(2)
	ConnectionStateClosing     = ConnectionState(3)
	ConnectionStateClosed      = ConnectionState(4)
)

Types

type Backend

type Backend struct {
	Id          uint32
	Name        string
	Address     netip.Addr
	MacAddress  net.HardwareAddr
	Iface       netlink.Link
	Status      BackendStatus
	HealthCheck string
	// contains filtered or unexported fields
}

type BackendStatus

type BackendStatus uint32

const (
	BackendStatusAvailable  BackendStatus = BackendStatus(0)
	BackenStatusUnavailable BackendStatus = BackendStatus(1)
)

func (BackendStatus) String

func (b BackendStatus) String() string

type ConnectionState

type ConnectionState uint8

func (ConnectionState) String

func (c ConnectionState) String() string

type ConntrackEntry

type ConntrackEntry struct {
	SrcAddr   netip.Addr
	DstAddr   netip.Addr
	SrcPort   uint32
	DstPort   uint32
	Protocol  protocols.TransportProtocol
	State     ConnectionState
	Timestamp time.Time
	BackendId uint32
	Counter   uint64
}

type LbBackendManager

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

func New

func New(vip netip.Addr, upstreamIface string, entry *ebpf.Program, redirectMap, backendInfoMap, backendIfindexMap, upstreamMap *ebpf.Map, conntrack, rrTableMap *ebpf.Map, gcEnabled bool, gcTime time.Duration) (*LbBackendManager, error)

func (*LbBackendManager) Delete

func (l *LbBackendManager) Delete(id uint32) error

ロードバランサーのバックエンドを削除します。

func (*LbBackendManager) DeleteAll

func (l *LbBackendManager) DeleteAll() error

func (*LbBackendManager) Drain

func (l *LbBackendManager) Drain(id uint32) error

ロードバランサーのバックエンドを drain します。 バックエンド削除の前準備のための処理です。 既存のコネクションを処理し続けたまま、新規のコネクションを受け付けないようにします。

func (*LbBackendManager) Get

func (l *LbBackendManager) Get() ([]Backend, error)

ロードバランサーに紐付けられているバックエンドのリストを取得します。

func (*LbBackendManager) GetConntrackEntries

func (l *LbBackendManager) GetConntrackEntries() ([]ConntrackEntry, error)

func (*LbBackendManager) Run

func (l *LbBackendManager) Run(ctx context.Context) error

func (*LbBackendManager) Set

func (l *LbBackendManager) Set(backend *Backend) error

ロードバランサーのバックエンドを追加します。

type Upstream

type Upstream struct {
	IpAddr  netip.Addr
	Index   uint32
	MacAddr net.HardwareAddr
}