spindle

package

v1.16.1-alpha Latest Latest Go to latest Published: Jul 17, 2026 License: MIT Imports: 62 Imported by: 0

Details

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

Repository

tangled.org/@tangled.org/core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Run(ctx context.Context) error
type Ingester
type Spindle
- func New(ctx context.Context, cfg *config.Config, d *db.DB, ...) (*Spindle, error)
type Tap
- func NewTapClient(s *Spindle) *Tap
- func (t *Tap) AddOwnerDIDs(ctx context.Context, dids []syntax.DID) error
- func (t *Tap) Start(connCtx context.Context)

Constants ¶

View Source

const RequiredVersion = "2.49.0"

Variables ¶

This section is empty.

Functions ¶

func Run ¶

func Run(ctx context.Context) error

Types ¶

type Ingester ¶

type Ingester func(ctx context.Context, e *models.Event) error

type Spindle ¶

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

func New ¶

func New(ctx context.Context, cfg *config.Config, d *db.DB, engines map[string]models.Engine) (*Spindle, error)

New creates a new Spindle server with the provided configuration and engines.

func (*Spindle) DB ¶

func (s *Spindle) DB() *db.DB

DB returns the database instance.

func (*Spindle) Enforcer ¶

func (s *Spindle) Enforcer() *rbac.Enforcer

Enforcer returns the RBAC enforcer instance.

func (*Spindle) Engines ¶

func (s *Spindle) Engines() map[string]models.Engine

Engines returns the map of available engines.

func (*Spindle) Events ¶

func (s *Spindle) Events(w http.ResponseWriter, r *http.Request)

func (*Spindle) GetMotdContent ¶

func (s *Spindle) GetMotdContent() []byte

GetMotdContent returns the current MOTD content.

func (*Spindle) Logs ¶

func (s *Spindle) Logs(w http.ResponseWriter, r *http.Request)

func (*Spindle) Notifier ¶

func (s *Spindle) Notifier() *notifier.Notifier

Notifier returns the notifier instance.

func (*Spindle) Queue ¶

func (s *Spindle) Queue() *queue.Queue

Queue returns the job queue instance.

func (*Spindle) RequestLogger ¶

func (s *Spindle) RequestLogger(next http.Handler) http.Handler

func (*Spindle) Router ¶

func (s *Spindle) Router() http.Handler

func (*Spindle) SetMotdContent ¶

func (s *Spindle) SetMotdContent(content []byte)

SetMotdContent sets custom MOTD content, replacing the embedded default.

func (*Spindle) Start ¶

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

Start starts the Spindle server (blocking).

func (*Spindle) TriggerManual ¶

func (s *Spindle) TriggerManual(ctx context.Context, repoDid syntax.DID, sha, ref string, workflows []string, sourceRepo syntax.DID, pull xrpc.PullContext, inputs []*tangled.Pipeline_Pair) (syntax.ATURI, error)

TriggerManual dispatches a pipeline at sha, authorized against and recorded under repoDid. sourceRepo, pull, and inputs are optional trigger payload.

func (*Spindle) Vault ¶

func (s *Spindle) Vault() secrets.Manager

Vault returns the secrets manager instance.

func (*Spindle) XrpcRouter ¶

func (s *Spindle) XrpcRouter() http.Handler

type Tap ¶

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

func NewTapClient ¶

func NewTapClient(s *Spindle) *Tap

func (*Tap) AddOwnerDIDs ¶

func (t *Tap) AddOwnerDIDs(ctx context.Context, dids []syntax.DID) error

func (*Tap) Start ¶

func (t *Tap) Start(connCtx context.Context)

Source Files ¶

casbin_copy.go
embedtap.go
ingester.go
middleware.go
secret_copy.go
server.go
startup_migrations.go
stream.go
tap_drain.go
tapclient.go

Directories ¶

Path	Synopsis
agentproto
gen
config
db
engine
engines
dummy
microvm
nixery
git
models
queue
secrets an sqlite3 backed secret manager	an sqlite3 backed secret manager
xrpc

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