Documentation
¶
Index ¶
- Constants
- type BuildkitController
- 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 (srv *DaggerServer) Close()
- func (srv *DaggerServer) HTTPHandlerForClient(clientMetadata *engine.ClientMetadata) http.Handler
- 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
- type Handler
- type HandlerConfig
- type RequestOptions
- type ResultCallbackFn
- type RootObjectFn
Constants ¶
View Source
const ( ContentTypeJSON = "application/json" ContentTypeGraphQL = "application/graphql" ContentTypeFormURLEncoded = "application/x-www-form-urlencoded" )
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 }
type DaggerServer ¶
type DaggerServer struct {
// contains filtered or unexported fields
}
func NewDaggerServer ¶
func (*DaggerServer) Close ¶
func (srv *DaggerServer) Close()
func (*DaggerServer) HTTPHandlerForClient ¶
func (srv *DaggerServer) HTTPHandlerForClient(clientMetadata *engine.ClientMetadata) http.Handler
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
type Handler ¶
func NewHandler ¶
func NewHandler(p *HandlerConfig) *Handler
func (*Handler) ContextHandler ¶
ContextHandler provides an entrypoint into executing graphQL queries with a user-provided context.
type HandlerConfig ¶
type HandlerConfig struct { Schema *graphql.Schema Pretty bool RootObjectFn RootObjectFn ResultCallbackFn ResultCallbackFn FormatErrorFn func(err error) gqlerrors.FormattedError }
func NewConfig ¶
func NewConfig() *HandlerConfig
type RequestOptions ¶
type RequestOptions struct { Query string `json:"query" url:"query" schema:"query"` Variables map[string]interface{} `json:"variables" url:"variables" schema:"variables"` OperationName string `json:"operationName" url:"operationName" schema:"operationName"` }
func NewRequestOptions ¶
func NewRequestOptions(r *http.Request) *RequestOptions
RequestOptions Parses a http.Request into GraphQL request options struct
type ResultCallbackFn ¶
Click to show internal directories.
Click to hide internal directories.