server

Documentation

Index

• type Catalog
• type Config
  • func DefaultConfig() *Config
• type Server
  • func NewServer(logger hclog.Logger, config *Config) (*Server, error)
  • func (s *Server) Create(req *proto.ApplyRequest) (string, error)
  • func (s *Server) Pull(nodeId string, ws memdb.WatchSet) ([]*proto.Allocation, error)
  • func (s *Server) Stop()
  • func (s *Server) UpdateAlloc(alloc *proto.Allocation) error

Types

type Catalog

type Catalog interface {
	Build(prev []byte, req *proto.ApplyRequest) ([]byte, map[string]*proto.Task, error)
}

type Config

type Config struct {
	GrpcAddr     string
	PersistentDB *bolt.DB
}

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig returns a default configuration

type Server

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

func NewServer

func NewServer(logger hclog.Logger, config *Config) (*Server, error)

func (*Server) Create

func (s *Server) Create(req *proto.ApplyRequest) (string, error)

func (*Server) Pull

func (s *Server) Pull(nodeId string, ws memdb.WatchSet) ([]*proto.Allocation, error)

func (*Server) Stop

func (s *Server) Stop()

func (*Server) UpdateAlloc

func (s *Server) UpdateAlloc(alloc *proto.Allocation) error