ingestserver

Documentation

Index

• func NewCommand(info app.ServerInfo) *app.Command
• func NewServer(conf config.Config, info app.ServerInfo, logger *Logger.Logger) (app.Server, error)
• type Server
  • func (s *Server) Close() error
  • func (s *Server) Err() <-chan error
  • func (s *Server) Open() error
• type Service

Functions

func NewCommand

func NewCommand(info app.ServerInfo) *app.Command

func NewServer

func NewServer(conf config.Config, info app.ServerInfo, logger *Logger.Logger) (app.Server, error)

Types

type Server

type Server struct {
	Listener net.Listener

	MetaClient *meta.Client
	TSDBStore  netstorage.Storage
	Logger     *Logger.Logger

	QueryExecutor     *query.Executor
	PointsWriter      *coordinator.PointsWriter
	SubscriberManager *coordinator.SubscriberManager

	RecordWriter *coordinator.RecordWriter
	// contains filtered or unexported fields
}

Server represents a container for the metadata and storage data and services. It is built using a Config and it manages the startup and shutdown of all services in the proper order.

func (*Server) Close

func (s *Server) Close() error

func (*Server) Err

func (s *Server) Err() <-chan error

func (*Server) Open

func (s *Server) Open() error

type Service

type Service interface {
	Open() error
	Close() error
}

Service represents a service attached to the server.