upstream

type ConnectionStatus string

type DiscoveredTool struct {
	// Name is the tool's unique identifier.
	Name string
	// Description is the human-readable tool description.
	Description string
	// InputSchema is the JSON Schema for the tool's parameters.
	InputSchema json.RawMessage
	// UpstreamID identifies which upstream this tool was discovered from.
	UpstreamID string
	// UpstreamName is the human-readable name of the upstream.
	UpstreamName string
	// DiscoveredAt records when this tool was discovered.
	DiscoveredAt time.Time
}

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

type ToolConflict struct {
	// ToolName is the conflicting tool name.
	ToolName string
	// SkippedUpstreamID is the ID of the upstream whose tool was skipped.
	SkippedUpstreamID string
	// SkippedUpstreamName is the human-readable name of the skipped upstream.
	SkippedUpstreamName string
	// WinnerUpstreamID is the ID of the upstream that owns the winning tool.
	WinnerUpstreamID string
	// WinnerUpstreamName is the human-readable name of the winning upstream.
	WinnerUpstreamName string
}

type Upstream struct {
	// ID is the unique identifier (UUID).
	ID string
	// Name is the human-readable display name (unique).
	Name string
	// Type is the transport type: stdio or http.
	Type UpstreamType
	// Enabled indicates whether this upstream is active.
	Enabled bool
	// Command is the executable path (stdio only).
	Command string
	// Args are the command-line arguments (stdio only).
	Args []string
	// URL is the endpoint (HTTP only).
	URL string
	// Env holds environment variables passed to stdio upstreams.
	Env map[string]string

	// Status is the runtime connection state (not persisted).
	Status ConnectionStatus
	// LastError is the most recent error message (not persisted).
	LastError string
	// ToolCount is the number of tools discovered (not persisted).
	ToolCount int

	// CreatedAt is when this upstream was added.
	CreatedAt time.Time
	// UpdatedAt is when this upstream was last modified.
	UpdatedAt time.Time
}

type UpstreamStore interface {
	// List returns all configured upstreams.
	List(ctx context.Context) ([]Upstream, error)
	// Get returns a single upstream by ID.
	// Returns ErrUpstreamNotFound if the upstream does not exist.
	Get(ctx context.Context, id string) (*Upstream, error)
	// Add stores a new upstream.
	Add(ctx context.Context, upstream *Upstream) error
	// Update replaces an existing upstream.
	// Returns ErrUpstreamNotFound if the upstream does not exist.
	Update(ctx context.Context, upstream *Upstream) error
	// Delete removes an upstream by ID.
	// Returns ErrUpstreamNotFound if the upstream does not exist.
	Delete(ctx context.Context, id string) error
}

type UpstreamType string