server

package

v1.0.1 Latest Latest Go to latest Published: Feb 28, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func ContextWithSignal(ctx context.Context) context.Context

ContextWithSignal creates a context canceled when SIGINT or SIGTERM are notified.

type DynamicFunc func(*dynamic.Config, chan<- interface{})

type Message struct {
	Name    string
	Content *dynamic.Config
}

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

func NewServer(ctx context.Context, cf *config.Config, handler http.Handler,
	watcher *Watcher) *Server

NewServer returns an initialized Server.

func (s *Server) Close()

Close destroys the server.

func (s *Server) Start()

Start Starts the server.

func (s *Server) Stop()

Stop stops the server.

func (s *Server) Wait()

Wait blocks until the server shutdown.

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

var GlobalWatcher *Watcher

func NewWatcher(ctx context.Context, pool *safe.Pool) *Watcher

func (w *Watcher) AddListener(name string, function DynamicFunc)

func (w *Watcher) Entry() chan<- *Message

func (w *Watcher) Out() <-chan interface{}

func (w *Watcher) Start()

func (w *Watcher) Stop()