etcddriver

Documentation

Index

• type EtcdDriver
  • func NewDriver(cli *clientv3.Client) *EtcdDriver
  • func (e *EtcdDriver) GetNodes(ctx context.Context) (nodes []string, err error)
  • func (e *EtcdDriver) Init(serverName string, opts ...commons.Option)
  • func (e *EtcdDriver) NodeID() string
  • func (e *EtcdDriver) Start(ctx context.Context) (err error)
  • func (e *EtcdDriver) Stop(ctx context.Context) (err error)
  • func (e *EtcdDriver) WithOption(opt commons.Option) (err error)

Types

type EtcdDriver

type EtcdDriver struct {
	// contains filtered or unexported fields
}

func NewDriver

func NewDriver(cli *clientv3.Client) *EtcdDriver

NewEtcdDriver

func (*EtcdDriver) GetNodes

func (e *EtcdDriver) GetNodes(ctx context.Context) (nodes []string, err error)

func (*EtcdDriver) Init

func (e *EtcdDriver) Init(serverName string, opts ...commons.Option)

func (*EtcdDriver) NodeID

func (e *EtcdDriver) NodeID() string

func (*EtcdDriver) Start

func (e *EtcdDriver) Start(ctx context.Context) (err error)

func (*EtcdDriver) Stop

func (e *EtcdDriver) Stop(ctx context.Context) (err error)

func (*EtcdDriver) WithOption

func (e *EtcdDriver) WithOption(opt commons.Option) (err error)