server

Documentation

Overview

Package server provides the main server and processing functionality for the load balancer provider

Index

• type Server
  • func (s *Server) ConfigureSubscribers() error
  • func (s *Server) GetLocation(subjs []gidx.PrefixedID) gidx.PrefixedID
  • func (s *Server) ListenChanges(messages <-chan events.Message[events.ChangeMessage])
  • func (s Server) LoadBalancerStatusUpdate(ctx context.Context, loadBalancerID gidx.PrefixedID, ...) error
  • func (s *Server) LocationCheck(i gidx.PrefixedID) bool
  • func (s *Server) Run(ctx context.Context) error

Types

type Server

type Server struct {
	APIClient             *lbapi.Client
	IPAMClient            *ipamclient.Client
	MetadataClient        *metadata.Client
	Context               context.Context
	Debug                 bool
	Echo                  *echox.Server
	IPBlock               string
	Locations             []string
	Logger                *zap.SugaredLogger
	Publisher             *events.Publisher
	EventsConnection      events.Connection
	ChangeTopics          []string
	MaxProcessMsgAttempts uint64

	ChangeChannels []<-chan events.Message[events.ChangeMessage]
}

Server holds options for server connectivity and settings

func (*Server) ConfigureSubscribers

func (s *Server) ConfigureSubscribers() error

func (*Server) GetLocation

func (s *Server) GetLocation(subjs []gidx.PrefixedID) gidx.PrefixedID

func (*Server) ListenChanges

func (s *Server) ListenChanges(messages <-chan events.Message[events.ChangeMessage])

func (Server) LoadBalancerStatusUpdate

func (s Server) LoadBalancerStatusUpdate(ctx context.Context, loadBalancerID gidx.PrefixedID, status *metastatus.LoadBalancerStatus) error

LoadBalancerStatusUpdate updates the state of a load balancer in the metadata service

func (*Server) LocationCheck

func (s *Server) LocationCheck(i gidx.PrefixedID) bool

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run will start the server queue connections and healthcheck endpoints