Documentation
¶
Overview ¶
Package streamrun binds existing stream engines to WB's native operations. It accepts plain requests and never constructs CLI commands.
Index ¶
- func SessionIdentity() string
- type Config
- type Creation
- type Service
- func (service *Service) Delete(root, name string) error
- func (service *Service) End(ctx context.Context, root string, options streams.EndOptions) (streams.EndResult, error)
- func (service *Service) Identity(root string) (login, machine string)
- func (service *Service) Join(ctx context.Context, request Creation, options streams.JoinOptions) (streams.StartResult, error)
- func (service *Service) List(_ context.Context, root string) ([]streams.Stream, []streams.Unreadable, error)
- func (service *Service) Start(ctx context.Context, request Creation, options streams.StartOptions) (streams.StartResult, error)
- func (service *Service) Status(ctx context.Context, root, name string) (streams.Status, error)
- func (service *Service) Sync(ctx context.Context, request SyncRequest) ([]streamsync.Result, error)
- type SyncRefusal
- type SyncRequest
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 (*Service) Join ¶
func (service *Service) Join(ctx context.Context, request Creation, options streams.JoinOptions) (streams.StartResult, 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) 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.
Click to show internal directories.
Click to hide internal directories.