Versions in this module Expand all Collapse all v0 v0.1.0 Sep 27, 2022 Changes in this version + func NewHandler(opts HandlerOpts) (http.Handler, error) + type AuthFn func(http *http.Request) error + func AuthFnPKITLS(rootCAs []*x509.Certificate) (AuthFn, error) + func AuthFnSharedTLS(cert tls.Certificate) (AuthFn, error) + type Authenticator interface + Authenticate func(r *http.Request) (*Manager, error) + type Cluster interface + Get func() string + type ConfigClient struct + Event relay.EventServiceClient + Node admin.NodeServiceClient + Status relay.StatusServiceClient + type ConfigRegisterer struct + func (c *ConfigRegisterer) Register(peer *wrpc.Peer, m *Manager) error + type DefaultAuthenticator struct + AuthFn AuthFn + Context context.Context + Manager *Manager + func (d *DefaultAuthenticator) Authenticate(r *http.Request) (*Manager, error) + type DefaultCluster struct + func (d DefaultCluster) Get() string + type ErrAuth struct + HTTPStatus int + Message string + func (e ErrAuth) Error() string + type ErrConnClosed struct + Code int + func (e ErrConnClosed) Error() string + type Event struct + func (e Event) String() string + type EventHandler interface + OnEvent func(ctx context.Context, e Event) error + type EventStream interface + Name func() string + Register func(ctx context.Context, cluster Cluster, handler EventHandler) error + Unregister func(ctx context.Context, cluster Cluster) error + type EventType int + const ReconfigureEvent + type HandlerOpts struct + Authenticator Authenticator + BaseServices Registerer + Logger *zap.Logger + type Manager struct + Cluster Cluster + func NewManager(opts ManagerOpts) (*Manager, error) + func (m *Manager) AddEventStream(eventStream EventStream) error + func (m *Manager) AddPendingNode(node *Node) error + func (m *Manager) AddWebsocketNode(node *Node) + func (m *Manager) FindNode(remoteAddress string) *Node + func (m *Manager) ReadConfig() ManagerConfig + func (m *Manager) UpdateConfig(c ManagerConfig) + type ManagerConfig struct + DataPlaneRequisites []*grpcKongUtil.DataPlanePrerequisite + type ManagerOpts struct + Client ConfigClient + Cluster Cluster + Config ManagerConfig + Ctx context.Context + DPConfigLoader config.Loader + DPVersionCompatibility config.VersionCompatibility + Logger *zap.Logger + type NegotiationRegisterer struct + func NewNegotiationRegisterer(logger *zap.Logger) (*NegotiationRegisterer, error) + func (n *NegotiationRegisterer) AddService(serviceName, version, message string, register Registerer) error + func (n *NegotiationRegisterer) Register(peer *wrpc.Peer, m *Manager) error + type Node struct + Hostname string + ID string + Logger *zap.Logger + Version string + func NewNode(opts nodeOpts) (*Node, error) + func (n *Node) Close() error + func (n *Node) GetPluginList() ([]string, error) + func (n *Node) RemoteAddr() net.Addr + type NodeList struct + func (l *NodeList) Add(node *Node) error + func (l *NodeList) All() []*Node + func (l *NodeList) FindNode(remoteAddress string) *Node + func (l *NodeList) Remove(node *Node) error + type Payload struct + func NewPayload(opts PayloadOpts) (*Payload, error) + func (p *Payload) ChangesFor(hash, version string) (config.TrackedChanges, error) + func (p *Payload) Payload(_ context.Context, version string) (config.Content, error) + func (p *Payload) UpdateBinary(_ context.Context, c config.Content) error + type PayloadOpts struct + Logger *zap.Logger + VersionCompatibilityProcessor config.VersionCompatibility + type Registerer interface + Register func(peer *wrpc.Peer, m *Manager) error + type RelayEventStreamer struct + func NewRelayEventStreamer(opts RelayEventStreamerOpts) (*RelayEventStreamer, error) + func (r *RelayEventStreamer) Name() string + func (r *RelayEventStreamer) Register(ctx context.Context, cluster Cluster, handler EventHandler) error + func (r *RelayEventStreamer) Unregister(ctx context.Context, _ Cluster) error + type RelayEventStreamerOpts struct + EventServiceClient relay.EventServiceClient + Logger *zap.Logger