spinlockers

Documentation

Index

• Constants
• Variables
• type CFeature
  • func (f *CFeature) Build(b feature.Buildable) (err error)
  • func (f *CFeature) Init(this interface{})
  • func (f *CFeature) Make() (feat Feature)
  • func (f *CFeature) NewSyncLocker(tag feature.Tag, key string, store feature.KeyValueStore) (l feature.SyncLocker)
  • func (f *CFeature) NewSyncLockerWith(tag feature.Tag, key string, store feature.KeyValueStore, ...) (l feature.SyncLocker)
  • func (f *CFeature) NewSyncRWLocker(tag feature.Tag, key string, readStore, writeStore feature.KeyValueStore) (l feature.SyncRWLocker)
  • func (f *CFeature) NewSyncRWLockerWith(tag feature.Tag, key string, readStore, writeStore feature.KeyValueStore, ...) (l feature.SyncRWLocker)
  • func (f *CFeature) Startup(ctx *cli.Context) (err error)
• type Feature
• type MakeFeature
  • func New() MakeFeature
  • func NewTagged(tag feature.Tag) MakeFeature

Constants

const Tag feature.Tag = "srv-factory-spinlockers"

Variables

var (
	DefaultSpinlockerTimeout  = time.Second * 10
	DefaultSpinlockerInterval = time.Millisecond * 50
)

Types

type CFeature

type CFeature struct {
	feature.CFeature
}

func (*CFeature) Build

func (f *CFeature) Build(b feature.Buildable) (err error)

func (*CFeature) Init

func (f *CFeature) Init(this interface{})

func (*CFeature) Make

func (f *CFeature) Make() (feat Feature)

func (*CFeature) NewSyncLocker

func (f *CFeature) NewSyncLocker(tag feature.Tag, key string, store feature.KeyValueStore) (l feature.SyncLocker)

func (*CFeature) NewSyncLockerWith

func (f *CFeature) NewSyncLockerWith(tag feature.Tag, key string, store feature.KeyValueStore, timeout, interval time.Duration) (l feature.SyncLocker)

func (*CFeature) NewSyncRWLocker

func (f *CFeature) NewSyncRWLocker(tag feature.Tag, key string, readStore, writeStore feature.KeyValueStore) (l feature.SyncRWLocker)

func (*CFeature) NewSyncRWLockerWith

func (f *CFeature) NewSyncRWLockerWith(tag feature.Tag, key string, readStore, writeStore feature.KeyValueStore, timeout, interval time.Duration) (l feature.SyncRWLocker)

func (*CFeature) Startup

func (f *CFeature) Startup(ctx *cli.Context) (err error)

type Feature

type Feature interface {
	feature.Feature
}

type MakeFeature

type MakeFeature interface {
	Make() Feature
}

func New

func New() MakeFeature

func NewTagged

func NewTagged(tag feature.Tag) MakeFeature