etcdv3

Documentation

Index

• type EtcdV3
  • func NewEtcdV3Server(cfg *config.Config, cache cache.Cache, revisioner Revisioner) (EtcdV3, error)
• type Revisioner

Types

type EtcdV3

type EtcdV3 interface {
	// Serve accepts a listener and launches the ETCD v3 server.
	Serve(net.Listener) error
	// Shutdown closes the ETCD v3 server.
	Shutdown(context.Context) error
	// PushEvents accepts a bunch of events and converts them to ETCD events,
	// then sending to watch clients.
	PushEvents([]types.Event)
}

EtcdV3 abstracts the behaviors of the mimicking ETCD v3 server.

func NewEtcdV3Server

func NewEtcdV3Server(cfg *config.Config, cache cache.Cache, revisioner Revisioner) (EtcdV3, error)

NewEtcdV3Server creates the ETCD v3 server.

type Revisioner

type Revisioner interface {
	// Revision returns the current revision.
	Revision() int64
}

Revisioner defines how to get the current revision.