driver

type DriverV2 interface {
	// init driver
	Init(serviceName string, opts ...Option)
	// get nodeID
	NodeID() string
	// get nodes
	GetNodes(ctx context.Context) (nodes []string, err error)

	// register node to remote server (like etcd/redis),
	// will create a goroutine to keep the connection.
	// And then continue for other work.
	Start(ctx context.Context) (err error)

	// stop the goroutine of keep connection.
	Stop(ctx context.Context) (err error)

	WithOption(opt Option) (err error)
}

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

type Option interface {
	Type() int
}

type RedisDriver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type RedisZSetDriver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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