store

Documentation

Index

• type AllocatorFunc
• type Dispose
• type Key
• type KeyFunc
• type Object
• type RefCountStore
  • func NewRefCountStore(kf KeyFunc) *RefCountStore
  • func (this *RefCountStore) Get(key Key, alloc AllocatorFunc) (Object, error)
  • func (this *RefCountStore) Start() *RefCountStore
  • func (this *RefCountStore) Stop(code int) <-chan error

Types

type AllocatorFunc

type AllocatorFunc func(Dispose) (Key, Object, error)

type Dispose

type Dispose interface {
	Propose() chan<- Object
	Accept() <-chan bool
}

Protocol between implementation and the store. The implementation is expected to send to Propose and then listen for a True on Accept. If true then the implementation can actually close and dispose the resources. This allows the central registry to implement shared connections and things like reference counting.

type Key

type Key interface{}

type KeyFunc

type KeyFunc func(Object) Key

type Object

type Object interface{}

type RefCountStore

type RefCountStore struct {
	// contains filtered or unexported fields
}

The implementation of the referencing counting store.

func NewRefCountStore

func NewRefCountStore(kf KeyFunc) *RefCountStore

The referencing counting store allows a client to delegate the referencing counting and tracking to this store via the `Dispose` interface and Track function. This allows the client to be arbitrarily complex in terms of object creation and deallocation.

func (*RefCountStore) Get

func (this *RefCountStore) Get(key Key, alloc AllocatorFunc) (Object, error)

func (*RefCountStore) Start

func (this *RefCountStore) Start() *RefCountStore

func (*RefCountStore) Stop

func (this *RefCountStore) Stop(code int) <-chan error