federation

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 26, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentRegistration added in v1.0.0

type AgentRegistration struct {
	ID           string
	Name         string
	Endpoint     string
	Capabilities []string
	Organization string
	Metadata     map[string]string
}

AgentRegistration is the local representation for registering an agent.

type BridgeConfig added in v1.0.0

type BridgeConfig struct {
	SyncInterval time.Duration // how often to sync all nodes
	AutoSync     bool          // auto-sync on node registration
}

BridgeConfig holds configuration for the DiscoveryBridge.

func DefaultBridgeConfig added in v1.0.0

func DefaultBridgeConfig() BridgeConfig

DefaultBridgeConfig returns a BridgeConfig with sensible defaults.

type DiscoveryBridge added in v1.0.0

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

DiscoveryBridge syncs federated nodes with the discovery registry.

func NewDiscoveryBridge added in v1.0.0

func NewDiscoveryBridge(
	orchestrator *Orchestrator,
	registry DiscoveryRegistry,
	config BridgeConfig,
	logger *zap.Logger,
) *DiscoveryBridge

NewDiscoveryBridge creates a new DiscoveryBridge.

func (*DiscoveryBridge) Start added in v1.0.0

func (b *DiscoveryBridge) Start(ctx context.Context) error

Start begins periodic sync and auto-sync on node changes.

func (*DiscoveryBridge) Stop added in v1.0.0

func (b *DiscoveryBridge) Stop()

Stop stops the bridge. It is safe to call multiple times.

func (*DiscoveryBridge) SyncAllNodes added in v1.0.0

func (b *DiscoveryBridge) SyncAllNodes(ctx context.Context) error

SyncAllNodes syncs all known federated nodes to discovery.

func (*DiscoveryBridge) SyncNode added in v1.0.0

func (b *DiscoveryBridge) SyncNode(ctx context.Context, node *FederatedNode) error

SyncNode registers a single federated node's capabilities in discovery.

type DiscoveryRegistry added in v1.0.0

type DiscoveryRegistry interface {
	RegisterAgent(ctx context.Context, info *AgentRegistration) error
	UnregisterAgent(ctx context.Context, agentID string) error
	UpdateAgentStatus(ctx context.Context, agentID string, status string) error
}

DiscoveryRegistry is a local interface matching the subset of discovery.CapabilityRegistry needed for federation sync. Using local interface pattern (§15).

type DiscoveryRegistryAdapter added in v1.0.0

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

DiscoveryRegistryAdapter adapts discovery.DiscoveryService to the DiscoveryRegistry interface used by the federation bridge.

func NewDiscoveryRegistryAdapter added in v1.0.0

func NewDiscoveryRegistryAdapter(service *discovery.DiscoveryService) *DiscoveryRegistryAdapter

NewDiscoveryRegistryAdapter creates a new adapter wrapping the given DiscoveryService.

func (*DiscoveryRegistryAdapter) RegisterAgent added in v1.0.0

func (a *DiscoveryRegistryAdapter) RegisterAgent(ctx context.Context, info *AgentRegistration) error

RegisterAgent converts an AgentRegistration to discovery.AgentInfo and registers it via the discovery service.

func (*DiscoveryRegistryAdapter) UnregisterAgent added in v1.0.0

func (a *DiscoveryRegistryAdapter) UnregisterAgent(ctx context.Context, agentID string) error

UnregisterAgent removes an agent from the discovery service.

func (*DiscoveryRegistryAdapter) UpdateAgentStatus added in v1.0.0

func (a *DiscoveryRegistryAdapter) UpdateAgentStatus(ctx context.Context, agentID string, status string) error

UpdateAgentStatus updates an agent's status in the discovery registry.

type FederatedNode

type FederatedNode struct {
	ID           string            `json:"id"`
	Name         string            `json:"name"`
	Endpoint     string            `json:"endpoint"`
	PublicKey    string            `json:"public_key,omitempty"`
	Capabilities []string          `json:"capabilities"`
	Metadata     map[string]string `json:"metadata,omitempty"`
	Status       NodeStatus        `json:"status"`
	LastSeen     time.Time         `json:"last_seen"`
}

