agent

package

v0.0.0-...-8f1971e Latest Latest Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 37 Imported by: 0

Details

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

Repository

github.com/kagent-dev/kagent

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ConvertMCPServerToRemoteMCPServer(mcpServer *v1alpha1.MCPServer) (*v1alpha2.RemoteMCPServer, error)
func ConvertServiceToRemoteMCPServer(svc *corev1.Service) (*v1alpha2.RemoteMCPServer, error)
func GetA2AAgentCard(agent *v1alpha2.Agent) *server.AgentCard
func NewValidationError(format string, args ...any) error
type AdkApiTranslator
- func NewAdkApiTranslator(kube client.Client, defaultModelConfig types.NamespacedName, ...) AdkApiTranslator
type AgentOutputs
type ImageConfig
- func (c ImageConfig) Image() string
type PromptTemplateContext
type TranslatorPlugin
type ValidationError
- func (e *ValidationError) Error() string
- func (e *ValidationError) Unwrap() error

Constants ¶

View Source

const (
	MCPServiceLabel              = "kagent.dev/mcp-service"
	MCPServicePathAnnotation     = "kagent.dev/mcp-service-path"
	MCPServicePortAnnotation     = "kagent.dev/mcp-service-port"
	MCPServiceProtocolAnnotation = "kagent.dev/mcp-service-protocol"

	MCPServicePathDefault     = "/mcp"
	MCPServiceProtocolDefault = v1alpha2.RemoteMCPServerProtocolStreamableHttp

	ProxyHostHeader = "x-kagent-host"

	// DefaultMCPServerTimeout is the fallback connection timeout applied when
	// an MCPServer CRD resource does not have an explicit Timeout set (e.g.
	// objects created before the field was introduced). This value mirrors
	// the kubebuilder default on MCPServerSpec.Timeout in the kmcp CRD.
	DefaultMCPServerTimeout = 30 * time.Second
)

View Source

const MAX_DEPTH = 10

Variables ¶

View Source

var DefaultImageConfig = ImageConfig{
	Registry:   "cr.kagent.dev",
	Tag:        version.Get().Version,
	PullPolicy: string(corev1.PullIfNotPresent),
	PullSecret: "",
	Repository: "kagent-dev/kagent/app",
}

View Source

var DefaultServiceAccountName string

DefaultServiceAccountName is the global default ServiceAccount name for agent pods. When set, agent pods that don't specify an explicit serviceAccountName will use this instead of auto-creating a per-agent ServiceAccount.

View Source

var DefaultSkillsInitImageConfig = ImageConfig{
	Registry:   "cr.kagent.dev",
	Tag:        version.Get().Version,
	PullPolicy: string(corev1.PullIfNotPresent),
	Repository: "kagent-dev/kagent/skills-init",
}

DefaultSkillsInitImageConfig is the image config for the skills-init container that clones skill repositories from Git and pulls OCI skill images.

Functions ¶

func ConvertMCPServerToRemoteMCPServer ¶

func ConvertMCPServerToRemoteMCPServer(mcpServer *v1alpha1.MCPServer) (*v1alpha2.RemoteMCPServer, error)

func ConvertServiceToRemoteMCPServer ¶

func ConvertServiceToRemoteMCPServer(svc *corev1.Service) (*v1alpha2.RemoteMCPServer, error)

func GetA2AAgentCard ¶

func GetA2AAgentCard(agent *v1alpha2.Agent) *server.AgentCard

func NewValidationError ¶

func NewValidationError(format string, args ...any) error

NewValidationError creates a new ValidationError

Types ¶

type AdkApiTranslator ¶

type AdkApiTranslator interface {
	TranslateAgent(
		ctx context.Context,
		agent *v1alpha2.Agent,
	) (*AgentOutputs, error)
	GetOwnedResourceTypes() []client.Object
}

func NewAdkApiTranslator ¶

func NewAdkApiTranslator(kube client.Client, defaultModelConfig types.NamespacedName, plugins []TranslatorPlugin, globalProxyURL string) AdkApiTranslator

type AgentOutputs ¶

type AgentOutputs = translator.AgentOutputs

TODO(ilackarms): migrate this whole package to pkg/translator

type ImageConfig ¶

type ImageConfig struct {
	Registry   string `json:"registry,omitempty"`
	Tag        string `json:"tag,omitempty"`
	PullPolicy string `json:"pullPolicy,omitempty"`
	PullSecret string `json:"pullSecret,omitempty"`
	Repository string `json:"repository,omitempty"`
}

func (ImageConfig) Image ¶

func (c ImageConfig) Image() string

Image returns the fully qualified image reference (registry/repository:tag).

type PromptTemplateContext ¶

type PromptTemplateContext struct {
	// AgentName is the metadata.name of the Agent resource.
	AgentName string
	// AgentNamespace is the metadata.namespace of the Agent resource.
	AgentNamespace string
	// Description is the spec.description of the Agent resource.
	Description string
	// ToolNames is the list of tool names from all MCP server tools configured on the agent.
	ToolNames []string
	// SkillNames is the list of skill identifiers configured on the agent.
	SkillNames []string
}

PromptTemplateContext holds the variables available to system message templates.

type TranslatorPlugin ¶

type TranslatorPlugin = translator.TranslatorPlugin

type ValidationError ¶

type ValidationError struct {
	Err error
}

ValidationError indicates a configuration error that requires user action to fix. These errors should not trigger exponential backoff retries.

func (*ValidationError) Error ¶

func (e *ValidationError) Error() string

func (*ValidationError) Unwrap ¶

func (e *ValidationError) Unwrap() error

Source Files ¶

View all Source files

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