storage

Documentation

Index

• type Client
  • func New(cache Implementation, errorChan chan error, queries chan common.PropertyQuery, ...) (*Client, error)
  • func (s *Client) Get(ctx context.Context, queries []common.PropertyQuery) []common.PropertyResponse
  • func (s *Client) Metrics() *ristretto.Metrics
  • func (s *Client) StartListening(ctx context.Context)
• type Implementation
• type Ristretto
  • func NewStorageImplementation(numberOfCounters int64, maxCost int64, bufferItems int64) (*Ristretto, error)
  • func (r *Ristretto) Get(key string) (common.PropertyResponse, bool)
  • func (r *Ristretto) Metrics() *ristretto.Metrics
  • func (r *Ristretto) SetWithTTL(key string, value common.PropertyResponse, cost int64, ttl time.Duration) bool

Types

type Client

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

Client is an is responsible for managing our storage.

func New

func New(
	cache Implementation,
	errorChan chan error,
	queries chan common.PropertyQuery,
	results chan common.PropertyResponse,
	wg *sync.WaitGroup,
	waitForMissing bool,
) (*Client, error)

func (*Client) Get

func (s *Client) Get(ctx context.Context, queries []common.PropertyQuery) []common.PropertyResponse

func (*Client) Metrics

func (s *Client) Metrics() *ristretto.Metrics

func (*Client) StartListening

func (s *Client) StartListening(ctx context.Context)

type Implementation

type Implementation interface {
	// cache io
	Get(key string) (common.PropertyResponse, bool)
	SetWithTTL(key string, value common.PropertyResponse, cost int64, ttl time.Duration) bool

	// for metrics
	Metrics() *ristretto.Metrics
}

type Ristretto

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

func NewStorageImplementation

func NewStorageImplementation(
	numberOfCounters int64,
	maxCost int64,
	bufferItems int64,
) (*Ristretto, error)

func (*Ristretto) Get

func (r *Ristretto) Get(key string) (common.PropertyResponse, bool)

func (*Ristretto) Metrics

func (r *Ristretto) Metrics() *ristretto.Metrics

func (*Ristretto) SetWithTTL

func (r *Ristretto) SetWithTTL(key string, value common.PropertyResponse, cost int64, ttl time.Duration) bool