server

package

v0.9.10 Latest Latest Go to latest Published: Feb 12, 2024 License: Apache-2.0 Imports: 50 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dagger/dagger

Links

Open Source Insights

Documentation ¶

Index ¶

type BuildkitController
- func NewBuildkitController(opts BuildkitControllerOpts) (*BuildkitController, error)
type BuildkitControllerOpts
type DaggerServer
- func NewDaggerServer(ctx context.Context, bkClient *buildkit.Client, worker bkworker.Worker, ...) (*DaggerServer, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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,
	cloudToken string,
	doNotTrack bool,
) (*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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL