serve

package
v0.0.0-...-e1d2767 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Options

type Options struct {
	RunsDir            string
	RepoCacheDir       string
	DBTDriver          string
	WorkspaceArtifacts []string                // workspace-level keep_artifacts (nil = use default)
	WebhookPort        int                     // port for inbound webhook HTTP server (0 = use default 9090)
	MetaStore          engine.MetadataRecorder // nil = no metadata tracking
	MetaQueryStore     meta.Store              // for API query endpoints (can be same instance as MetaStore)
	APIToken           string                  // optional bearer token for /api/ endpoints (empty = no auth)
}

Options holds workspace-level settings passed from the CLI layer.

type Server

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

Server manages triggers and executes DAGs in response to events.

func NewServer

func NewServer(rootDir, secretsPath string, verbose bool, srvOpts Options) (*Server, error)

NewServer discovers projects, validates them, and registers triggers.

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start launches all triggers and processes events until the context is cancelled.

Jump to

Keyboard shortcuts

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