etcd

README

etcd State Store adapter

Notes:

• This adapter expects the kustomization base to be present already, but otherwise only uses the filesystem by writing right before running kustomize build <instance dir>.

Documentation

Index

• func GetSessionAndMutex(clientV3 *clientv3.Client, key, caller string) (context.CancelFunc, *concurrency.Session, *concurrency.Mutex, error)
• type Engine
  • func (engine *Engine) Init() error
  • func (engine *Engine) NewDeleter(instance *pb.Instance, instancesDir string) state.Deleter
  • func (engine *Engine) NewGetter(options *pb.GetOptions, list *pb.InstanceList, instancesDir string) state.Getter
  • func (engine *Engine) NewTemplatesGetter(list *pb.InstanceList, templatesDir string) state.TemplatesGetter
  • func (engine *Engine) NewUpdater(instance *pb.Instance, instancesDir string) state.Updater

Functions

func GetSessionAndMutex

func GetSessionAndMutex(clientV3 *clientv3.Client, key, caller string) (context.CancelFunc, *concurrency.Session, *concurrency.Mutex, error)

GetSessionAndMutex gets an etcd lock

Types

type Engine

type Engine struct {
	WorkingDir      string
	EndpointsString string
}

Engine fulfills the StateStore interface

func (*Engine) Init

func (engine *Engine) Init() error

Init does setup

func (*Engine) NewDeleter

func (engine *Engine) NewDeleter(instance *pb.Instance, instancesDir string) state.Deleter

NewDeleter returns an initialized Deleter

func (*Engine) NewGetter

func (engine *Engine) NewGetter(options *pb.GetOptions, list *pb.InstanceList, instancesDir string) state.Getter

NewGetter returns an initialized Getter

func (*Engine) NewTemplatesGetter

func (engine *Engine) NewTemplatesGetter(list *pb.InstanceList, templatesDir string) state.TemplatesGetter

NewTemplatesGetter returns an initialized TemplatesGetter

func (*Engine) NewUpdater

func (engine *Engine) NewUpdater(instance *pb.Instance, instancesDir string) state.Updater

NewUpdater returns an initialized Updater