session

package

v0.7.3 Latest Latest Go to latest Published: Aug 11, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

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

Repository

github.com/uvwt/agentdock

Links

Open Source Insights

Documentation ¶

Rendered for

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CommandFactory ¶

type CommandFactory func(context.Context) *exec.Cmd

type ExecutionContext ¶

type ExecutionContext struct {
	Runtime      string
	Distribution string
	Workdir      string
}

type PrepareFunc ¶

type PrepareFunc func(*exec.Cmd) (func(), map[string]any)

type Session ¶

type Session struct {
	ID         string
	Command    *exec.Cmd
	Cancel     context.CancelFunc
	Stdin      io.WriteCloser
	StartedAt  time.Time
	FinishedAt time.Time
	Done       chan struct{}
	TimedOut   bool
	Terminal   string
	// contains filtered or unexported fields
}

func Start ¶

func Start(ctx context.Context, command, workdir string, env []string, timeout time.Duration, prepare PrepareFunc) (*Session, map[string]any, error)

func StartCommandWithTTY ¶

func StartCommandWithTTY(ctx context.Context, build CommandFactory, timeout time.Duration, tty bool, prepare PrepareFunc) (*Session, map[string]any, error)

func StartWithTTY ¶

func StartWithTTY(ctx context.Context, command, workdir string, env []string, timeout time.Duration, tty bool, prepare PrepareFunc) (*Session, map[string]any, error)

func (*Session) CloseStdin ¶

func (s *Session) CloseStdin() error

func (*Session) Completed ¶

func (s *Session) Completed() bool

func (*Session) CompletedBefore ¶

func (s *Session) CompletedBefore(cutoff time.Time) bool

func (*Session) Kill ¶

func (s *Session) Kill() bool

func (*Session) Peek ¶

func (s *Session) Peek(status string, maxBytes int) map[string]any

Peek returns the current unread output without advancing the observation cursors. Mutation tools use it so a following status call still receives the output.

func (*Session) SetExecutionContext ¶

func (s *Session) SetExecutionContext(execution ExecutionContext)

func (*Session) Snapshot ¶

func (s *Session) Snapshot(status string, maxBytes int) map[string]any

func (*Session) Summary ¶

func (s *Session) Summary() Summary

func (*Session) WaitError ¶

func (s *Session) WaitError() error

func (*Session) Write ¶

func (s *Session) Write(text string) error

type Store ¶

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

func NewStore ¶

func NewStore() *Store

func (*Store) Add ¶

func (s *Store) Add(session *Session)

func (*Store) AddReserved ¶

func (s *Store) AddReserved(session *Session)

func (*Store) Delete ¶

func (s *Store) Delete(id string)

func (*Store) Get ¶

func (s *Store) Get(id string) (*Session, bool)

func (*Store) List ¶

func (s *Store) List() []*Session

func (*Store) PruneCompletedBefore ¶

func (s *Store) PruneCompletedBefore(cutoff time.Time) int

func (*Store) PruneCompletedToLimit ¶

func (s *Store) PruneCompletedToLimit(limit int) int

func (*Store) ReleaseReservation ¶

func (s *Store) ReleaseReservation()

func (*Store) ReservationCount ¶

func (s *Store) ReservationCount() int

func (*Store) TryReserve ¶

func (s *Store) TryReserve(maxRunning int) bool

type Summary ¶

type Summary struct {
	ID           string `json:"id"`
	Status       string `json:"status"`
	ElapsedMS    int64  `json:"elapsed_ms"`
	TimedOut     bool   `json:"timed_out"`
	Runtime      string `json:"runtime,omitempty"`
	Distribution string `json:"wsl_distribution,omitempty"`
	Workdir      string `json:"workdir,omitempty"`
}

Source Files ¶

View all Source files

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