sidecar

type Config struct {
	Socket            string
	HeartbeatInterval time.Duration
	HeartbeatTimeout  time.Duration
	NativeProxyPort   int      // proxy listen port; excluded from sidecar early_claim ranges
	ReservedNames     []string // built-in adapter names sidecars may not reuse
	// ScopeCheck gates dial_upstream destinations; nil allows any host.
	ScopeCheck func(host string) (allowed bool, reason string)
	// DialTimeout bounds each dial_upstream connection attempt.
	DialTimeout time.Duration
	// NativeHTTPSend originates an outbound HTTP request through the in-process
	// proxy on a sidecar's behalf; nil disables native origination.
	NativeHTTPSend func(ctx context.Context, p wire.SidecarSendParams, invokedBy string) (wire.SidecarSendResult, *wire.Error)
}

type CoreService interface {
	// CoreInvoke dispatches a core MCP tool by name.
	CoreInvoke(ctx context.Context, tool string, params json.RawMessage) (content string, isErr bool, err error)
	// CoreToolNames lists core tool names for registration-time collision checks.
	CoreToolNames() []string
}

type FlowSink interface {
	Store(*types.Flow) string
	Complete(flowID string, resp *types.Message, completedAt time.Time, annotations map[string]any) bool
	SetInvokedBy(flowID, invokedBy string) bool
	Get(flowID string) (*types.Flow, bool)
	ShouldCapture(*types.Flow) bool
}

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

type Liveness struct {
	LastPongRecv time.Time
}

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

type Record struct {
	Name         string
	ProtoVersion wire.ProtocolVersion
	Protocols    []string
	Capabilities wire.Capabilities
	MCPTools     []wire.MCPTool // tool definitions the sidecar provides
	InstanceID   string
	// contains filtered or unexported fields
}

type RuleSource interface {
	// RuleSnapshot returns the monotonic version and rules scoped to the adapter.
	RuleSnapshot(adapter string) (version uint64, rules []wire.Rule)
}