opencodehost

package

v2.25.0 Latest Latest Go to latest Published: Nov 1, 2026 License: GPL-3.0 Imports: 22 Imported by: 0

Details

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

Repository

github.com/dagucloud/dagu

Links

Open Source Insights

Documentation ¶

Index ¶

func DAGUsesManaged(dag *ir.DAG) bool
func DeleteSession(ctx context.Context, hostConfig Config, directory, sessionID string) error
func SessionAvailable(ctx context.Context, hostConfig Config, directory, sessionID string) (bool, error)
func SharingDisabled(value any) bool
func UnavailableEnv(err error) []string
func WithHost(ctx context.Context, host *Host) context.Context
type Config
- func ConfigFromContext(ctx context.Context) (Config, bool, error)
- func (c Config) Env() []string
- func (c Config) IsV2() bool
type Host
- func New(parent context.Context, settings config.OpenCodeConfig) *Host
- func (h *Host) Close(ctx context.Context) error
- func (h *Host) Ensure() (Config, error)
type ModeResult
- func Mode(values map[string]any) (ModeResult, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DAGUsesManaged ¶

func DAGUsesManaged(dag *ir.DAG) bool

DAGUsesManaged reports whether a DAG has a host-compatible managed OpenCode step.

func DeleteSession ¶

func DeleteSession(ctx context.Context, hostConfig Config, directory, sessionID string) error

DeleteSession removes a host-owned OpenCode session after its DAG run is removed.

func SessionAvailable ¶

func SessionAvailable(ctx context.Context, hostConfig Config, directory, sessionID string) (bool, error)

SessionAvailable reports whether a managed session exists in directory.

func SharingDisabled ¶

func SharingDisabled(value any) bool

SharingDisabled checks the effective sharing setting in either API's config response. V2 returns ordered documents; the last defined value wins.

func UnavailableEnv ¶

func UnavailableEnv(err error) []string

UnavailableEnv returns a private transport error for a required managed step.

func WithHost ¶

func WithHost(ctx context.Context, host *Host) context.Context

WithHost makes a managed OpenCode host available to runtime executors.

Types ¶

type Config ¶

type Config struct {
	URL        string
	Username   string
	Password   string
	InstanceID string
	Version    string
}

Config contains the private loopback connection used by managed harness steps.

func ConfigFromContext ¶

func ConfigFromContext(ctx context.Context) (Config, bool, error)

ConfigFromContext resolves a host-owned or process-injected connection.

func (Config) Env ¶

func (c Config) Env() []string

Env returns the private transport entries needed by a child Dagu process.

func (Config) IsV2 ¶

func (c Config) IsV2() bool

IsV2 reports whether the host uses the OpenCode v2 HTTP protocol.

type Host ¶

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

Host lazily owns one OpenCode server process.

func New ¶

func New(parent context.Context, settings config.OpenCodeConfig) *Host

New creates an idle host whose lifecycle ends with parent.

func (*Host) Close ¶

func (h *Host) Close(ctx context.Context) error

Close stops the managed server.

func (*Host) Ensure ¶

func (h *Host) Ensure() (Config, error)

Ensure returns a healthy managed server, starting it when necessary.

type ModeResult ¶

type ModeResult struct {
	Managed  bool
	Required bool
	Reason   string
}

ModeResult describes how an OpenCode harness config should run.

func Mode ¶

func Mode(values map[string]any) (ModeResult, error)

Mode reports whether an OpenCode harness config can use the managed service.

Source Files ¶

View all Source files

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