redis

Documentation

Index

• type Config
• type Redis
  • func New(cfg Config) (*Redis, error)
  • func (r *Redis) AddDelayedTask(listName string, data string, delay time.Duration) error
  • func (r *Redis) AddEventToBloom(id []byte) error
  • func (r *Redis) CheckAcceptability(restrictedWrites bool, eid []byte, pubkey string) error
  • func (r *Redis) Close() error
  • func (r *Redis) GetReadyTasks(listName string) ([]string, error)
  • func (r *Redis) RemoveTasks(listName string, tasks []string) error

Types

type Config

type Config struct {
	URI                 string
	BloomFilterName     string `yaml:"bloom_filter_name"`
	BlackListFilterName string `yaml:"black_list_filter_name"`
	WhiteListFilterName string `yaml:"white_list_filter_name"`
	ConnectionTimeout   int16  `yaml:"connection_timeout_in_ms"`
	QueryTimeout        int16  `yaml:"query_timeout_in_ms"`
}

type Redis

type Redis struct {
	Client              *redis.Client
	BloomFilterName     string
	WhiteListFilterName string
	BlackListFilterName string
	Name                string
	QueryTimeout        time.Duration
}

func New

func New(cfg Config) (*Redis, error)

func (*Redis) AddDelayedTask

func (r *Redis) AddDelayedTask(listName string,
	data string, delay time.Duration,
) error

! note: delayed tasks probably are not concurrent safe at the moment.

func (*Redis) AddEventToBloom

func (r *Redis) AddEventToBloom(id []byte) error

func (*Redis) CheckAcceptability

func (r *Redis) CheckAcceptability(restrictedWrites bool, eid []byte, pubkey string) error

func (*Redis) Close

func (r *Redis) Close() error

func (*Redis) GetReadyTasks

func (r *Redis) GetReadyTasks(listName string) ([]string, error)

func (*Redis) RemoveTasks

func (r *Redis) RemoveTasks(listName string, tasks []string) error