slice

Documentation

Index

• type UserSliceLoader
  • func NewLoader() *UserSliceLoader
  • func NewUserSliceLoader(config UserSliceLoaderConfig) *UserSliceLoader
  • func (l *UserSliceLoader) Clear(key string)
  • func (l *UserSliceLoader) Load(key string) ([]example.User, error)
  • func (l *UserSliceLoader) LoadAll(keys []string) ([][]example.User, []error)
  • func (l *UserSliceLoader) LoadAllThunk(keys []string) func() ([][]example.User, []error)
  • func (l *UserSliceLoader) LoadThunk(key string) func() ([]example.User, error)
  • func (l *UserSliceLoader) Prime(key string, value []example.User) bool
• type UserSliceLoaderCache
• type UserSliceLoaderConfig
• type UserSliceLoaderGoCache
  • func NewUserSliceLoaderGoCache(conf UserSliceLoaderGoCacheConfig) *UserSliceLoaderGoCache
  • func (c *UserSliceLoaderGoCache) ClearKey(key string)
  • func (c *UserSliceLoaderGoCache) Get(key string) ([]example.User, bool)
  • func (c *UserSliceLoaderGoCache) Set(key string, value []example.User)
• type UserSliceLoaderGoCacheConfig
• type UserSliceLoaderMapCache
  • func NewUserSliceLoaderMapCache() *UserSliceLoaderMapCache
  • func (c *UserSliceLoaderMapCache) ClearKey(key string)
  • func (c *UserSliceLoaderMapCache) Get(key string) ([]example.User, bool)
  • func (c *UserSliceLoaderMapCache) Set(key string, value []example.User)

Types

type UserSliceLoader

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

UserSliceLoader batches and caches requests

func NewLoader

func NewLoader() *UserSliceLoader

func NewUserSliceLoader

func NewUserSliceLoader(config UserSliceLoaderConfig) *UserSliceLoader

NewUserSliceLoader creates a new UserSliceLoader given a fetch, wait, and maxBatch

func (*UserSliceLoader) Clear

func (l *UserSliceLoader) Clear(key string)

Clear the value at key from the cache, if it exists

func (*UserSliceLoader) Load

func (l *UserSliceLoader) Load(key string) ([]example.User, error)

Load a User by key, batching and caching will be applied automatically

func (*UserSliceLoader) LoadAll

func (l *UserSliceLoader) LoadAll(keys []string) ([][]example.User, []error)

LoadAll fetches many keys at once. It will be broken into appropriate sized sub batches depending on how the loader is configured

func (*UserSliceLoader) LoadAllThunk

func (l *UserSliceLoader) LoadAllThunk(keys []string) func() ([][]example.User, []error)

LoadAllThunk returns a function that when called will block waiting for a Users. This method should be used if you want one goroutine to make requests to many different data loaders without blocking until the thunk is called.

func (*UserSliceLoader) LoadThunk

func (l *UserSliceLoader) LoadThunk(key string) func() ([]example.User, error)

LoadThunk returns a function that when called will block waiting for a User. This method should be used if you want one goroutine to make requests to many different data loaders without blocking until the thunk is called.

func (*UserSliceLoader) Prime

func (l *UserSliceLoader) Prime(key string, value []example.User) bool

Prime the cache with the provided key and value. If the key already exists, no change is made and false is returned. (To forcefully prime the cache, clear the key first with loader.clear(key).prime(key, value).)

type UserSliceLoaderCache

type UserSliceLoaderCache interface {
	Get(key string) ([]example.User, bool)
	Set(key string, value []example.User)
	ClearKey(key string)
}

UserSliceLoaderCache can be used to cache results. A default map based implementation is used by default.

type UserSliceLoaderConfig

type UserSliceLoaderConfig struct {
	// Fetch is a method that provides the data for the loader
	Fetch func(keys []string) ([][]example.User, []error)

	// Wait is how long wait before sending a batch
	Wait time.Duration

	// MaxBatch will limit the maximum number of keys to send in one batch, 0 = not limit
	MaxBatch int

	// Cache is the datastructure used to cache fetched data
	Cache UserSliceLoaderCache
}

UserSliceLoaderConfig captures the config to create a new UserSliceLoader

type UserSliceLoaderGoCache

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

func NewUserSliceLoaderGoCache

func NewUserSliceLoaderGoCache(conf UserSliceLoaderGoCacheConfig) *UserSliceLoaderGoCache

func (*UserSliceLoaderGoCache) ClearKey

func (c *UserSliceLoaderGoCache) ClearKey(key string)

func (*UserSliceLoaderGoCache) Get

func (c *UserSliceLoaderGoCache) Get(key string) ([]example.User, bool)

func (*UserSliceLoaderGoCache) Set

func (c *UserSliceLoaderGoCache) Set(key string, value []example.User)

type UserSliceLoaderGoCacheConfig

type UserSliceLoaderGoCacheConfig struct {
	DefaultExpiration time.Duration
	CleanupInterval   time.Duration
}

type UserSliceLoaderMapCache

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

func NewUserSliceLoaderMapCache

func NewUserSliceLoaderMapCache() *UserSliceLoaderMapCache

func (*UserSliceLoaderMapCache) ClearKey

func (c *UserSliceLoaderMapCache) ClearKey(key string)

func (*UserSliceLoaderMapCache) Get

func (c *UserSliceLoaderMapCache) Get(key string) ([]example.User, bool)

func (*UserSliceLoaderMapCache) Set

func (c *UserSliceLoaderMapCache) Set(key string, value []example.User)