loaders

Documentation

Index

• func GetContextWithLoaders(ctx context.Context, apiClients LoaderClients) context.Context
• type DataLoaders
  • func GetDataLoadersFromContext(ctx context.Context) *DataLoaders
• type ListSomeEntitiesResponse_SomeEntityLoader
  • func (l *ListSomeEntitiesResponse_SomeEntityLoader) Clear(key string)
  • func (l *ListSomeEntitiesResponse_SomeEntityLoader) Load(key string) (*proto.ListSomeEntitiesResponse_SomeEntity, error)
  • func (l *ListSomeEntitiesResponse_SomeEntityLoader) LoadAll(keys []string) ([]*proto.ListSomeEntitiesResponse_SomeEntity, []error)
  • func (l *ListSomeEntitiesResponse_SomeEntityLoader) LoadAllThunk(keys []string) func() ([]*proto.ListSomeEntitiesResponse_SomeEntity, []error)
  • func (l *ListSomeEntitiesResponse_SomeEntityLoader) LoadThunk(key string) func() (*proto.ListSomeEntitiesResponse_SomeEntity, error)
  • func (l *ListSomeEntitiesResponse_SomeEntityLoader) Prime(key string, value *proto.ListSomeEntitiesResponse_SomeEntity) bool
• type ListSomeEntitiesResponse_SomeEntitySliceLoader
  • func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) Clear(key string)
  • func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) Load(key string) ([]*proto.ListSomeEntitiesResponse_SomeEntity, error)
  • func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadAll(keys []string) ([][]*proto.ListSomeEntitiesResponse_SomeEntity, []error)
  • func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadAllThunk(keys []string) func() ([][]*proto.ListSomeEntitiesResponse_SomeEntity, []error)
  • func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadThunk(key string) func() ([]*proto.ListSomeEntitiesResponse_SomeEntity, error)
  • func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) Prime(key string, value []*proto.ListSomeEntitiesResponse_SomeEntity) bool
• type LoaderClients

Functions

func GetContextWithLoaders

func GetContextWithLoaders(ctx context.Context, apiClients LoaderClients) context.Context

Types

type DataLoaders

type DataLoaders struct {
	SomeEntitiesByIDLoader  ListSomeEntitiesResponse_SomeEntityLoader
	SomeEntitiesByAIDLoader ListSomeEntitiesResponse_SomeEntitySliceLoader
}

func GetDataLoadersFromContext

func GetDataLoadersFromContext(ctx context.Context) *DataLoaders

type ListSomeEntitiesResponse_SomeEntityLoader

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

ListSomeEntitiesResponse_SomeEntityLoader batches and caches requests

func (*ListSomeEntitiesResponse_SomeEntityLoader) Clear

func (l *ListSomeEntitiesResponse_SomeEntityLoader) Clear(key string)

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

func (*ListSomeEntitiesResponse_SomeEntityLoader) Load

func (l *ListSomeEntitiesResponse_SomeEntityLoader) Load(key string) (*proto.ListSomeEntitiesResponse_SomeEntity, error)

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

func (*ListSomeEntitiesResponse_SomeEntityLoader) LoadAll

func (l *ListSomeEntitiesResponse_SomeEntityLoader) LoadAll(keys []string) ([]*proto.ListSomeEntitiesResponse_SomeEntity, []error)

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

func (*ListSomeEntitiesResponse_SomeEntityLoader) LoadAllThunk

func (l *ListSomeEntitiesResponse_SomeEntityLoader) LoadAllThunk(keys []string) func() ([]*proto.ListSomeEntitiesResponse_SomeEntity, []error)

LoadThunk returns a function that when called will block waiting for a listSomeEntitiesResponse_SomeEntitys. 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 (*ListSomeEntitiesResponse_SomeEntityLoader) LoadThunk

func (l *ListSomeEntitiesResponse_SomeEntityLoader) LoadThunk(key string) func() (*proto.ListSomeEntitiesResponse_SomeEntity, error)

LoadThunk returns a function that when called will block waiting for a listSomeEntitiesResponse_SomeEntity. 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 (*ListSomeEntitiesResponse_SomeEntityLoader) Prime

func (l *ListSomeEntitiesResponse_SomeEntityLoader) Prime(key string, value *proto.ListSomeEntitiesResponse_SomeEntity) 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 ListSomeEntitiesResponse_SomeEntitySliceLoader

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

ListSomeEntitiesResponse_SomeEntitySliceLoader batches and caches requests

func (*ListSomeEntitiesResponse_SomeEntitySliceLoader) Clear

func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) Clear(key string)

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

func (*ListSomeEntitiesResponse_SomeEntitySliceLoader) Load

func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) Load(key string) ([]*proto.ListSomeEntitiesResponse_SomeEntity, error)

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

func (*ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadAll

func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadAll(keys []string) ([][]*proto.ListSomeEntitiesResponse_SomeEntity, []error)

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

func (*ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadAllThunk

func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadAllThunk(keys []string) func() ([][]*proto.ListSomeEntitiesResponse_SomeEntity, []error)

LoadThunk returns a function that when called will block waiting for a listSomeEntitiesResponse_SomeEntitys. 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 (*ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadThunk

func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) LoadThunk(key string) func() ([]*proto.ListSomeEntitiesResponse_SomeEntity, error)

LoadThunk returns a function that when called will block waiting for a listSomeEntitiesResponse_SomeEntity. 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 (*ListSomeEntitiesResponse_SomeEntitySliceLoader) Prime

func (l *ListSomeEntitiesResponse_SomeEntitySliceLoader) Prime(key string, value []*proto.ListSomeEntitiesResponse_SomeEntity) 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 LoaderClients

type LoaderClients interface {
	GetServiceExampleClient() proto.ServiceExampleClient
}