zk

Documentation

Index

• Constants
• type ZKStore
  • func DB() *ZKStore
  • func NewZKStore(url *url.URL) (*ZKStore, error)
  • func (zk *ZKStore) CreateApp(app *types.Application) error
  • func (zk *ZKStore) CreateCompose(cps *types.Compose) error
  • func (zk *ZKStore) CreateTask(aid string, task *types.Task) error
  • func (zk *ZKStore) CreateVersion(aid string, version *types.Version) error
  • func (zk *ZKStore) DeleteApp(id string) error
  • func (zk *ZKStore) DeleteCompose(idOrName string) error
  • func (zk *ZKStore) DeleteTask(id string) error
  • func (zk *ZKStore) GetApp(id string) (*types.Application, error)
  • func (zk *ZKStore) GetCompose(idOrName string) (*types.Compose, error)
  • func (zk *ZKStore) GetFrameworkId() string
  • func (zk *ZKStore) GetLeader() (string, error)
  • func (zk *ZKStore) GetTask(aid, tid string) (*types.Task, error)
  • func (zk *ZKStore) GetVersion(aid, vid string) (*types.Version, error)
  • func (zk *ZKStore) ListApps() ([]*types.Application, error)
  • func (zk *ZKStore) ListComposes() ([]*types.Compose, error)
  • func (zk *ZKStore) ListTaskHistory(aid, sid string) []*types.Task
  • func (zk *ZKStore) ListTasks(id string) ([]*types.Task, error)
  • func (zk *ZKStore) ListVersions(aid string) ([]*types.Version, error)
  • func (zk *ZKStore) UpdateApp(app *types.Application) error
  • func (zk *ZKStore) UpdateCompose(cps *types.Compose) error
  • func (zk *ZKStore) UpdateFrameworkId(id string) error
  • func (zk *ZKStore) UpdateTask(aid string, task *types.Task) error

Constants

const LeaderElectionPath = "/leader-election" // TODO(nmg)

Types

type ZKStore

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

func DB

func DB() *ZKStore

func NewZKStore

func NewZKStore(url *url.URL) (*ZKStore, error)

func (*ZKStore) CreateApp

func (zk *ZKStore) CreateApp(app *types.Application) error

func (*ZKStore) CreateCompose

func (zk *ZKStore) CreateCompose(cps *types.Compose) error

func (*ZKStore) CreateTask

func (zk *ZKStore) CreateTask(aid string, task *types.Task) error

func (*ZKStore) CreateVersion

func (zk *ZKStore) CreateVersion(aid string, version *types.Version) error

As Nested Field of AppHolder, CreateVersion Require Transaction Lock

func (*ZKStore) DeleteApp

func (zk *ZKStore) DeleteApp(id string) error

func (*ZKStore) DeleteCompose

func (zk *ZKStore) DeleteCompose(idOrName string) error

func (*ZKStore) DeleteTask

func (zk *ZKStore) DeleteTask(id string) error

func (*ZKStore) GetApp

func (zk *ZKStore) GetApp(id string) (*types.Application, error)

func (*ZKStore) GetCompose

func (zk *ZKStore) GetCompose(idOrName string) (*types.Compose, error)

func (*ZKStore) GetFrameworkId

func (zk *ZKStore) GetFrameworkId() string

func (*ZKStore) GetLeader

func (zk *ZKStore) GetLeader() (string, error)

func (*ZKStore) GetTask

func (zk *ZKStore) GetTask(aid, tid string) (*types.Task, error)

func (*ZKStore) GetVersion

func (zk *ZKStore) GetVersion(aid, vid string) (*types.Version, error)

func (*ZKStore) ListApps

func (zk *ZKStore) ListApps() ([]*types.Application, error)

func (*ZKStore) ListComposes

func (zk *ZKStore) ListComposes() ([]*types.Compose, error)

func (*ZKStore) ListTaskHistory

func (zk *ZKStore) ListTaskHistory(aid, sid string) []*types.Task

func (*ZKStore) ListTasks

func (zk *ZKStore) ListTasks(id string) ([]*types.Task, error)

func (*ZKStore) ListVersions

func (zk *ZKStore) ListVersions(aid string) ([]*types.Version, error)

func (*ZKStore) UpdateApp

func (zk *ZKStore) UpdateApp(app *types.Application) error

All of AppHolder Write Ops Requires Transaction Lock

func (*ZKStore) UpdateCompose

func (zk *ZKStore) UpdateCompose(cps *types.Compose) error

func (*ZKStore) UpdateFrameworkId

func (zk *ZKStore) UpdateFrameworkId(id string) error

func (*ZKStore) UpdateTask

func (zk *ZKStore) UpdateTask(aid string, task *types.Task) error