联邦 节点代表联邦的一个节点.

type FederatedTask

type FederatedTask struct {
	ID           string         `json:"id"`
	Type         string         `json:"type"`
	Payload      any            `json:"payload"`
	SourceNode   string         `json:"source_node"`
	TargetNodes  []string       `json:"target_nodes,omitempty"`
	Priority     int            `json:"priority"`
	Timeout      time.Duration  `json:"timeout"`
	RequiredCaps []string       `json:"required_capabilities,omitempty"`
	CreatedAt    time.Time      `json:"created_at"`
	Status       TaskStatus     `json:"status"`
	Results      map[string]any `json:"results,omitempty"`
}

联邦 这项任务是分配给各联邦的任务。

type FederationConfig

type FederationConfig struct {
	NodeID            string
	NodeName          string
	ListenAddr        string
	TLSConfig         *tls.Config
	HeartbeatInterval time.Duration
	TaskTimeout       time.Duration
}

Federation Config配置了联邦管弦乐团.

type NodeStatus

type NodeStatus string

节点状态代表一个联邦节点的地位.

const (
	NodeStatusOnline   NodeStatus = "online"
	NodeStatusOffline  NodeStatus = "offline"
	NodeStatusDegraded NodeStatus = "degraded"
)

type Orchestrator

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

Orchestrator管理联邦代理合作.

func NewOrchestrator

func NewOrchestrator(config FederationConfig, logger *zap.Logger) *Orchestrator

新奥尔良创造了一个新的联邦管弦乐团.

func (*Orchestrator) GetTask

func (o *Orchestrator) GetTask(taskID string) (*FederatedTask, bool)

GetTask 以 ID 检索任务 。

func (*Orchestrator) ListNodes

func (o *Orchestrator) ListNodes() []*FederatedNode

ListNodes 返回所有已注册的节点 。

func (*Orchestrator) RegisterHandler

func (o *Orchestrator) RegisterHandler(taskType string, handler TaskHandler)

登记 Handler 登记任务处理器 。

func (*Orchestrator) RegisterNode

func (o *Orchestrator) RegisterNode(node *FederatedNode)

注册点在联邦登记一个节点。

func (*Orchestrator) SetOnNodeRegister added in v1.0.0

func (o *Orchestrator) SetOnNodeRegister(fn func(node *FederatedNode))

SetOnNodeRegister sets a callback invoked after a node is registered.

func (*Orchestrator) SetOnNodeStatusChange added in v1.0.0

func (o *Orchestrator) SetOnNodeStatusChange(fn func(nodeID string, status NodeStatus))

SetOnNodeStatusChange sets a callback invoked when a node's status changes.

func (*Orchestrator) SetOnNodeUnregister added in v1.0.0

func (o *Orchestrator) SetOnNodeUnregister(fn func(nodeID string))

SetOnNodeUnregister sets a callback invoked after a node is unregistered.

func (*Orchestrator) Start

func (o *Orchestrator) Start(ctx context.Context) error

开始指挥

func (*Orchestrator) Stop

func (o *Orchestrator) Stop()

停止停止指挥器。

func (*Orchestrator) SubmitTask

func (o *Orchestrator) SubmitTask(ctx context.Context, task *FederatedTask) error

向联邦提交任务。

func (*Orchestrator) UnregisterNode

func (o *Orchestrator) UnregisterNode(nodeID string)

UnregisterNode从联邦中删除一个节点.

type TaskHandler

type TaskHandler func(ctx context.Context, task *FederatedTask) (any, error)

特劳斯·汉德勒处理联邦任务.

type TaskStatus

type TaskStatus string

任务状态代表联合任务状态.

const (
	TaskStatusPending   TaskStatus = "pending"
	TaskStatusRunning   TaskStatus = "running"
	TaskStatusCompleted TaskStatus = "completed"
	TaskStatusFailed    TaskStatus = "failed"
)

Jump to

Keyboard shortcuts

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