aggregator

Nov 19, 2025

Changes in this version

type AggregatedCapabilities

+ CompositeTools []vmcp.Tool

type BackendDiscoverer

+ func NewBackendDiscoverer(ctx context.Context, groupsManager groups.Manager, ...) (BackendDiscoverer, error)

+ func NewBackendDiscovererWithManager(workloadManager workloads.Discoverer, groupsManager groups.Manager, ...) BackendDiscoverer

+ func NewUnifiedBackendDiscoverer(workloadsManager workloads.Discoverer, groupsManager groups.Manager, ...) BackendDiscoverer

Nov 3, 2025

Changes in this version

type ConflictResolver

+ func NewConflictResolver(aggregationConfig *config.AggregationConfig) (ConflictResolver, error)

+ type ManualConflictResolver struct

+ Overrides map[string]*config.ToolOverride

+ func NewManualConflictResolver(workloadConfigs []*config.WorkloadToolConfig) (*ManualConflictResolver, error)

+ func (r *ManualConflictResolver) ResolveToolConflicts(_ context.Context, toolsByBackend map[string][]vmcp.Tool) (map[string]*ResolvedTool, error)

+ type PrefixConflictResolver struct

+ PrefixFormat string

+ func NewPrefixConflictResolver(prefixFormat string) *PrefixConflictResolver

+ func (r *PrefixConflictResolver) ResolveToolConflicts(_ context.Context, toolsByBackend map[string][]vmcp.Tool) (map[string]*ResolvedTool, error)

+ type PriorityConflictResolver struct

+ PriorityOrder []string

+ func NewPriorityConflictResolver(priorityOrder []string) (*PriorityConflictResolver, error)

+ func (r *PriorityConflictResolver) ResolveToolConflicts(_ context.Context, toolsByBackend map[string][]vmcp.Tool) (map[string]*ResolvedTool, error)

Oct 30, 2025

Changes in this version

+ var ErrBackendQueryFailed = fmt.Errorf("failed to query backend capabilities")

+ var ErrInvalidConflictStrategy = fmt.Errorf("invalid conflict resolution strategy")

+ var ErrNoBackendsFound = fmt.Errorf("no backends found in group")

+ var ErrUnresolvedConflicts = fmt.Errorf("unresolved capability name conflicts")

+ type AggregatedCapabilities struct

+ Metadata *AggregationMetadata

+ Prompts []vmcp.Prompt

+ Resources []vmcp.Resource

+ RoutingTable *vmcp.RoutingTable

+ SupportsLogging bool

+ SupportsSampling bool

+ Tools []vmcp.Tool

+ type AggregationMetadata struct

+ BackendCount int

+ ConflictStrategy vmcp.ConflictResolutionStrategy

+ ConflictsResolved int

+ PromptCount int

+ ResourceCount int

+ ToolCount int

+ type Aggregator interface

+ AggregateCapabilities func(ctx context.Context, backends []vmcp.Backend) (*AggregatedCapabilities, error)

+ MergeCapabilities func(ctx context.Context, resolved *ResolvedCapabilities, ...) (*AggregatedCapabilities, error)

+ QueryAllCapabilities func(ctx context.Context, backends []vmcp.Backend) (map[string]*BackendCapabilities, error)

+ QueryCapabilities func(ctx context.Context, backend vmcp.Backend) (*BackendCapabilities, error)

+ ResolveConflicts func(ctx context.Context, capabilities map[string]*BackendCapabilities) (*ResolvedCapabilities, error)

+ func NewDefaultAggregator(backendClient vmcp.BackendClient) Aggregator

+ type BackendCapabilities struct

+ BackendID string

+ Prompts []vmcp.Prompt

+ Resources []vmcp.Resource

+ SupportsLogging bool

+ SupportsSampling bool

+ Tools []vmcp.Tool

+ type BackendDiscoverer interface

+ Discover func(ctx context.Context, groupRef string) ([]vmcp.Backend, error)

+ func NewCLIBackendDiscoverer(workloadsManager workloads.Manager, groupsManager groups.Manager) BackendDiscoverer

+ func NewK8sBackendDiscoverer() BackendDiscoverer

+ type ConflictResolver interface

+ ResolveToolConflicts func(ctx context.Context, tools map[string][]vmcp.Tool) (map[string]*ResolvedTool, error)

+ type ResolvedCapabilities struct

+ Prompts []vmcp.Prompt

+ Resources []vmcp.Resource

+ SupportsLogging bool

+ SupportsSampling bool

+ Tools map[string]*ResolvedTool

+ type ResolvedTool struct

+ BackendID string

+ ConflictResolutionApplied vmcp.ConflictResolutionStrategy

+ Description string

+ InputSchema map[string]any

+ OriginalName string

+ ResolvedName string

+ type ToolFilter interface

+ FilterTools func(ctx context.Context, tools []vmcp.Tool) ([]vmcp.Tool, error)

+ type ToolOverride interface

+ ApplyOverrides func(ctx context.Context, tools []vmcp.Tool) ([]vmcp.Tool, error)