server

Documentation

Index

• type BuildkitController
  • func NewBuildkitController(opts BuildkitControllerOpts) (*BuildkitController, error)
  • func (e *BuildkitController) Close() error
  • func (e *BuildkitController) DiskUsage(ctx context.Context, r *controlapi.DiskUsageRequest) (*controlapi.DiskUsageResponse, error)
  • func (e *BuildkitController) Export(ctx context.Context, req *tracev1.ExportTraceServiceRequest) (*tracev1.ExportTraceServiceResponse, error)
  • func (e *BuildkitController) Info(ctx context.Context, r *controlapi.InfoRequest) (*controlapi.InfoResponse, error)
  • func (e *BuildkitController) ListWorkers(ctx context.Context, r *controlapi.ListWorkersRequest) (*controlapi.ListWorkersResponse, error)
  • func (e *BuildkitController) ListenBuildHistory(req *controlapi.BuildHistoryRequest, ...) error
  • func (e *BuildkitController) LogMetrics(l *logrus.Entry) *logrus.Entry
  • func (e *BuildkitController) Prune(req *controlapi.PruneRequest, stream controlapi.Control_PruneServer) error
  • func (e *BuildkitController) Register(server *grpc.Server)
  • func (e *BuildkitController) Session(stream controlapi.Control_SessionServer) (rerr error)
  • func (e *BuildkitController) Solve(ctx context.Context, req *controlapi.SolveRequest) (*controlapi.SolveResponse, error)
  • func (e *BuildkitController) Status(req *controlapi.StatusRequest, stream controlapi.Control_StatusServer) error
  • func (e *BuildkitController) UpdateBuildHistory(ctx context.Context, req *controlapi.UpdateBuildHistoryRequest) (*controlapi.UpdateBuildHistoryResponse, error)
• type BuildkitControllerOpts
• type DaggerServer
  • func NewDaggerServer(ctx context.Context, bkClient *buildkit.Client, worker bkworker.Worker, ...) (*DaggerServer, error)
  • func (srv *DaggerServer) Close()
  • func (srv *DaggerServer) HTTPHandlerForClient(clientMetadata *engine.ClientMetadata, conn net.Conn, lg *logrus.Entry) (http.Handler, <-chan struct{}, error)
  • func (srv *DaggerServer) LogMetrics(l *logrus.Entry) *logrus.Entry
  • func (srv *DaggerServer) ServeClientConn(ctx context.Context, clientMetadata *engine.ClientMetadata, conn net.Conn) error
  • func (srv *DaggerServer) Wait(ctx context.Context) error

Types

type BuildkitController

type BuildkitController struct {
	BuildkitControllerOpts
	*tracev1.UnimplementedTraceServiceServer // needed for grpc service register to not complain
	// contains filtered or unexported fields
}

func NewBuildkitController

func NewBuildkitController(opts BuildkitControllerOpts) (*BuildkitController, error)

func (*BuildkitController) Close

func (e *BuildkitController) Close() error

func (*BuildkitController) DiskUsage

func (e *BuildkitController) DiskUsage(ctx context.Context, r *controlapi.DiskUsageRequest) (*controlapi.DiskUsageResponse, error)

func (*BuildkitController) Export

func (e *BuildkitController) Export(ctx context.Context, req *tracev1.ExportTraceServiceRequest) (*tracev1.ExportTraceServiceResponse, error)

func (*BuildkitController) Info

func (e *BuildkitController) Info(ctx context.Context, r *controlapi.InfoRequest) (*controlapi.InfoResponse, error)

func (*BuildkitController) ListWorkers

func (e *BuildkitController) ListWorkers(ctx context.Context, r *controlapi.ListWorkersRequest) (*controlapi.ListWorkersResponse, error)

func (*BuildkitController) ListenBuildHistory

func (e *BuildkitController) ListenBuildHistory(req *controlapi.BuildHistoryRequest, srv controlapi.Control_ListenBuildHistoryServer) error

func (*BuildkitController) LogMetrics

func (e *BuildkitController) LogMetrics(l *logrus.Entry) *logrus.Entry

func (*BuildkitController) Prune

func (e *BuildkitController) Prune(req *controlapi.PruneRequest, stream controlapi.Control_PruneServer) error

func (*BuildkitController) Register

func (e *BuildkitController) Register(server *grpc.Server)

func (*BuildkitController) Session

func (e *BuildkitController) Session(stream controlapi.Control_SessionServer) (rerr error)

func (*BuildkitController) Solve

func (e *BuildkitController) Solve(ctx context.Context, req *controlapi.SolveRequest) (*controlapi.SolveResponse, error)

Solve is currently only used for triggering upstream remote cache exports on a dagger server

func (*BuildkitController) Status

func (e *BuildkitController) Status(req *controlapi.StatusRequest, stream controlapi.Control_StatusServer) error

func (*BuildkitController) UpdateBuildHistory

func (e *BuildkitController) UpdateBuildHistory(ctx context.Context, req *controlapi.UpdateBuildHistoryRequest) (*controlapi.UpdateBuildHistoryResponse, error)

type BuildkitControllerOpts

type BuildkitControllerOpts struct {
	WorkerController       *bkworker.Controller
	SessionManager         *session.Manager
	CacheManager           solver.CacheManager
	ContentStore           *containerdsnapshot.Store
	LeaseManager           *leaseutil.Manager
	Entitlements           []string
	EngineName             string
	Frontends              map[string]frontend.Frontend
	TraceCollector         trace.SpanExporter
	UpstreamCacheExporters map[string]remotecache.ResolveCacheExporterFunc
	UpstreamCacheImporters map[string]remotecache.ResolveCacheImporterFunc
	DNSConfig              *oci.DNSConfig
}

type DaggerServer

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

func NewDaggerServer

func NewDaggerServer(
	ctx context.Context,
	bkClient *buildkit.Client,
	worker bkworker.Worker,
	caller bksession.Caller,
	serverID string,
	secretStore *core.SecretStore,
	authProvider *auth.RegistryAuthProvider,
	rootLabels []pipeline.Label,
) (*DaggerServer, error)

func (*DaggerServer) Close

func (srv *DaggerServer) Close()

func (*DaggerServer) HTTPHandlerForClient

func (srv *DaggerServer) HTTPHandlerForClient(clientMetadata *engine.ClientMetadata, conn net.Conn, lg *logrus.Entry) (http.Handler, <-chan struct{}, error)

func (*DaggerServer) LogMetrics

func (srv *DaggerServer) LogMetrics(l *logrus.Entry) *logrus.Entry

func (*DaggerServer) ServeClientConn

func (srv *DaggerServer) ServeClientConn(
	ctx context.Context,
	clientMetadata *engine.ClientMetadata,
	conn net.Conn,
) error

func (*DaggerServer) Wait

func (srv *DaggerServer) Wait(ctx context.Context) error