embededetcd

Documentation

Index

• type EtcdEmbed
  • func (s *EtcdEmbed) Close()
  • func (s *EtcdEmbed) Compact(ctx context.Context, reserve int64) error
  • func (s *EtcdEmbed) Do(ctx context.Context, opts ...registry.PluginOpOption) (*registry.PluginResponse, 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) PutNoOverride(ctx context.Context, opts ...registry.PluginOpOption) (bool, error)
  • func (s *EtcdEmbed) Ready() <-chan struct{}
  • func (s *EtcdEmbed) Txn(ctx context.Context, opts []registry.PluginOp) (*registry.PluginResponse, error)
  • func (s *EtcdEmbed) TxnWithCmp(ctx context.Context, success []registry.PluginOp, cmps []registry.CompareOp, ...) (*registry.PluginResponse, error)
  • func (s *EtcdEmbed) Watch(ctx context.Context, opts ...registry.PluginOpOption) (err error)

Types

type EtcdEmbed

type EtcdEmbed struct {
	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 ...registry.PluginOpOption) (*registry.PluginResponse, 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) PutNoOverride

func (s *EtcdEmbed) PutNoOverride(ctx context.Context, opts ...registry.PluginOpOption) (bool, error)

func (*EtcdEmbed) Ready

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

func (*EtcdEmbed) Txn

func (s *EtcdEmbed) Txn(ctx context.Context, opts []registry.PluginOp) (*registry.PluginResponse, error)

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

func (*EtcdEmbed) TxnWithCmp

func (s *EtcdEmbed) TxnWithCmp(ctx context.Context, success []registry.PluginOp, cmps []registry.CompareOp, fail []registry.PluginOp) (*registry.PluginResponse, error)

func (*EtcdEmbed) Watch

func (s *EtcdEmbed) Watch(ctx context.Context, opts ...registry.PluginOpOption) (err error)