server

package
v1.0.1-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 5, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultHttpConnectionManager 

func DefaultHttpConnectionManager() *model.HttpConnectionManagerConfig

DefaultHttpConnectionManager

func GetTraceDriverManager 

func GetTraceDriverManager() *tracing.TraceDriverManager

func Start 

func Start(bs *model.Bootstrap)

Types

type AdapterManager 

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

func CreateDefaultAdapterManager 

func CreateDefaultAdapterManager(server *Server, bs *model.Bootstrap) *AdapterManager

func (*AdapterManager) Start 

func (am *AdapterManager) Start()

func (*AdapterManager) Stop 

func (am *AdapterManager) Stop()

type ApiConfigListener 

type ApiConfigListener interface {
	OnAddAPI(r router.API) error
	OnRemoveAPI(r router.API) error
	OnDeleteRouter(r config.Resource) error
}

type ApiConfigManager 

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

ApiConfigManager similar to RouterManager

func CreateDefaultApiConfigManager 

func CreateDefaultApiConfigManager(server *Server, bs *model.Bootstrap) *ApiConfigManager

func GetApiConfigManager 

func GetApiConfigManager() *ApiConfigManager

func (*ApiConfigManager) AddAPI 

func (acm *ApiConfigManager) AddAPI(adapterID string, r router.API) error

func (*ApiConfigManager) AddApiConfigListener 

func (acm *ApiConfigManager) AddApiConfigListener(adapterID string, l ApiConfigListener)

func (*ApiConfigManager) DeleteRouter 

func (acm *ApiConfigManager) DeleteRouter(adapterID string, r config.Resource) error

func (*ApiConfigManager) RemoveAPI 

func (acm *ApiConfigManager) RemoveAPI(adapterID string, r router.API) error

type ClusterManager 

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

func CreateDefaultClusterManager 

func CreateDefaultClusterManager(bs *model.Bootstrap) *ClusterManager

func GetClusterManager 

func GetClusterManager() *ClusterManager

func (*ClusterManager) AddCluster 

func (cm *ClusterManager) AddCluster(c *model.ClusterConfig)

func (*ClusterManager) CloneStore 

func (cm *ClusterManager) CloneStore() (*ClusterStore, error)

func (*ClusterManager) CloneXdsControlStore 

func (cm *ClusterManager) CloneXdsControlStore() (controls.ClusterStore, error)

CloneXdsControlStore clone cluster store for xds

func (*ClusterManager) CompareAndSetStore 

func (cm *ClusterManager) CompareAndSetStore(store *ClusterStore) bool

func (*ClusterManager) DeleteEndpoint 

func (cm *ClusterManager) DeleteEndpoint(clusterName string, endpointID string)

func (*ClusterManager) HasCluster 

func (cm *ClusterManager) HasCluster(clusterName string) bool

func (*ClusterManager) NewStore 

func (cm *ClusterManager) NewStore(version int32) *ClusterStore

func (*ClusterManager) PickEndpoint 

func (cm *ClusterManager) PickEndpoint(clusterName string, policy model.LbPolicy) *model.Endpoint

func (*ClusterManager) RemoveCluster 

func (cm *ClusterManager) RemoveCluster(namesToDel []string)

func (*ClusterManager) SetEndpoint 

func (cm *ClusterManager) SetEndpoint(clusterName string, endpoint *model.Endpoint)

func (*ClusterManager) UpdateCluster 

func (cm *ClusterManager) UpdateCluster(new *model.ClusterConfig)

type ClusterStore 

type ClusterStore struct {
	Config  []*model.ClusterConfig `yaml:"config" json:"config"`
	Version int32                  `yaml:"version" json:"version"`
	// contains filtered or unexported fields
}

ClusterStore store for cluster array

func (*ClusterStore) AddCluster 

func (s *ClusterStore) AddCluster(c *model.ClusterConfig)

func (*ClusterStore) DeleteEndpoint 

func (s *ClusterStore) DeleteEndpoint(clusterName string, endpointID string)

