store

Documentation

Index

• type RedisStore
  • func NewRedisStore(config *configs.Config) (*RedisStore, error)
  • func (s *RedisStore) GetNextRun(feed *configs.FeedConfig) (time.Time, error)
  • func (s *RedisStore) GetValues() (map[string]map[string]interface{}, error)
  • func (s *RedisStore) SetNextRun(feed *configs.FeedConfig, nextRun time.Time) error
  • func (s *RedisStore) SetValues(feed *configs.FeedConfig, values map[string]gjson.Result) error
  • func (s *RedisStore) StringOrVar(value string) string
• type Store

Types

type RedisStore

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

func NewRedisStore

func NewRedisStore(config *configs.Config) (*RedisStore, error)

func (*RedisStore) GetNextRun

func (s *RedisStore) GetNextRun(feed *configs.FeedConfig) (time.Time, error)

func (*RedisStore) GetValues

func (s *RedisStore) GetValues() (map[string]map[string]interface{}, error)

func (*RedisStore) SetNextRun

func (s *RedisStore) SetNextRun(feed *configs.FeedConfig, nextRun time.Time) error

func (*RedisStore) SetValues

func (s *RedisStore) SetValues(feed *configs.FeedConfig, values map[string]gjson.Result) error

func (*RedisStore) StringOrVar

func (s *RedisStore) StringOrVar(value string) string

type Store

type Store interface {
	StringOrVar(value string) string
	GetNextRun(feed *configs.FeedConfig) (time.Time, error)
	SetNextRun(feed *configs.FeedConfig, nextRun time.Time) error
	GetValues() (map[string]map[string]interface{}, error)
	SetValues(feed *configs.FeedConfig, values map[string]gjson.Result) error
}