package limited

import "github.com/moby/buildkit/util/resolver/limited"

Index ¶

• Variables
• func FetchHandler(ingester content.Ingester, fetcher remotes.Fetcher, ref string) images.HandlerFunc
• func PushHandler(pusher remotes.Pusher, provider content.Provider, ref string) images.HandlerFunc
• type Group
• func New(size int) *Group
• func (g *Group) PushHandler(pusher remotes.Pusher, provider content.Provider, ref string) images.HandlerFunc
• func (g *Group) WrapFetcher(f remotes.Fetcher, ref string) remotes.Fetcher

Variables ¶

var Default = New(int(DefaultMaxConcurrency))

var DefaultMaxConcurrency int64 = 4

DefaultMaxConcurrency is the default number of concurrent connections per registry.

Functions ¶

func FetchHandler ¶

func FetchHandler(ingester content.Ingester, fetcher remotes.Fetcher, ref string) images.HandlerFunc

func PushHandler ¶

func PushHandler(pusher remotes.Pusher, provider content.Provider, ref string) images.HandlerFunc

Types ¶

type Group ¶

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

func New ¶

func New(size int) *Group

func (*Group) PushHandler ¶

func (g *Group) PushHandler(pusher remotes.Pusher, provider content.Provider, ref string) images.HandlerFunc

func (*Group) WrapFetcher ¶

func (g *Group) WrapFetcher(f remotes.Fetcher, ref string) remotes.Fetcher

Source Files ¶

group.go