etcd

Documentation

Index

• type EtcdClusterInfo
• type EtcdStore
  • func NewEtcdStore(addrs []string) (*EtcdStore, error)
  • func (s *EtcdStore) ClusterInfo() (EtcdClusterInfo, error)
  • func (s *EtcdStore) CreateApp(app *types.Application) error
  • func (s *EtcdStore) CreateCompose(cps *types.Compose) error
  • func (s *EtcdStore) CreateComposeNG(cmpApp *types.ComposeApp) error
  • func (s *EtcdStore) CreateTask(aid string, task *types.Task) error
  • func (s *EtcdStore) CreateVersion(aid string, version *types.Version) error
  • func (s *EtcdStore) DeleteApp(id string) error
  • func (s *EtcdStore) DeleteCompose(idOrName string) error
  • func (s *EtcdStore) DeleteComposeNG(idOrName string) error
  • func (s *EtcdStore) DeleteTask(id string) error
  • func (s *EtcdStore) DeleteVersion(aid, vid string) error
  • func (s *EtcdStore) GetApp(id string) (*types.Application, error)
  • func (s *EtcdStore) GetAppOpStatus(appId string) (string, error)
  • func (s *EtcdStore) GetCompose(idOrName string) (*types.Compose, error)
  • func (s *EtcdStore) GetComposeNG(idOrName string) (*types.ComposeApp, error)
  • func (s *EtcdStore) GetFrameworkId() (string, int64)
  • func (s *EtcdStore) GetTask(aid, tid string) (*types.Task, error)
  • func (s *EtcdStore) GetVersion(aid, vid string) (*types.Version, error)
  • func (s *EtcdStore) IsErrNotFound(err error) bool
  • func (s *EtcdStore) ListApps() ([]*types.Application, error)
  • func (s *EtcdStore) ListComposes() ([]*types.Compose, error)
  • func (s *EtcdStore) ListComposesNG() ([]*types.ComposeApp, error)
  • func (s *EtcdStore) ListTaskHistory(aid, sid string) []*types.Task
  • func (s *EtcdStore) ListTasks(id string) ([]*types.Task, error)
  • func (s *EtcdStore) ListVersions(aid string) ([]*types.Version, error)
  • func (s *EtcdStore) UpdateApp(app *types.Application) error
  • func (s *EtcdStore) UpdateCompose(cps *types.Compose) error
  • func (s *EtcdStore) UpdateComposeNG(cmpApp *types.ComposeApp) error
  • func (s *EtcdStore) UpdateFrameworkId(id string) error
  • func (s *EtcdStore) UpdateTask(aid string, task *types.Task) error
• type MemberWrapper

Types

type EtcdClusterInfo

type EtcdClusterInfo struct {
	Health  bool            `json:"health"`
	Members []MemberWrapper `json:"members"`
}

type EtcdStore

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

func NewEtcdStore

func NewEtcdStore(addrs []string) (*EtcdStore, error)

func (*EtcdStore) ClusterInfo

func (s *EtcdStore) ClusterInfo() (EtcdClusterInfo, error)

func (*EtcdStore) CreateApp

func (s *EtcdStore) CreateApp(app *types.Application) error

func (*EtcdStore) CreateCompose

func (s *EtcdStore) CreateCompose(cps *types.Compose) error

func (*EtcdStore) CreateComposeNG

func (s *EtcdStore) CreateComposeNG(cmpApp *types.ComposeApp) error

func (*EtcdStore) CreateTask

func (s *EtcdStore) CreateTask(aid string, task *types.Task) error

func (*EtcdStore) CreateVersion

func (s *EtcdStore) CreateVersion(aid string, version *types.Version) error

func (*EtcdStore) DeleteApp

func (s *EtcdStore) DeleteApp(id string) error

func (*EtcdStore) DeleteCompose

func (s *EtcdStore) DeleteCompose(idOrName string) error

func (*EtcdStore) DeleteComposeNG

func (s *EtcdStore) DeleteComposeNG(idOrName string) error

func (*EtcdStore) DeleteTask

func (s *EtcdStore) DeleteTask(id string) error

func (*EtcdStore) DeleteVersion

func (s *EtcdStore) DeleteVersion(aid, vid string) error

func (*EtcdStore) GetApp

func (s *EtcdStore) GetApp(id string) (*types.Application, error)

func (*EtcdStore) GetAppOpStatus

func (s *EtcdStore) GetAppOpStatus(appId string) (string, error)

func (*EtcdStore) GetCompose

func (s *EtcdStore) GetCompose(idOrName string) (*types.Compose, error)

func (*EtcdStore) GetComposeNG

func (s *EtcdStore) GetComposeNG(idOrName string) (*types.ComposeApp, error)

func (*EtcdStore) GetFrameworkId

func (s *EtcdStore) GetFrameworkId() (string, int64)

func (*EtcdStore) GetTask

func (s *EtcdStore) GetTask(aid, tid string) (*types.Task, error)

func (*EtcdStore) GetVersion

func (s *EtcdStore) GetVersion(aid, vid string) (*types.Version, error)

func (*EtcdStore) IsErrNotFound

func (s *EtcdStore) IsErrNotFound(err error) bool

func (*EtcdStore) ListApps

func (s *EtcdStore) ListApps() ([]*types.Application, error)

func (*EtcdStore) ListComposes

func (s *EtcdStore) ListComposes() ([]*types.Compose, error)

func (*EtcdStore) ListComposesNG

func (s *EtcdStore) ListComposesNG() ([]*types.ComposeApp, error)

func (*EtcdStore) ListTaskHistory

func (s *EtcdStore) ListTaskHistory(aid, sid string) []*types.Task

func (*EtcdStore) ListTasks

func (s *EtcdStore) ListTasks(id string) ([]*types.Task, error)

func (*EtcdStore) ListVersions

func (s *EtcdStore) ListVersions(aid string) ([]*types.Version, error)

func (*EtcdStore) UpdateApp

func (s *EtcdStore) UpdateApp(app *types.Application) error

func (*EtcdStore) UpdateCompose

func (s *EtcdStore) UpdateCompose(cps *types.Compose) error

func (*EtcdStore) UpdateComposeNG

func (s *EtcdStore) UpdateComposeNG(cmpApp *types.ComposeApp) error

func (*EtcdStore) UpdateFrameworkId

func (s *EtcdStore) UpdateFrameworkId(id string) error

func (*EtcdStore) UpdateTask

func (s *EtcdStore) UpdateTask(aid string, task *types.Task) error

type MemberWrapper

type MemberWrapper struct {
	etcd.Member
	Leader   bool   `json:"leader"`
	Health   bool   `json:"health"`
	EndPoint string `json:"endpoint"`
}