Documentation
¶
Overview ¶
Package pbconv provides conversion functions between A2A protobufs and native Go types.
Index ¶
- func ExtractConfigID(name string) (string, error)
- func ExtractTaskID(name string) (a2a.TaskID, error)
- func FromProtoAgentCard(pCard *a2apb.AgentCard) (*a2a.AgentCard, error)
- func FromProtoCreateTaskPushConfigRequest(req *a2apb.CreateTaskPushNotificationConfigRequest) (*a2a.TaskPushConfig, error)
- func FromProtoDeleteTaskPushConfigRequest(req *a2apb.DeleteTaskPushNotificationConfigRequest) (*a2a.DeleteTaskPushConfigParams, error)
- func FromProtoGetTaskPushConfigRequest(req *a2apb.GetTaskPushNotificationConfigRequest) (*a2a.GetTaskPushConfigParams, error)
- func FromProtoGetTaskRequest(req *a2apb.GetTaskRequest) (*a2a.TaskQueryParams, error)
- func FromProtoListTaskPushConfig(resp *a2apb.ListTaskPushNotificationConfigResponse) ([]*a2a.TaskPushConfig, error)
- func FromProtoListTasksResponse(resp *a2apb.ListTasksResponse) (*a2a.ListTasksResponse, error)
- func FromProtoMessage(pMsg *a2apb.Message) (*a2a.Message, error)
- func FromProtoSendMessageRequest(req *a2apb.SendMessageRequest) (*a2a.MessageSendParams, error)
- func FromProtoSendMessageResponse(resp *a2apb.SendMessageResponse) (a2a.SendMessageResult, error)
- func FromProtoStreamResponse(resp *a2apb.StreamResponse) (a2a.Event, error)
- func FromProtoTask(pTask *a2apb.Task) (*a2a.Task, error)
- func FromProtoTaskPushConfig(pTaskConfig *a2apb.TaskPushNotificationConfig) (*a2a.TaskPushConfig, error)
- func MakeConfigName(taskID a2a.TaskID, configID string) string
- func MakeTaskName(taskID a2a.TaskID) string
- func ToProtoAgentCard(card *a2a.AgentCard) (*a2apb.AgentCard, error)
- func ToProtoCancelTaskRequest(params *a2a.TaskIDParams) (*a2apb.CancelTaskRequest, error)
- func ToProtoCreateTaskPushConfigRequest(config *a2a.TaskPushConfig) (*a2apb.CreateTaskPushNotificationConfigRequest, error)
- func ToProtoDeleteTaskPushConfigRequest(params *a2a.DeleteTaskPushConfigParams) (*a2apb.DeleteTaskPushNotificationConfigRequest, error)
- func ToProtoGetTaskPushConfigRequest(params *a2a.GetTaskPushConfigParams) (*a2apb.GetTaskPushNotificationConfigRequest, error)
- func ToProtoGetTaskRequest(params *a2a.TaskQueryParams) (*a2apb.GetTaskRequest, error)
- func ToProtoListTaskPushConfig(configs []*a2a.TaskPushConfig) (*a2apb.ListTaskPushNotificationConfigResponse, error)
- func ToProtoListTaskPushConfigRequest(req *a2a.ListTaskPushConfigParams) (*a2apb.ListTaskPushNotificationConfigRequest, error)
- func ToProtoListTasksRequest(req *a2a.ListTasksRequest) (*a2apb.ListTasksRequest, error)
- func ToProtoSendMessageRequest(params *a2a.MessageSendParams) (*a2apb.SendMessageRequest, error)
- func ToProtoSendMessageResponse(result a2a.SendMessageResult) (*a2apb.SendMessageResponse, error)
- func ToProtoStreamResponse(event a2a.Event) (*a2apb.StreamResponse, error)
- func ToProtoTask(task *a2a.Task) (*a2apb.Task, error)
- func ToProtoTaskPushConfig(config *a2a.TaskPushConfig) (*a2apb.TaskPushNotificationConfig, error)
- func ToProtoTaskSubscriptionRequest(params *a2a.TaskIDParams) (*a2apb.TaskSubscriptionRequest, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractConfigID ¶
func FromProtoCreateTaskPushConfigRequest ¶
func FromProtoCreateTaskPushConfigRequest(req *a2apb.CreateTaskPushNotificationConfigRequest) (*a2a.TaskPushConfig, error)
func FromProtoDeleteTaskPushConfigRequest ¶
func FromProtoDeleteTaskPushConfigRequest(req *a2apb.DeleteTaskPushNotificationConfigRequest) (*a2a.DeleteTaskPushConfigParams, error)
func FromProtoGetTaskPushConfigRequest ¶
func FromProtoGetTaskPushConfigRequest(req *a2apb.GetTaskPushNotificationConfigRequest) (*a2a.GetTaskPushConfigParams, error)
func FromProtoGetTaskRequest ¶
func FromProtoGetTaskRequest(req *a2apb.GetTaskRequest) (*a2a.TaskQueryParams, error)
func FromProtoListTaskPushConfig ¶
func FromProtoListTaskPushConfig(resp *a2apb.ListTaskPushNotificationConfigResponse) ([]*a2a.TaskPushConfig, error)
func FromProtoListTasksResponse ¶ added in v0.3.7
func FromProtoListTasksResponse(resp *a2apb.ListTasksResponse) (*a2a.ListTasksResponse, error)
func FromProtoSendMessageRequest ¶
func FromProtoSendMessageRequest(req *a2apb.SendMessageRequest) (*a2a.MessageSendParams, error)
func FromProtoSendMessageResponse ¶
func FromProtoSendMessageResponse(resp *a2apb.SendMessageResponse) (a2a.SendMessageResult, error)
func FromProtoStreamResponse ¶
func FromProtoStreamResponse(resp *a2apb.StreamResponse) (a2a.Event, error)
func FromProtoTaskPushConfig ¶
func FromProtoTaskPushConfig(pTaskConfig *a2apb.TaskPushNotificationConfig) (*a2a.TaskPushConfig, error)
func MakeTaskName ¶
func ToProtoCancelTaskRequest ¶
func ToProtoCancelTaskRequest(params *a2a.TaskIDParams) (*a2apb.CancelTaskRequest, error)
func ToProtoCreateTaskPushConfigRequest ¶
func ToProtoCreateTaskPushConfigRequest(config *a2a.TaskPushConfig) (*a2apb.CreateTaskPushNotificationConfigRequest, error)
func ToProtoDeleteTaskPushConfigRequest ¶
func ToProtoDeleteTaskPushConfigRequest(params *a2a.DeleteTaskPushConfigParams) (*a2apb.DeleteTaskPushNotificationConfigRequest, error)
func ToProtoGetTaskPushConfigRequest ¶
func ToProtoGetTaskPushConfigRequest(params *a2a.GetTaskPushConfigParams) (*a2apb.GetTaskPushNotificationConfigRequest, error)
func ToProtoGetTaskRequest ¶
func ToProtoGetTaskRequest(params *a2a.TaskQueryParams) (*a2apb.GetTaskRequest, error)
func ToProtoListTaskPushConfig ¶
func ToProtoListTaskPushConfig(configs []*a2a.TaskPushConfig) (*a2apb.ListTaskPushNotificationConfigResponse, error)
func ToProtoListTaskPushConfigRequest ¶
func ToProtoListTaskPushConfigRequest(req *a2a.ListTaskPushConfigParams) (*a2apb.ListTaskPushNotificationConfigRequest, error)
func ToProtoListTasksRequest ¶ added in v0.3.7
func ToProtoListTasksRequest(req *a2a.ListTasksRequest) (*a2apb.ListTasksRequest, error)
func ToProtoSendMessageRequest ¶
func ToProtoSendMessageRequest(params *a2a.MessageSendParams) (*a2apb.SendMessageRequest, error)
func ToProtoSendMessageResponse ¶
func ToProtoSendMessageResponse(result a2a.SendMessageResult) (*a2apb.SendMessageResponse, error)
func ToProtoStreamResponse ¶
func ToProtoStreamResponse(event a2a.Event) (*a2apb.StreamResponse, error)
func ToProtoTaskPushConfig ¶
func ToProtoTaskPushConfig(config *a2a.TaskPushConfig) (*a2apb.TaskPushNotificationConfig, error)
func ToProtoTaskSubscriptionRequest ¶
func ToProtoTaskSubscriptionRequest(params *a2a.TaskIDParams) (*a2apb.TaskSubscriptionRequest, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.