stores

Documentation

Index

• type MemoryStore
  • func NewMemoryStore() *MemoryStore
  • func (ms *MemoryStore) DataKey(_ context.Context, ev interfaces.IncomingEventInterface, ...) string
  • func (ms *MemoryStore) Enqueue(_ context.Context, key string, value string, ttl time.Duration) (bool, error)
  • func (ms *MemoryStore) Get(_ context.Context, key string) (string, bool, time.Duration, error)
  • func (ms *MemoryStore) GetQueue(_ context.Context, key string) ([]string, bool, time.Duration, error)
  • func (ms *MemoryStore) Len() int
  • func (ms *MemoryStore) Remove(_ context.Context, key string) (bool, error)
  • func (ms *MemoryStore) Set(_ context.Context, key string, value string, ttl time.Duration) (bool, error)
  • func (ms *MemoryStore) Update(_ context.Context, key string, value string) (bool, error)

Types

type MemoryStore

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

MemoryStore - In-app memory storage

func NewMemoryStore

func NewMemoryStore() *MemoryStore

NewMemoryStore - Create new MemoryStore

func (*MemoryStore) DataKey

func (ms *MemoryStore) DataKey(_ context.Context, ev interfaces.IncomingEventInterface, dest interfaces.DestinationInterface, prefix string, suffix string) string

DataKey - Generate DataKey with events and destination

func (*MemoryStore) Enqueue

func (ms *MemoryStore) Enqueue(_ context.Context, key string, value string, ttl time.Duration) (bool, error)

Enqueue - ttl: optional params for setting the ttl of queue when first element is enqueued

func (*MemoryStore) Get

func (ms *MemoryStore) Get(_ context.Context, key string) (string, bool, time.Duration, error)

Get - Get value from store, return with remaining time

func (*MemoryStore) GetQueue

func (ms *MemoryStore) GetQueue(_ context.Context, key string) ([]string, bool, time.Duration, error)

func (*MemoryStore) Len

func (ms *MemoryStore) Len() int

Len - Get memory size

func (*MemoryStore) Remove

func (ms *MemoryStore) Remove(_ context.Context, key string) (bool, error)

Remove - Remove value in store

func (*MemoryStore) Set

func (ms *MemoryStore) Set(_ context.Context, key string, value string, ttl time.Duration) (bool, error)

Set - Set value into store with ttl

func (*MemoryStore) Update

func (ms *MemoryStore) Update(_ context.Context, key string, value string) (bool, error)

Update - Update value into store