runner

Documentation

Index

• type Option
  • func WithBigCache(cache *cache.Cache, size int) Option
  • func WithCaches(caches ...*cache.Cache) Option
  • func WithFilterPlatform(filterPlatform func(pf spec.Platform) bool) Option
  • func WithHttpClient(httpClient *http.Client) Option
  • func WithLease(lease string) Option
  • func WithLogger(logger *slog.Logger) Option
  • func WithManifestCache(cache *cache.Cache) Option
  • func WithQueueClient(queueClient *client.MessageClient) Option
  • func WithResumeSize(resumeSize int) Option
• type Runner
  • func NewRunner(opts ...Option) (*Runner, error)
  • func (r *Runner) Run(ctx context.Context) error

Types

type Option

type Option func(r *Runner)

func WithBigCache

func WithBigCache(cache *cache.Cache, size int) Option

func WithCaches

func WithCaches(caches ...*cache.Cache) Option

func WithFilterPlatform

func WithFilterPlatform(filterPlatform func(pf spec.Platform) bool) Option

func WithHttpClient

func WithHttpClient(httpClient *http.Client) Option

func WithLease

func WithLease(lease string) Option

func WithLogger

func WithLogger(logger *slog.Logger) Option

func WithManifestCache

func WithManifestCache(cache *cache.Cache) Option

func WithQueueClient

func WithQueueClient(queueClient *client.MessageClient) Option

func WithResumeSize

func WithResumeSize(resumeSize int) Option

type Runner

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

func NewRunner

func NewRunner(opts ...Option) (*Runner, error)

func (*Runner) Run

func (r *Runner) Run(ctx context.Context) error