backend

Documentation

Index

• Constants
• type Storage
  • func NewStorage(endPoints []string, user, password string) (*Storage, error)
  • func (s *Storage) Delete(ctx context.Context, key string, opts ...v3.OpOption) (resp *v3.DeleteResponse, err error)
  • func (s *Storage) Get(ctx context.Context, key string, opts ...v3.OpOption) (resp *v3.GetResponse, err error)
  • func (s *Storage) NewElection(key string) (*concurrency.Election, error)
  • func (s *Storage) NewMutex(key string) (*concurrency.Mutex, error)
  • func (s *Storage) Put(ctx context.Context, key, value string, opts ...v3.OpOption) (resp *v3.PutResponse, err error)

Constants

const (
	DialTimeout  = 5 * time.Second
	ReadTimeout  = 5 * time.Second
	WriteTimeout = 5 * time.Second

	RetryTimes = 3
)

Types

type Storage

type Storage struct {
	*v3.Client
}

func NewStorage

func NewStorage(endPoints []string, user, password string) (*Storage, error)

func (*Storage) Delete

func (s *Storage) Delete(ctx context.Context, key string, opts ...v3.OpOption) (resp *v3.DeleteResponse, err error)

func (*Storage) Get

func (s *Storage) Get(ctx context.Context, key string, opts ...v3.OpOption) (resp *v3.GetResponse, err error)

func (*Storage) NewElection

func (s *Storage) NewElection(key string) (*concurrency.Election, error)

func (*Storage) NewMutex

func (s *Storage) NewMutex(key string) (*concurrency.Mutex, error)

func (*Storage) Put

func (s *Storage) Put(ctx context.Context, key, value string, opts ...v3.OpOption) (resp *v3.PutResponse, err error)