shareds

Documentation

Index

• Variables
• func RegisterLocalStoreBuild(build LocalStoreBuild)
• type DefaultLocalSharedStoreConfig
• type LocalSharedConfig
• type LocalStoreBuild
• type Locker
• type Lockers
  • func LocalLockers() Lockers
• type Options
• type Shared
  • func Local(log logs.Logger, config LocalSharedConfig) (v Shared, err error)
• type Store

Variables

var (
	ErrLockTimeout = fmt.Errorf("fns: shared lockers lock timeout failed")
)

Functions

func RegisterLocalStoreBuild

func RegisterLocalStoreBuild(build LocalStoreBuild)

Types

type DefaultLocalSharedStoreConfig

type DefaultLocalSharedStoreConfig struct {
	CacheSize string `json:"cacheSize,omitempty" yaml:"cacheSize,omitempty"`
}

type LocalSharedConfig

type LocalSharedConfig struct {
	Store json.RawMessage `json:"store,omitempty" yaml:"store,omitempty"`
}

type LocalStoreBuild

type LocalStoreBuild func(log logs.Logger, config configures.Config) (Store, error)

type Locker

type Locker interface {
	Lock(ctx context.Context) (err error)
	Unlock(ctx context.Context) (err error)
}

type Lockers

type Lockers interface {
	Acquire(ctx context.Context, key []byte, ttl time.Duration) (locker Locker, err error)
}

func LocalLockers

func LocalLockers() Lockers

type Options

type Options struct {
	Log    logs.Logger
	Config configures.Config
}

type Shared

type Shared interface {
	Construct(options Options) (err error)
	Lockers() (lockers Lockers)
	Store() (store Store)
}

func Local

func Local(log logs.Logger, config LocalSharedConfig) (v Shared, err error)

type Store

type Store interface {
	Get(ctx context.Context, key []byte) (value []byte, has bool, err error)
	Set(ctx context.Context, key []byte, value []byte) (err error)
	SetWithTTL(ctx context.Context, key []byte, value []byte, ttl time.Duration) (err error)
	Incr(ctx context.Context, key []byte, delta int64) (v int64, err error)
	Remove(ctx context.Context, key []byte) (err error)
	Close()
}