v2

Documentation

Index

• type Server
  • func NewXNetConfigServer(ctx context.Context, cfg configurator.Configurator, ...) *Server
  • func (s *Server) BroadcastListener(stopCh <-chan struct{})
  • func (s *Server) Start() error

Types

type Server

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

func NewXNetConfigServer

func NewXNetConfigServer(ctx context.Context, cfg configurator.Configurator, xnetworkController xnetwork.Controller, kubecontroller k8s.Controller, msgBroker *messaging.Broker) *Server

NewXNetConfigServer creates a new xnetwork config Service server

func (*Server) BroadcastListener

func (s *Server) BroadcastListener(stopCh <-chan struct{})

BroadcastListener listens for broadcast messages from the message broker

func (*Server) Start

func (s *Server) Start() error