func (*ClusterStore) HasCluster 

func (s *ClusterStore) HasCluster(clusterName string) bool

func (*ClusterStore) IncreaseVersion 

func (s *ClusterStore) IncreaseVersion()

func (*ClusterStore) SetEndpoint 

func (s *ClusterStore) SetEndpoint(clusterName string, endpoint *model.Endpoint)

func (*ClusterStore) UpdateCluster 

func (s *ClusterStore) UpdateCluster(new *model.ClusterConfig)

type DynamicResourceManager 

type DynamicResourceManager interface {
	GetLds() *model.ApiConfigSource
	GetNode() *model.Node
	GetCds() *model.ApiConfigSource
}

DynamicResourceManager help to management the dynamic resource

func GetDynamicResourceManager 

func GetDynamicResourceManager() DynamicResourceManager

type DynamicResourceManagerImpl 

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

func (DynamicResourceManagerImpl) GetCds 

func (d DynamicResourceManagerImpl) GetCds() *model.ApiConfigSource

func (DynamicResourceManagerImpl) GetLds 

func (d DynamicResourceManagerImpl) GetLds() *model.ApiConfigSource

func (DynamicResourceManagerImpl) GetNode 

func (d DynamicResourceManagerImpl) GetNode() *model.Node

type ListenerManager 

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

ListenerManager the listener manager

func CreateDefaultListenerManager 

func CreateDefaultListenerManager(bs *model.Bootstrap) *ListenerManager

CreateDefaultListenerManager create listener manager from config

func (*ListenerManager) AddListener 

func (lm *ListenerManager) AddListener(lsConf *model.Listener) error

func (*ListenerManager) CloneXdsControlListener 

func (lm *ListenerManager) CloneXdsControlListener() ([]*model.Listener, error)

func (*ListenerManager) GetListenerService 

func (lm *ListenerManager) GetListenerService(name string) listener.ListenerService

func (*ListenerManager) HasListener 

func (lm *ListenerManager) HasListener(name string) bool

func (*ListenerManager) RemoveListener 

func (lm *ListenerManager) RemoveListener(names []string)

func (*ListenerManager) StartListen 

func (lm *ListenerManager) StartListen()

func (*ListenerManager) UpdateListener 

func (lm *ListenerManager) UpdateListener(m *model.Listener) error

type RouterListener 

type RouterListener interface {
	OnAddRouter(r *model.Router)
	OnDeleteRouter(r *model.Router)
}

type RouterManager 

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

func CreateDefaultRouterManager 

func CreateDefaultRouterManager(server *Server, bs *model.Bootstrap) *RouterManager

func GetRouterManager 

func GetRouterManager() *RouterManager

func (*RouterManager) AddRouter 

func (rm *RouterManager) AddRouter(r *model.Router)

func (*RouterManager) AddRouterListener 

func (rm *RouterManager) AddRouterListener(l RouterListener)

func (*RouterManager) DeleteRouter 

func (rm *RouterManager) DeleteRouter(r *model.Router)

type Server 

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

PX is Pixiu start struct

func GetServer 

func GetServer() *Server

func NewServer 

func NewServer() *Server

NewServer create server

func (*Server) GetApiConfigManager 

func (s *Server) GetApiConfigManager() *ApiConfigManager

func (*Server) GetClusterManager 

func (s *Server) GetClusterManager() *ClusterManager

func (*Server) GetDynamicResourceManager 

func (s *Server) GetDynamicResourceManager() DynamicResourceManager

func (*Server) GetListenerManager 

func (s *Server) GetListenerManager() *ListenerManager

func (*Server) GetRouterManager 

func (s *Server) GetRouterManager() *RouterManager

func (*Server) GetTraceDriverManager 

func (s *Server) GetTraceDriverManager() *tracing.TraceDriverManager

func (*Server) Start 

func (s *Server) Start()

Start server start

Source Files

View all Source files

Directories

Path Synopsis
mocks

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.