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) 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 (s *DaggerServer) ClientCallContext(clientDigest digest.Digest) (*core.ClientCallContext, bool)
  • func (s *DaggerServer) Close(ctx context.Context) error
  • func (s *DaggerServer) CurrentServedDeps(ctx context.Context) (*core.ModDeps, error)
  • func (s *DaggerServer) LogMetrics(l *logrus.Entry) *logrus.Entry
  • func (s *DaggerServer) RegisterClient(clientID, clientHostname, secretToken string) error
  • func (s *DaggerServer) ServeClientConn(ctx context.Context, clientMetadata *engine.ClientMetadata, conn net.Conn) error
  • func (s *DaggerServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (s *DaggerServer) VerifyClient(clientID, secretToken string) error
  • func (s *DaggerServer) Wait(ctx context.Context) error

Types

type BuildkitController

type BuildkitController struct {
	BuildkitControllerOpts
	// 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) 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)

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
	TelemetryPubSub        *telemetry.PubSub
	UpstreamCacheExporters map[string]remotecache.ResolveCacheExporterFunc
	UpstreamCacheImporters map[string]remotecache.ResolveCacheImporterFunc
	DNSConfig              *oci.DNSConfig
	BuildkitLogSink        io.Writer
}

type DaggerServer

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

func (*DaggerServer) ClientCallContext

func (s *DaggerServer) ClientCallContext(clientDigest digest.Digest) (*core.ClientCallContext, bool)

func (*DaggerServer) Close

func (s *DaggerServer) Close(ctx context.Context) error

func (*DaggerServer) CurrentServedDeps

func (s *DaggerServer) CurrentServedDeps(ctx context.Context) (*core.ModDeps, error)

func (*DaggerServer) LogMetrics

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

func (*DaggerServer) RegisterClient

func (s *DaggerServer) RegisterClient(clientID, clientHostname, secretToken string) error

func (*DaggerServer) ServeClientConn

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

func (*DaggerServer) ServeHTTP

func (s *DaggerServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*DaggerServer) VerifyClient

func (s *DaggerServer) VerifyClient(clientID, secretToken string) error

func (*DaggerServer) Wait

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