database

type ConfigCache interface {
	GetConfigObject(context.Context, *configV1.ConfigRef) (*configV1.ConfigObject, error)
	HasCrawledContent(ctx context.Context, revisitKey string) (*contentwriter.CrawledContent, error)
	WriteCrawledContent(ctx context.Context, crawledContent *contentwriter.CrawledContent) error
}

type DbAdapter interface {
	GetConfigObject(context.Context, *configV1.ConfigRef) (*configV1.ConfigObject, error)
	HasCrawledContent(ctx context.Context, revisitKey string) (*contentwriter.CrawledContent, error)
	WriteCrawledContent(ctx context.Context, crawledContent *contentwriter.CrawledContent) error
}

type MockConnection struct {
	*RethinkDbConnection
}

type Options struct {
	Username           string
	Password           string
	Database           string
	UseOpenTracing     bool
	Address            string
	QueryTimeout       time.Duration
	MaxRetries         int
	MaxOpenConnections int
}

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