etcd

package

v0.2.5 Latest Latest Go to latest Published: Aug 14, 2017 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dataman-cloud/swan

Links

Open Source Insights

Documentation ¶

Index ¶

type EtcdClusterInfo
type EtcdStore
- func NewEtcdStore(addrs []string) (*EtcdStore, error)
type MemberWrapper

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

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

func (*EtcdStore) GetCompose ¶

func (s *EtcdStore) GetCompose(idOrName string) (*types.Compose, 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 ¶ added in v0.2.2

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) 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) 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"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL