dbmanager

Documentation

Index

• type DBManager
  • func NewDBManager(redisClient prowlredis.ClientInterface, logger loggo.LoggerInterface) *DBManager
  • func (dm *DBManager) SaveResults(ctx context.Context, results []models.PageData, key string) error
• type DatabaseManagerInterface
• type MockDBManager
  • func NewMockDBManager() *MockDBManager
  • func (m *MockDBManager) ClearRedisSet(_ context.Context, _ string) error
  • func (m *MockDBManager) GetLinksFromRedis(_ context.Context, _ string) ([]string, error)
  • func (m *MockDBManager) GetResultsFromRedis(_ context.Context, _ string) ([]models.PageData, error)
  • func (m *MockDBManager) RedisOptions() prowlredis.Options
  • func (m *MockDBManager) SaveResults(_ context.Context, results []models.PageData, _ string) error
• type RedisManager
  • func NewRedisManager(client prowlredis.ClientInterface, logger loggo.LoggerInterface) *RedisManager
  • func (rm *RedisManager) ClearRedisSet(ctx context.Context, key string) error
  • func (rm *RedisManager) GetLinksFromRedis(ctx context.Context, key string) ([]string, error)
  • func (rm *RedisManager) RedisOptions() prowlredis.Options
  • func (rm *RedisManager) SaveResults(ctx context.Context, results []models.PageData, key string) error

Types

type DBManager

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

func NewDBManager

func NewDBManager(redisClient prowlredis.ClientInterface, logger loggo.LoggerInterface) *DBManager

func (*DBManager) SaveResults

func (dm *DBManager) SaveResults(ctx context.Context, results []models.PageData, key string) error

type DatabaseManagerInterface

type DatabaseManagerInterface interface {
	SaveResults(ctx context.Context, results []models.PageData, key string) error
	ClearRedisSet(ctx context.Context, key string) error
	GetLinksFromRedis(ctx context.Context, key string) ([]string, error)
	RedisOptions() prowlredis.Options
}

type MockDBManager

type MockDBManager struct {
	// You can add more fields if needed
	SavedResults []models.PageData
}

func NewMockDBManager

func NewMockDBManager() *MockDBManager

func (*MockDBManager) ClearRedisSet

func (m *MockDBManager) ClearRedisSet(_ context.Context, _ string) error

func (*MockDBManager) GetLinksFromRedis

func (m *MockDBManager) GetLinksFromRedis(_ context.Context, _ string) ([]string, error)

func (*MockDBManager) GetResultsFromRedis

func (m *MockDBManager) GetResultsFromRedis(_ context.Context, _ string) ([]models.PageData, error)

func (*MockDBManager) RedisOptions

func (m *MockDBManager) RedisOptions() prowlredis.Options

func (*MockDBManager) SaveResults

func (m *MockDBManager) SaveResults(_ context.Context, results []models.PageData, _ string) error

type RedisManager

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

func NewRedisManager

func NewRedisManager(client prowlredis.ClientInterface, logger loggo.LoggerInterface) *RedisManager

func (*RedisManager) ClearRedisSet

func (rm *RedisManager) ClearRedisSet(ctx context.Context, key string) error

func (*RedisManager) GetLinksFromRedis

func (rm *RedisManager) GetLinksFromRedis(ctx context.Context, key string) ([]string, error)

func (*RedisManager) RedisOptions

func (rm *RedisManager) RedisOptions() prowlredis.Options

func (*RedisManager) SaveResults

func (rm *RedisManager) SaveResults(ctx context.Context, results []models.PageData, key string) error