cache

type Caches interface {
	Get(ctx context.Context, key string, typeDestination any, fallbackFn ...FallbackFn) error
	Del(ctx context.Context, key string) (int64, error)
	Set(ctx context.Context, key string, value any, expire ...int) error
	HSet(ctx context.Context, key, field string, value any, expire ...int) error
	HGet(ctx context.Context, key, field string, typeDestination any, fallbackFn ...FallbackFn) error
	HDel(ctx context.Context, key, field string) error
	HGetAll(ctx context.Context, key string, dest interface{}) error
	HSetBulk(ctx context.Context, key string, fields map[string]interface{}, expire ...int) error
	XGroupCreateMkStream(ctx context.Context, streamKey, group, startID string) error
	XReadGroup(ctx context.Context, group, consumer string, streams []string, ids []string, block time.Duration, count int64) ([]StreamMessages, error)
	XAck(ctx context.Context, streamKey, group, id string) (int64, error)
}

type FallbackFn func(ctx context.Context) (result any, expire int64, err error)

type Handler interface {
	Get() redigo.Conn
	GetContext(context.Context) (redigo.Conn, error)
}

type Options func(*RedisCfg)

type RedisCfg struct {
	Address   string `yaml:"address"`
	Timeout   int    `yaml:"timeout"`
	MaxIdle   int    `yaml:"max_iddle"`
	MaxActive int    `yaml:"max_active"`
	Password  string `yaml:"password"`
	Username  string `yaml:"username"`
	MaxRetry  int
	// contains filtered or unexported fields
}

type Store struct {
	Pool Handler
	// contains filtered or unexported fields
}

type StreamData struct {
	ID     string
	Values map[string]string
}

type StreamMessages struct {
	Stream   string
	Messages []StreamData
}