watcher

Documentation

Index

• type Config
• type WatcherI
  • func New(ctx context.Context, config *Config) (WatcherI, error)

Types

type Config

type Config struct {
	//etcd://ip:port,ip:port
	Target  string
	Timeout time.Duration
}

type WatcherI

type WatcherI interface {
	GetLocalIp() string
	Create(path string, data string) error
	Delete(path string) error

	Read(path string) (string, uint64, error)
	//return keys, index, error
	List(path string) ([]string, uint64, error)

	Update(path string, data []byte) error

	//cb should return afterIndex
	Watch(path string, cb func() (uint64, error)) error

	CreateEphemeral(path string, data []byte) error
	CreateEphemeralInOrder(path string, data []byte) error

	Close() error
}

func New

func New(ctx context.Context, config *Config) (WatcherI, error)