zk

Documentation

Index

• 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(id string) error
  • func (zk *ZKStore) DeleteTask(id string) error
  • func (zk *ZKStore) DeleteVersion(aid, vid string) error
  • func (zk *ZKStore) GetApp(id string) (*types.Application, error)
  • func (zk *ZKStore) GetAppOpStatus(appId string) (string, error)
  • func (zk *ZKStore) GetCompose(id string) (*types.Compose, error)
  • func (zk *ZKStore) GetFrameworkId() (string, int64)
  • func (zk *ZKStore) GetTask(aid, tid string) (*types.Task, error)
  • func (zk *ZKStore) GetVersion(aid, vid string) (*types.Version, error)
  • func (zs *ZKStore) IsErrNotFound(err error) bool
  • 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

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

func (*ZKStore) DeleteTask

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

func (*ZKStore) DeleteVersion

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

func (*ZKStore) GetApp

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

func (*ZKStore) GetAppOpStatus

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

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