datastore

package

v0.1.0 Latest Latest Go to latest Published: Oct 1, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/viant/mly

Links

Open Source Insights

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
type Service
- func New(l1Client, l2Client client.Service, counter *gmetric.Operation) *Service
- func NewWithCache(config *config.Datastore, l1Client, l2Client client.Service, ...) (*Service, error)
type StoreMode
type Storer
type Value

Constants ¶

View Source

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

View Source

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

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client
mock

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL