server

package

v0.3.1 Latest Latest Go to latest Published: Feb 8, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrAlreadyStarted = errors.New("server already started")
)

This section is empty.

type Option interface {
	// contains filtered or unexported methods
}

func WithAuthBearer(token string) Option

WithAuthBearer configures the server to validate connections based on the provided token

func WithDiskStorage(path string) Option

WithDiskStorage enables the persistence of the internal state of the server to disk. Path contains the root folder where the data will be stored

func WithLogger(l logging.Logger) Option

WithLogger changes the internal logger. In case of not setting it, the server does not output logs

func WithReconciliationPeriod(p time.Duration) Option

WithReconciliationPeriod sets how often the server will try to reconcile its configuration with the connected samplers.

func WithTLS(certFile, keyFile string) Option

WithTLS enables TLS communication encryption

type Server struct {
	protos.UnimplementedControlPlaneServer
	// contains filtered or unexported fields
}

func New(uid string, serverOptions ...Option) (*Server, error)

func (s *Server) Addr() net.Addr

func (s *Server) ClientConn(stream protos.ControlPlane_ClientConnServer) error

func (s *Server) Events() chan event.Event

func (s *Server) GetSamplers(resourceName, samplerName string) ([]*control.Sampler, error)

func (s *Server) SamplerConn(stream protos.ControlPlane_SamplerConnServer) error

func (s *Server) Start(listenAddr string) error

func (s *Server) Stop(_ time.Duration) error