Documentation ¶
Index ¶
- type AllocUpdater
- type BoltdbStore
- func (s *BoltdbStore) GetProjects() ([]*proto.Project, error)
- func (s *BoltdbStore) GetTaskState(allocID, taskName string) (*proto.ServiceState, *proto.ServiceState_Handle, error)
- func (s *BoltdbStore) GetTasks(allocID string) ([]string, error)
- func (s *BoltdbStore) PutProject(a *proto.Project) error
- func (s *BoltdbStore) PutTaskHandle(allocID string, taskName string, handle *proto.ServiceState_Handle) error
- func (s *BoltdbStore) PutTaskState(allocID string, taskName string, state *proto.ServiceState) error
- type Config
- type Notifier
- type Option
- type ProjectRunner
- type Server
- type Status
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AllocUpdater ¶
type AllocUpdater interface { }
type BoltdbStore ¶
type BoltdbStore struct {
// contains filtered or unexported fields
}
func NewBoltdbStore ¶
func NewBoltdbStore(path string) (*BoltdbStore, error)
func NewBoltdbStoreWithDB ¶
func NewBoltdbStoreWithDB(db *bolt.DB) (*BoltdbStore, error)
func (*BoltdbStore) GetProjects ¶
func (s *BoltdbStore) GetProjects() ([]*proto.Project, error)
func (*BoltdbStore) GetTaskState ¶
func (s *BoltdbStore) GetTaskState(allocID, taskName string) (*proto.ServiceState, *proto.ServiceState_Handle, error)
func (*BoltdbStore) PutProject ¶
func (s *BoltdbStore) PutProject(a *proto.Project) error
func (*BoltdbStore) PutTaskHandle ¶
func (s *BoltdbStore) PutTaskHandle(allocID string, taskName string, handle *proto.ServiceState_Handle) error
func (*BoltdbStore) PutTaskState ¶
func (s *BoltdbStore) PutTaskState(allocID string, taskName string, state *proto.ServiceState) error
type Config ¶
type Config struct { DbPath string Notifier Notifier Hooks []hooks.ServiceHookFactory }
func DefaultConfig ¶
func DefaultConfig() *Config
type Option ¶
type Option func(*Config)
func WithHooks ¶
func WithHooks(h ...hooks.ServiceHookFactory) Option
func WithNotifier ¶
type ProjectRunner ¶
type ProjectRunner struct {
// contains filtered or unexported fields
}
func (*ProjectRunner) Restore ¶
func (p *ProjectRunner) Restore() error
func (*ProjectRunner) Status ¶
func (r *ProjectRunner) Status() *Status
func (*ProjectRunner) UpdateProject ¶
func (r *ProjectRunner) UpdateProject(p *proto.Project)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.