streamrun

package
v0.182.6 Latest Latest
Warning

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

Go to latest
Published: Oct 6, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package streamrun binds existing stream engines to WB's native operations. It accepts plain requests and never constructs CLI commands.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SessionIdentity

func SessionIdentity() string

Types

type Config

type Config struct {
	Machine    func(string) (string, error)
	Login      func() (string, error)
	Executable func() string
}

Config binds private root identity resolution and the verified hook executable.

type Creation

type Creation struct {
	ProjectsRoot    string
	Base            string
	WorkLog         worktrees.WorkLogOptions
	SessionRequired bool
}

Creation carries the already prepared task provenance for a native operation.

type Service

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

Service keeps immutable bindings; every operation builds fresh native state.

func New

func New(config Config) *Service

New binds production methods without retaining execution-specific options.

func (*Service) Delete

func (service *Service) Delete(root, name string) error

func (*Service) End

func (service *Service) End(ctx context.Context, root string, options streams.EndOptions) (streams.EndResult, error)

func (*Service) Identity

func (service *Service) Identity(root string) (login, machine string)

func (*Service) Join

func (service *Service) Join(ctx context.Context, request Creation, options streams.JoinOptions) (streams.StartResult, error)

func (*Service) List

func (service *Service) List(_ context.Context, root string) ([]streams.Stream, []streams.Unreadable, error)

func (*Service) Start

func (service *Service) Start(ctx context.Context, request Creation, options streams.StartOptions) (streams.StartResult, error)

Start preserves graph reporting after successful native creation.

func (*Service) Status

func (service *Service) Status(ctx context.Context, root, name string) (streams.Status, error)

func (*Service) Sync

func (service *Service) Sync(ctx context.Context, request SyncRequest) ([]streamsync.Result, error)

type SyncRefusal

type SyncRefusal struct {
	Repository string
	Refusal    *streamsync.Refusal
}

SyncRefusal qualifies an existing engine refusal with its affected member.

func (*SyncRefusal) Error

func (refusal *SyncRefusal) Error() string

func (*SyncRefusal) Unwrap

func (refusal *SyncRefusal) Unwrap() error

type SyncRequest

type SyncRequest struct {
	ProjectsRoot, Name, Base string
	Libraries                []streamsync.Library
	Verify, AllowMidReview   bool
	PushTrigger              streamsync.PushTrigger
	PushReason               string
	Timeout                  time.Duration
}

SyncRequest carries one parsed reconciliation request.

Jump to

Keyboard shortcuts

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