etcdv3

Documentation

Index

• Constants
• type Mutex
  • func (m *Mutex) Lock() error
  • func (m *Mutex) UnLock() error
• type Session
  • func NewRedisSession(redis *redis.Client) (*Session, error)
  • func (s *Session) HDel(ctx context.Context, key string, fields ...string) error
  • func (s *Session) HGet(ctx context.Context, k string, field string) (string, error)
  • func (s *Session) HGetAll(ctx context.Context, key string) (map[string]string, error)
  • func (s *Session) HSet(ctx context.Context, k, field string, value interface{}) error
  • func (s *Session) HWatch(ctx context.Context, key string, interval time.Duration) <-chan map[string]string
  • func (s *Session) KeepAlive(ctx context.Context, key string, fieldFunc func() (f, v string), ...)
  • func (s *Session) NewMutex(ctx context.Context, key string) *Mutex

Constants

const (
	ROOT        = "workers/services"
	LOCK        = "lock"
	EmptyString = ""
)

Types

type Mutex

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

func (*Mutex) Lock

func (m *Mutex) Lock() error

func (*Mutex) UnLock

func (m *Mutex) UnLock() error

type Session

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

func NewRedisSession

func NewRedisSession(redis *redis.Client) (*Session, error)

func (*Session) HDel

func (s *Session) HDel(ctx context.Context, key string, fields ...string) error

func (*Session) HGet

func (s *Session) HGet(ctx context.Context, k string, field string) (string, error)

func (*Session) HGetAll

func (s *Session) HGetAll(ctx context.Context, key string) (map[string]string, error)

func (*Session) HSet

func (s *Session) HSet(ctx context.Context, k, field string, value interface{}) error

func (*Session) HWatch

func (s *Session) HWatch(ctx context.Context, key string, interval time.Duration) <-chan map[string]string

func (*Session) KeepAlive

func (s *Session) KeepAlive(ctx context.Context, key string, fieldFunc func() (f, v string), interval time.Duration)

func (*Session) NewMutex

func (s *Session) NewMutex(ctx context.Context, key string) *Mutex