etcd

Documentation

Index

• Constants
• type Actions
  • func (a *Actions) List(ctx context.Context, extras map[string]string) (error, *cPb.ListResp)
  • func (a *Actions) Mutate(ctx context.Context, req *cPb.MutateReq) (error, *cPb.MutateResp)
  • func (a *Actions) StatusUpdate(ctx context.Context, key, newStatus string) error
• type Configs
  • func (c *Configs) List(ctx context.Context, extras map[string]string) (error, *cPb.ListResp)
  • func (c *Configs) Mutate(ctx context.Context, req *cPb.MutateReq) (error, *cPb.MutateResp)
  • func (c *Configs) StatusUpdate(ctx context.Context, key, newStatus string) error
• type DB
  • func New(conf *config.Config, timeout time.Duration) (*DB, error)
  • func (db *DB) Actions() storage.Actions
  • func (db *DB) Close()
  • func (db *DB) Configs() storage.Configs
  • func (db *DB) Init()
  • func (db *DB) Reconcile() storage.Reconcile
  • func (db *DB) Secrets() storage.Secrets
• type Reconcile
  • func (r *Reconcile) Start(ctx context.Context, address string)
• type Secrets
  • func (s *Secrets) List(ctx context.Context, extras map[string]string) (error, *cPb.ListResp)
  • func (s *Secrets) Mutate(ctx context.Context, req *cPb.MutateReq) (error, *cPb.MutateResp)
  • func (s *Secrets) StatusUpdate(ctx context.Context, key, newStatus string) error

Constants

const (
	Tombstone = "!!Tombstone"
)

Types

type Actions

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

func (*Actions) List

func (a *Actions) List(ctx context.Context, extras map[string]string) (error, *cPb.ListResp)

func (*Actions) Mutate

func (a *Actions) Mutate(ctx context.Context, req *cPb.MutateReq) (error, *cPb.MutateResp)

func (*Actions) StatusUpdate

func (a *Actions) StatusUpdate(ctx context.Context, key, newStatus string) error

type Configs

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

func (*Configs) List

func (c *Configs) List(ctx context.Context, extras map[string]string) (error, *cPb.ListResp)

func (*Configs) Mutate

func (c *Configs) Mutate(ctx context.Context, req *cPb.MutateReq) (error, *cPb.MutateResp)

func (*Configs) StatusUpdate

func (c *Configs) StatusUpdate(ctx context.Context, key, newStatus string) error

type DB

type DB struct {
	Kv     clientv3.KV
	Client *clientv3.Client

	Gravity string
	Apollo  string
	// contains filtered or unexported fields
}

func New

func New(conf *config.Config, timeout time.Duration) (*DB, error)

func (*DB) Actions

func (db *DB) Actions() storage.Actions

func (*DB) Close

func (db *DB) Close()

func (*DB) Configs

func (db *DB) Configs() storage.Configs

func (*DB) Init

func (db *DB) Init()

func (*DB) Reconcile

func (db *DB) Reconcile() storage.Reconcile

func (*DB) Secrets

func (db *DB) Secrets() storage.Secrets

type Reconcile

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

func (*Reconcile) Start

func (r *Reconcile) Start(ctx context.Context, address string)

type Secrets

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

func (*Secrets) List

func (s *Secrets) List(ctx context.Context, extras map[string]string) (error, *cPb.ListResp)

func (*Secrets) Mutate

func (s *Secrets) Mutate(ctx context.Context, req *cPb.MutateReq) (error, *cPb.MutateResp)

func (*Secrets) StatusUpdate

func (s *Secrets) StatusUpdate(ctx context.Context, key, newStatus string) error