composer

README

Composer

Documentation

Index

• type AllocUpdater
• type BoltdbStore
  • func NewBoltdbStore(path string) (*BoltdbStore, error)
  • func NewBoltdbStoreWithDB(db *bolt.DB) (*BoltdbStore, error)
  • 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
  • func DefaultConfig() *Config
• type Notifier
• type Option
  • func WithHooks(h ...hooks.ServiceHookFactory) Option
  • func WithNotifier(n Notifier) Option
• type ProjectRunner
  • func (p *ProjectRunner) Restore() error
  • func (r *ProjectRunner) Status() *Status
  • func (r *ProjectRunner) UpdateProject(p *proto.Project)
• type Server
  • func NewServer(configOpts ...Option) (*Server, error)
  • func (r *Server) GetProjectStatus(name string) (*Status, error)
  • func (r *Server) Up(ctx context.Context, req *proto.Project) (*proto.Project_Ref, error)
• type Status

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) GetTasks

func (s *BoltdbStore) GetTasks(allocID string) ([]string, 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 Notifier

type Notifier interface {
	Notify(event *proto.Event)
}

type Option

type Option func(*Config)

func WithHooks

func WithHooks(h ...hooks.ServiceHookFactory) Option

func WithNotifier

func WithNotifier(n Notifier) Option

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)

type Server

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

func NewServer

func NewServer(configOpts ...Option) (*Server, error)

func (*Server) GetProjectStatus

func (r *Server) GetProjectStatus(name string) (*Status, error)

func (*Server) Up

func (r *Server) Up(ctx context.Context, req *proto.Project) (*proto.Project_Ref, error)

type Status

type Status struct {
	Complete bool
	State    map[string]*proto.ServiceState
}