storage

Documentation

Index

• Constants
• type ETCDConfig
• type GetResponse
• type Repo
  • func New(cfg *ETCDConfig) (Repo, error)
• type SetResponse

Constants

const ConcurrentSet = "/SAIL/ConcurrentSet"

Types

type ETCDConfig

type ETCDConfig struct {
	Endpoints            []string
	DialTimeout          time.Duration
	DialKeepAlive        time.Duration
	DialKeepAliveTimeout time.Duration
	Username             string
	Password             string
}

type GetResponse

type GetResponse struct {
	Value string

	Revision int
	Err      error
}

type Repo

type Repo interface {
	Set(ctx context.Context, key string, value string) SetResponse
	AtomicBatchSet(ctx context.Context, key []string, value []string, callback ...func()) SetResponse
	Get(ctx context.Context, key string) GetResponse
	ConcurrentSet(ctx context.Context, key string, value string) SetResponse
	GetWithReversion(ctx context.Context, key string, reversion int) GetResponse
	Del(ctx context.Context, key string) (bool, error)
	Close() error
}

func New

func New(cfg *ETCDConfig) (Repo, error)

type SetResponse

type SetResponse struct {
	Revision int
	Err      error
}