Documentation
¶
Index ¶
- type A2AClient
- func (c *A2AClient) AgentCard(ctx context.Context) (*models.AgentCard, error)
- func (c *A2AClient) CancelTask(ctx context.Context, params *models.TaskIDParams) (*models.Task, error)
- func (c *A2AClient) GetPushNotificationConfig(ctx context.Context, params *models.GetTaskPushNotificationConfigParams) (*models.TaskPushNotificationConfig, error)
- func (c *A2AClient) GetTask(ctx context.Context, params *models.TaskQueryParams) (*models.Task, error)
- func (c *A2AClient) ResubscribeTask(ctx context.Context, params *models.TaskIDParams) (*ServerStreamingWrapper, error)
- func (c *A2AClient) SendMessage(ctx context.Context, params *models.MessageSendParams) (*models.SendMessageResponseUnion, error)
- func (c *A2AClient) SendMessageStreaming(ctx context.Context, params *models.MessageSendParams) (*ServerStreamingWrapper, error)
- func (c *A2AClient) SetPushNotificationConfig(ctx context.Context, params *models.TaskPushNotificationConfig) (*models.TaskPushNotificationConfig, error)
- type Config
- type ServerStreamingWrapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type A2AClient ¶
type A2AClient struct {
// contains filtered or unexported fields
}
A2AClient represents an A2A protocol client
func NewA2AClient ¶
NewA2AClient creates a new A2A client
func (*A2AClient) CancelTask ¶
func (*A2AClient) GetPushNotificationConfig ¶
func (c *A2AClient) GetPushNotificationConfig(ctx context.Context, params *models.GetTaskPushNotificationConfigParams) (*models.TaskPushNotificationConfig, error)
func (*A2AClient) ResubscribeTask ¶
func (c *A2AClient) ResubscribeTask(ctx context.Context, params *models.TaskIDParams) (*ServerStreamingWrapper, error)
func (*A2AClient) SendMessage ¶
func (c *A2AClient) SendMessage(ctx context.Context, params *models.MessageSendParams) (*models.SendMessageResponseUnion, error)
func (*A2AClient) SendMessageStreaming ¶
func (c *A2AClient) SendMessageStreaming(ctx context.Context, params *models.MessageSendParams) (*ServerStreamingWrapper, error)
func (*A2AClient) SetPushNotificationConfig ¶
func (c *A2AClient) SetPushNotificationConfig(ctx context.Context, params *models.TaskPushNotificationConfig) (*models.TaskPushNotificationConfig, error)
type Config ¶
type Config struct {
Transport transport.ClientTransport
}
type ServerStreamingWrapper ¶
type ServerStreamingWrapper struct {
// contains filtered or unexported fields
}
func (*ServerStreamingWrapper) Close ¶
func (s *ServerStreamingWrapper) Close() error
func (*ServerStreamingWrapper) Recv ¶
func (s *ServerStreamingWrapper) Recv() (resp *models.SendMessageStreamingResponseUnion, err error)
Source Files
Click to show internal directories.
Click to hide internal directories.