a2a

package

v0.0.0-...-b5da06d Latest Latest Go to latest Published: Jan 21, 2026 License: Apache-2.0 Imports: 25 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 ¶

func ExtractText(message protocol.Message) string
func NewA2AHttpMux(pathPrefix string, authenticator auth.AuthProvider) *handlerMux
func NewPassthroughManager(client *client.A2AClient) taskmanager.TaskManager
type A2AHandlerMux
type A2ARegistrar
- func NewA2ARegistrar(cache crcache.Cache, translator agent_translator.AdkApiTranslator, ...) *A2ARegistrar
- func (a *A2ARegistrar) NeedLeaderElection() bool
- func (a *A2ARegistrar) Start(ctx context.Context) error
type PassthroughManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ExtractText ¶

func ExtractText(message protocol.Message) string

ExtractText extracts the text content from a message.

func NewA2AHttpMux ¶

func NewA2AHttpMux(pathPrefix string, authenticator auth.AuthProvider) *handlerMux

func NewPassthroughManager ¶

func NewPassthroughManager(client *client.A2AClient) taskmanager.TaskManager

Types ¶

type A2AHandlerMux ¶

type A2AHandlerMux interface {
	SetAgentHandler(
		agentRef string,
		client *client.A2AClient,
		card server.AgentCard,
	) error
	RemoveAgentHandler(
		agentRef string,
	)
	http.Handler
}

A2AHandlerMux is an interface that defines methods for adding, getting, and removing agentic task handlers.

type A2ARegistrar ¶

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

func NewA2ARegistrar ¶

func NewA2ARegistrar(
	cache crcache.Cache,
	translator agent_translator.AdkApiTranslator,
	mux A2AHandlerMux,
	a2aBaseUrl string,
	authenticator auth.AuthProvider,
	streamingMaxBuf int,
	streamingInitialBuf int,
	streamingTimeout time.Duration,
) *A2ARegistrar

func (*A2ARegistrar) NeedLeaderElection ¶

func (a *A2ARegistrar) NeedLeaderElection() bool

func (*A2ARegistrar) Start ¶

func (a *A2ARegistrar) Start(ctx context.Context) error

type PassthroughManager ¶

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

func (*PassthroughManager) OnCancelTask ¶

func (m *PassthroughManager) OnCancelTask(ctx context.Context, params protocol.TaskIDParams) (*protocol.Task, error)

func (*PassthroughManager) OnGetTask ¶

func (m *PassthroughManager) OnGetTask(ctx context.Context, params protocol.TaskQueryParams) (*protocol.Task, error)

func (*PassthroughManager) OnPushNotificationGet ¶

func (m *PassthroughManager) OnPushNotificationGet(ctx context.Context, params protocol.TaskIDParams) (*protocol.TaskPushNotificationConfig, error)

func (*PassthroughManager) OnPushNotificationSet ¶

func (m *PassthroughManager) OnPushNotificationSet(ctx context.Context, params protocol.TaskPushNotificationConfig) (*protocol.TaskPushNotificationConfig, error)

func (*PassthroughManager) OnResubscribe ¶

func (m *PassthroughManager) OnResubscribe(ctx context.Context, params protocol.TaskIDParams) (<-chan protocol.StreamingMessageEvent, error)

func (*PassthroughManager) OnSendMessage ¶

func (m *PassthroughManager) OnSendMessage(ctx context.Context, request protocol.SendMessageParams) (*protocol.MessageResult, error)

func (*PassthroughManager) OnSendMessageStream ¶

func (m *PassthroughManager) OnSendMessageStream(ctx context.Context, request protocol.SendMessageParams) (<-chan protocol.StreamingMessageEvent, error)

Source Files ¶

View all Source files

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