gateway

Documentation

Index

• func NewContainer(ctx context.Context, w worker.Worker, sm *session.Manager, g session.Group, ...) (client.Container, error)
• func NewGatewayFrontend(w worker.Infos) frontend.Frontend
• func ParseExtraHosts(ips []*pb.HostIP) ([]executor.HostIP, error)
• type LLBBridgeForwarder
  • func NewBridgeForwarder(ctx context.Context, llbBridge frontend.FrontendLLBBridge, ...) LLBBridgeForwarder
• type MakeMutable
• type Mount
• type MountMutableRef
• type MountRef
• type NewContainerRequest
• type PreparedMounts
  • func PrepareMounts(ctx context.Context, mm *mounts.MountManager, cm cache.Manager, ...) (p PreparedMounts, err error)

Functions

func NewContainer

func NewContainer(ctx context.Context, w worker.Worker, sm *session.Manager, g session.Group, req NewContainerRequest) (client.Container, error)

func NewGatewayFrontend

func NewGatewayFrontend(w worker.Infos) frontend.Frontend

func ParseExtraHosts

func ParseExtraHosts(ips []*pb.HostIP) ([]executor.HostIP, error)

Types

type LLBBridgeForwarder

type LLBBridgeForwarder interface {
	pb.LLBBridgeServer
	Done() <-chan struct{}
	Result() (*frontend.Result, error)
	Discard()
}

func NewBridgeForwarder

func NewBridgeForwarder(ctx context.Context, llbBridge frontend.FrontendLLBBridge, workers worker.Infos, inputs map[string]*opspb.Definition, sid string, sm *session.Manager) LLBBridgeForwarder

type MakeMutable

type MakeMutable func(m *opspb.Mount, ref cache.ImmutableRef) (cache.MutableRef, error)

type Mount

type Mount struct {
	*opspb.Mount
	WorkerRef *worker.WorkerRef
}

Mount used for the gateway.Container is nearly identical to the client.Mount except is has a RefProxy instead of Ref to allow for a common abstraction between gateway clients.

type MountMutableRef

type MountMutableRef struct {
	Ref        cache.MutableRef
	MountIndex int
	NoCommit   bool
}

type MountRef

type MountRef struct {
	Ref        cache.Ref
	MountIndex int
}

type NewContainerRequest

type NewContainerRequest struct {
	ContainerID string
	NetMode     opspb.NetMode
	ExtraHosts  []executor.HostIP
	Mounts      []Mount
	Platform    *opspb.Platform
	Constraints *opspb.WorkerConstraints
}

type PreparedMounts

type PreparedMounts struct {
	Root           executor.Mount
	ReadonlyRootFS bool
	Mounts         []executor.Mount
	OutputRefs     []MountRef
	Actives        []MountMutableRef
}

func PrepareMounts

func PrepareMounts(ctx context.Context, mm *mounts.MountManager, cm cache.Manager, g session.Group, cwd string, mnts []*opspb.Mount, refs []*worker.WorkerRef, makeMutable MakeMutable) (p PreparedMounts, err error)