redisloader

Documentation

Index

• func New[K comparable, V any](client ClientInterface, loader dataloader.Loader[K, V], ...) *redisDataLoader[K, V]
• func WithExpiration(expiration time.Duration) func(*option)
• func WithKeyFunc(keyFunc func(any) string) func(*option)
• func WithMarshalFunc(marshalFunc func(any) ([]byte, error)) func(*option)
• func WithUnmarshalFunc(unmarshalFunc func([]byte, any) error) func(*option)
• type ClientInterface

Functions

func New

func New[K comparable, V any](client ClientInterface, loader dataloader.Loader[K, V], options ...func(*option)) *redisDataLoader[K, V]

New creates a new RedisDataLoader

func WithExpiration

func WithExpiration(expiration time.Duration) func(*option)

WithExpiration sets the expiration time for the cache

func WithKeyFunc

func WithKeyFunc(keyFunc func(any) string) func(*option)

WithKeyFunc sets the key function for the cache

func WithMarshalFunc

func WithMarshalFunc(marshalFunc func(any) ([]byte, error)) func(*option)

WithMarshalFunc sets the marshal function for the cache

func WithUnmarshalFunc

func WithUnmarshalFunc(unmarshalFunc func([]byte, any) error) func(*option)

WithUnmarshalFunc sets the unmarshal function for the cache

Types

type ClientInterface

type ClientInterface interface {
	MGet(ctx context.Context, keys ...string) *redis.SliceCmd
	Pipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
}