embedded

Documentation

Index

• Constants
• func NewEmbeddedEtcd(cfg etcdadpt.Config) etcdadpt.Client
• type EtcdEmbed
  • func (s *EtcdEmbed) Close()
  • func (s *EtcdEmbed) Compact(ctx context.Context, reserve int64) error
  • func (s *EtcdEmbed) Do(ctx context.Context, opts ...etcdadpt.OpOption) (*etcdadpt.Response, error)
  • func (s *EtcdEmbed) Err() <-chan error
  • func (s *EtcdEmbed) LeaseGrant(ctx context.Context, TTL int64) (int64, error)
  • func (s *EtcdEmbed) LeaseRenew(ctx context.Context, leaseID int64) (int64, error)
  • func (s *EtcdEmbed) LeaseRevoke(ctx context.Context, leaseID int64) error
  • func (s *EtcdEmbed) ListCluster(ctx context.Context) (etcdadpt.Clusters, error)
  • func (s *EtcdEmbed) Ready() <-chan struct{}
  • func (s *EtcdEmbed) Status(ctx context.Context) (*etcdadpt.StatusResponse, error)
  • func (s *EtcdEmbed) Txn(ctx context.Context, opts []etcdadpt.OpOptions) (*etcdadpt.Response, error)
  • func (s *EtcdEmbed) TxnWithCmp(ctx context.Context, success []etcdadpt.OpOptions, cmps []etcdadpt.CmpOptions, ...) (*etcdadpt.Response, error)
  • func (s *EtcdEmbed) Watch(ctx context.Context, opts ...etcdadpt.OpOption) (err error)
  • func (s *EtcdEmbed) WithTimeout(ctx context.Context) (context.Context, context.CancelFunc)

Constants

const DefaultDataDir = "data"

Functions

func NewEmbeddedEtcd

func NewEmbeddedEtcd(cfg etcdadpt.Config) etcdadpt.Client

Types

type EtcdEmbed

type EtcdEmbed struct {
	Cfg   etcdadpt.Config
	Embed *embed.Etcd
	// contains filtered or unexported fields
}

func (*EtcdEmbed) Close

func (s *EtcdEmbed) Close()

func (*EtcdEmbed) Compact

func (s *EtcdEmbed) Compact(ctx context.Context, reserve int64) error

func (*EtcdEmbed) Do

func (s *EtcdEmbed) Do(ctx context.Context, opts ...etcdadpt.OpOption) (*etcdadpt.Response, error)

func (*EtcdEmbed) Err

func (s *EtcdEmbed) Err() <-chan error

func (*EtcdEmbed) LeaseGrant

func (s *EtcdEmbed) LeaseGrant(ctx context.Context, TTL int64) (int64, error)

func (*EtcdEmbed) LeaseRenew

func (s *EtcdEmbed) LeaseRenew(ctx context.Context, leaseID int64) (int64, error)

func (*EtcdEmbed) LeaseRevoke

func (s *EtcdEmbed) LeaseRevoke(ctx context.Context, leaseID int64) error

func (*EtcdEmbed) ListCluster

func (s *EtcdEmbed) ListCluster(ctx context.Context) (etcdadpt.Clusters, error)

func (*EtcdEmbed) Ready

func (s *EtcdEmbed) Ready() <-chan struct{}

func (*EtcdEmbed) Status

func (s *EtcdEmbed) Status(ctx context.Context) (*etcdadpt.StatusResponse, error)

func (*EtcdEmbed) Txn

func (s *EtcdEmbed) Txn(ctx context.Context, opts []etcdadpt.OpOptions) (*etcdadpt.Response, error)

TODO EMBED支持KV().TxnBegin()->TxnID，可惜PROXY模式暂时不支持

func (*EtcdEmbed) TxnWithCmp

func (s *EtcdEmbed) TxnWithCmp(ctx context.Context, success []etcdadpt.OpOptions, cmps []etcdadpt.CmpOptions, fail []etcdadpt.OpOptions) (*etcdadpt.Response, error)

func (*EtcdEmbed) Watch

func (s *EtcdEmbed) Watch(ctx context.Context, opts ...etcdadpt.OpOption) (err error)

func (*EtcdEmbed) WithTimeout

func (s *EtcdEmbed) WithTimeout(ctx context.Context) (context.Context, context.CancelFunc)