storage

Documentation

Index

• Constants
• type Option
  • func WithBootstrap(v string) Option
  • func WithTTL(v time.Duration) Option
  • func WithType(v string) Option
• type Storage
  • func New(ctx context.Context, opts ...Option) (Storage, error)

Constants

const (
	DefaultEtcdLoggerName = "etcd-storage"

	DefaultEtcdMutexName = "pg"

	DefaultEtcdDictionaryName = "pg"

	DefaultEtcdDialTimeout      = 5000 * time.Millisecond
	DefaultEtcdOpTimeout        = 2000 * time.Millisecond
	DefaultEtcdKeepAliveTime    = 2000 * time.Millisecond
	DefaultEtcdKeepAliveTimeout = 1000 * time.Millisecond
)

const (
	DefaultStoaLoggerName = "stoa-storage"

	// DefaultStoaMutexName is the default name for the mutex locked by a master.
	DefaultStoaMutexName = "pg"

	// DefaultStoaDictionaryName is the default name for the dictionary used to
	// register clusters.
	DefaultStoaDictionaryName = "pg"
)

const (
	Stoa = "stoa"
	Etcd = "etcd"
)

const (
	DefaultType = Stoa
	DefaultTTL  = 5000 * time.Millisecond
)

Types

type Option

type Option func(*options)

func WithBootstrap

func WithBootstrap(v string) Option

func WithTTL

func WithTTL(v time.Duration) Option

func WithType

func WithType(v string) Option

type Storage

type Storage interface {
	MutexTryLock(context.Context) (bool, error)

	MutexUnlock(context.Context) error

	DictionaryPut(ctx context.Context, k, v []byte) error

	DictionaryGet(ctx context.Context, k []byte) ([]byte, error)

	DictionaryRemove(ctx context.Context, k []byte) error
}

func New

func New(ctx context.Context, opts ...Option) (Storage, error)