zk

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(id string) error

func (*ZKStore) DeleteTask ¶

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

func (*ZKStore) DeleteVersion ¶ added in v0.2.1

func (zk *ZKStore) DeleteVersion(aid, vid string) error

func (*ZKStore) GetApp ¶

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

func (*ZKStore) GetAppOpStatus ¶ added in v0.2.2

func (zk *ZKStore) GetAppOpStatus(appId string) (string, error)

func (*ZKStore) GetCompose ¶

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

func (*ZKStore) GetFrameworkId ¶

func (zk *ZKStore) GetFrameworkId() (string, int64)

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) IsErrNotFound ¶ added in v0.2.2

func (zs *ZKStore) IsErrNotFound(err error) bool

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