app

package

v0.12.1 Latest Latest Go to latest Published: Sep 28, 2026 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/synrise25/rss-pod

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Migrate(ctx context.Context, cfg *config.Config) error
func ParsePollSources(cfg *config.Config, value string) ([]config.SourceConfig, error)
func ParseQueues(cfg *config.Config, value string) ([]string, error)
func Run(ctx context.Context, cfg *config.Config) error
func Serve(ctx context.Context, cfg *config.Config) error
func Worker(ctx context.Context, cfg *config.Config, queueNames []string) error
type QueuedPoll
- func EnqueuePolls(ctx context.Context, cfg *config.Config, sources []config.SourceConfig, ...) ([]QueuedPoll, error)

Constants ¶

View Source

const MaxManualPollTimes = 100

Variables ¶

This section is empty.

Functions ¶

func Migrate ¶

func Migrate(ctx context.Context, cfg *config.Config) error

func ParsePollSources ¶

func ParsePollSources(cfg *config.Config, value string) ([]config.SourceConfig, error)

func ParseQueues ¶

func ParseQueues(cfg *config.Config, value string) ([]string, error)

func Run ¶

func Run(ctx context.Context, cfg *config.Config) error

func Serve ¶

func Serve(ctx context.Context, cfg *config.Config) error

func Worker ¶

func Worker(ctx context.Context, cfg *config.Config, queueNames []string) error

Types ¶

type QueuedPoll ¶

type QueuedPoll struct {
	SourceID string    `json:"source_id"`
	Number   int       `json:"number"`
	RunID    uuid.UUID `json:"run_id"`
	JobID    int64     `json:"job_id"`
}

func EnqueuePolls ¶

func EnqueuePolls(
	ctx context.Context,
	cfg *config.Config,
	sources []config.SourceConfig,
	times int,
	limit int,
	resumeIncomplete bool,
) ([]QueuedPoll, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL