run

Documentation

Index

• func NewCommand(info app.ServerInfo, enableGossip bool) *app.Command
• func NewHttpHandler(c *config.Store) *httpHandler
• func NewServer(c 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) GetStore() *storage.Storage
  • func (s *Server) Open() error
• type Service
  • func NewService(c *config.Store) *Service
  • func (s *Service) Close() error
  • func (s *Service) Open() error

Functions

func NewCommand

func NewCommand(info app.ServerInfo, enableGossip bool) *app.Command

func NewHttpHandler

func NewHttpHandler(c *config.Store) *httpHandler

newHandler returns a new instance of handler with routes.

func NewServer

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

NewServer returns a new instance of Server built from a config.

Types

type Server

type Server struct {
	Logger *Logger.Logger

	StoreService *Service
	// contains filtered or unexported fields
}

func (*Server) Close

func (s *Server) Close() error

Close shuts down the meta and data stores and all services.

func (*Server) Err

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

Err returns an error channel that multiplexes all out of band errors received from all services.

func (*Server) GetStore

func (s *Server) GetStore() *storage.Storage

func (*Server) Open

func (s *Server) Open() error

Open opens the meta and data store and all services.

type Service

type Service struct {
	Ln net.Listener
	// contains filtered or unexported fields
}

func NewService

func NewService(c *config.Store) *Service

NewService returns a new instance of Service.

func (*Service) Close

func (s *Service) Close() error

func (*Service) Open

func (s *Service) Open() error

Open starts the meta service