embededetcd

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)