etcd

Documentation

Index

• type DB
  • func New(conf *model.Config, timeout time.Duration) (*DB, error)
  • func (db *DB) Get(ctx context.Context, req *sPb.GetReq) (*sPb.GetResp, error)
  • func (db *DB) List(ctx context.Context, req *sPb.ListReq) (*sPb.ListResp, error)
  • func (db *DB) StartCollector(ctx context.Context)

Types

type DB

type DB struct {
	Kv     clientv3.KV
	Client *clientv3.Client
	// contains filtered or unexported fields
}

func New

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

func (*DB) Get

func (db *DB) Get(ctx context.Context, req *sPb.GetReq) (*sPb.GetResp, error)

func (*DB) List

func (db *DB) List(ctx context.Context, req *sPb.ListReq) (*sPb.ListResp, error)

func (*DB) StartCollector

func (db *DB) StartCollector(ctx context.Context)