datastore

Documentation

Index

• Constants
• func NewStores(cfg *config.DatastoreList, gmetrics *gmetric.Service) (map[string]*Service, error)
• type CacheStatus
• type Entry
  • func (e *Entry) DecodeBinary(stream *bintly.Reader) error
  • func (e *Entry) EncodeBinary(stream *bintly.Writer) error
• type EntryData
• type Key
  • func NewKey(cfg *config.Datastore, key string) *Key
  • func (k *Key) AsString() string
  • func (k *Key) Key() (*aero.Key, error)
  • func (k *Key) WritePolicy(generation uint32) *aero.WritePolicy
• type Service
  • func New(l1Client, l2Client client.Service, counter *gmetric.Operation) *Service
  • func NewWithCache(config *config.Datastore, l1Client, l2Client client.Service, ...) (*Service, error)
  • func (s *Service) Config() *config.Datastore
  • func (s *Service) Enabled() bool
  • func (s *Service) GetInto(ctx context.Context, key *Key, storable Value) (dictHash int, err error)
  • func (s *Service) Key(key string) *Key
  • func (s *Service) Mode() StoreMode
  • func (s *Service) Put(ctx context.Context, key *Key, value Value, dictHash int) error
  • func (s *Service) SetMode(mode StoreMode)
• type StoreMode
• type Storer
• type Value

Constants

const (
	//CacheStatusFoundNoSuchKey cacheable no such key status
	CacheStatusFoundNoSuchKey = CacheStatus(iota)
	//CacheStatusNotFound no such key status
	CacheStatusNotFound
	//CacheStatusFound entry found status
	CacheStatusFound
)

const (
	//ModeServer server mode
	ModeServer = StoreMode(0)
	//ModeClient client mode
	ModeClient = StoreMode(1)
)

Functions

func NewStores

func NewStores(cfg *config.DatastoreList, gmetrics *gmetric.Service) (map[string]*Service, error)

NewStores creates new stores

Types

type CacheStatus

type CacheStatus int

type Entry

type Entry struct {
	Key      string
	Data     EntryData
	Hash     int
	NotFound bool
	Expiry   time.Time
}

Entry represents data entry

func (*Entry) DecodeBinary

func (e *Entry) DecodeBinary(stream *bintly.Reader) error

DecodeBinary decodes data to binary stream

func (*Entry) EncodeBinary

func (e *Entry) EncodeBinary(stream *bintly.Writer) error

EncodeBinary encodes data from binary stream

type EntryData

type EntryData interface{}

EntryData

type Key

type Key struct {
	Namespace string
	Set       string
	Value     interface{}
	*aero.GenerationPolicy
	TimeToLive time.Duration
	L2         *Key
}

Key represents a datastore key

func NewKey

func NewKey(cfg *config.Datastore, key string) *Key

func (*Key) AsString

func (k *Key) AsString() string

func (*Key) Key

func (k *Key) Key() (*aero.Key, error)

func (*Key) WritePolicy

func (k *Key) WritePolicy(generation uint32) *aero.WritePolicy

type Service

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

Service datastore service

func New

func New(l1Client, l2Client client.Service, counter *gmetric.Operation) *Service

New returns a new Service

func NewWithCache

func NewWithCache(config *config.Datastore, l1Client, l2Client client.Service, counter *gmetric.Operation) (*Service, error)

NewWithCache creates Service with cache

func (*Service) Config

func (s *Service) Config() *config.Datastore

func (*Service) Enabled

func (s *Service) Enabled() bool

func (*Service) GetInto

func (s *Service) GetInto(ctx context.Context, key *Key, storable Value) (dictHash int, err error)

GetInto gets data into storable or error

func (*Service) Key

func (s *Service) Key(key string) *Key

func (*Service) Mode

func (s *Service) Mode() StoreMode

func (*Service) Put

func (s *Service) Put(ctx context.Context, key *Key, value Value, dictHash int) error

Put puts entry to the datastore

func (*Service) SetMode

func (s *Service) SetMode(mode StoreMode)

type StoreMode

type StoreMode int

StoreMode represents service mode

type Storer

type Storer interface {
	Put(ctx context.Context, key *Key, value Value, dictHash int) error
	GetInto(ctx context.Context, key *Key, storable Value) (dictHash int, err error)
	Key(key string) *Key
	Enabled() bool
	Mode() StoreMode
	SetMode(mode StoreMode)
	Config() *config.Datastore
}

type Value

type Value interface{}

Value represents a datastore value