httpapi

Documentation

Index

• Constants
• func HandlerForSQLite(ctx context.Context, dsn string, offer []domain.OfferSnapshot) (http.Handler, func() error, error)
• func HandlerForSQLiteWithAdapter(ctx context.Context, dsn string, ad adapter.Adapter, options ...Option) (http.Handler, func() error, error)
• func HandlerForSQLiteWithOptions(ctx context.Context, dsn string, offer []domain.OfferSnapshot, ...) (http.Handler, func() error, error)
• func New(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, ...) http.Handler
• func NewWithAllServices(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, ...) http.Handler
• func NewWithServices(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, ...) http.Handler
• type Option
  • func WithBearerAuth(token string, workspaces []string) Option
  • func WithCredentialResolver(resolver *credential.Resolver) Option
  • func WithReportSigner(signer *reporting.Signer) Option
  • func WithSecretStore(store credential.SecretStore) Option
  • func WithVerifier(verifier connectionVerifier) Option
• type Server
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const OpenAPIJSON = `` /* 21356-byte string literal not displayed */

Functions

func HandlerForSQLite

func HandlerForSQLite(ctx context.Context, dsn string, offer []domain.OfferSnapshot) (http.Handler, func() error, error)

func HandlerForSQLiteWithAdapter

func HandlerForSQLiteWithAdapter(ctx context.Context, dsn string, ad adapter.Adapter, options ...Option) (http.Handler, func() error, error)

func HandlerForSQLiteWithOptions

func HandlerForSQLiteWithOptions(ctx context.Context, dsn string, offer []domain.OfferSnapshot, options ...Option) (http.Handler, func() error, error)

func New

func New(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, options ...Option) http.Handler

func NewWithAllServices

func NewWithAllServices(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, workloads *workload.Service, sinkManager *sinkspkg.Manager, conns *connection.Service, offerService *offers.Service, resolver interface {
	Resolve(context.Context, ociresolver.ResolveRequest) (ociresolver.ResolvedImage, error)
}, options ...Option) http.Handler

func NewWithServices

func NewWithServices(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, workloads *workload.Service, resolver interface {
	Resolve(context.Context, ociresolver.ResolveRequest) (ociresolver.ResolvedImage, error)
}, options ...Option) http.Handler

Types

type Option

type Option func(*Server)

func WithBearerAuth

func WithBearerAuth(token string, workspaces []string) Option

func WithCredentialResolver

func WithCredentialResolver(resolver *credential.Resolver) Option

WithCredentialResolver wires the credential.Resolver the server uses to turn a {source, ref} credential into a plaintext secret.

func WithReportSigner

func WithReportSigner(signer *reporting.Signer) Option

WithReportSigner wires the per-run token signer used to authenticate the POST /v1/runs/{id}:report ingest endpoint.

func WithSecretStore

func WithSecretStore(store credential.SecretStore) Option

WithSecretStore wires the SecretStore the server uses to persist sealed connection credentials.

func WithVerifier

func WithVerifier(verifier connectionVerifier) Option

WithVerifier wires the connection verifier (the Broker) the server uses to validate a connection during the authorize flow.

type Server

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

func (*Server) ServeHTTP

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