agent

Documentation

Index

• type Agent
  • func NewAgent(opts ...Option) (*Agent, error)
  • func (c *Agent) Serve(rw http.ResponseWriter, r *http.Request, info *BlobInfo, t *token.Token)
  • func (c *Agent) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type BlobInfo
• type Option
  • func WithAuthenticator(authenticator *token.Authenticator) Option
  • func WithBigCache(cache *cache.Cache, size int) Option
  • func WithBlobCacheDuration(blobCacheDuration time.Duration) Option
  • func WithBlobNoRedirectMaxSizePerSecond(blobNoRedirectMaxSizePerSecond int) Option
  • func WithBlobNoRedirectSize(blobNoRedirectSize int) Option
  • func WithCache(cache *cache.Cache) Option
  • func WithClient(client *http.Client) Option
  • func WithConcurrency(concurrency int) Option
  • func WithForceBlobNoRedirect(forceBlobNoRedirect bool) Option
  • func WithLogger(logger *slog.Logger) Option
  • func WithQueueClient(queueClient *client.MessageClient) Option

Types

type Agent

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

func NewAgent

func NewAgent(opts ...Option) (*Agent, error)

func (*Agent) Serve

func (c *Agent) Serve(rw http.ResponseWriter, r *http.Request, info *BlobInfo, t *token.Token)

func (*Agent) ServeHTTP

func (c *Agent) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type BlobInfo

type BlobInfo struct {
	Host  string
	Image string

	Blobs string
}

type Option

type Option func(c *Agent) error

func WithAuthenticator

func WithAuthenticator(authenticator *token.Authenticator) Option

func WithBigCache

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

func WithBlobCacheDuration

func WithBlobCacheDuration(blobCacheDuration time.Duration) Option

func WithBlobNoRedirectMaxSizePerSecond

func WithBlobNoRedirectMaxSizePerSecond(blobNoRedirectMaxSizePerSecond int) Option

func WithBlobNoRedirectSize

func WithBlobNoRedirectSize(blobNoRedirectSize int) Option

func WithCache

func WithCache(cache *cache.Cache) Option

func WithClient

func WithClient(client *http.Client) Option

func WithConcurrency

func WithConcurrency(concurrency int) Option

func WithForceBlobNoRedirect

func WithForceBlobNoRedirect(forceBlobNoRedirect bool) Option

func WithLogger

func WithLogger(logger *slog.Logger) Option

func WithQueueClient

func WithQueueClient(queueClient *client.MessageClient) Option