taskupdate

package

v0.3.6 Latest Latest Go to latest Published: Jan 30, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Package taskupdate provides types and utilities for performing a2a.Task updates in response to a2a.Event-s.

This section is empty.

This section is empty.

func IsFinal(event a2a.Event) bool

IsFinal returns true if event must terminate a valid execution event sequence.

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

Manager is used for processing a2a.Event related to an a2a.Task. It updates the Task accordingly and uses Saver to store the new state.

func NewManager(saver Saver, task *VersionedTask) *Manager

NewManager is a Manager constructor function.

func (mgr *Manager) Process(ctx context.Context, event a2a.Event) (*VersionedTask, error)

Process validates the event associated with the managed a2a.Task and integrates the new state into it.

func (mgr *Manager) SetTaskFailed(ctx context.Context, event a2a.Event, cause error) (*VersionedTask, error)

SetTaskFailed attempts to move the Task to failed state and returns it in case of a success.

type Saver interface {
	Save(ctx context.Context, task *a2a.Task, event a2a.Event, prev a2a.TaskVersion) (a2a.TaskVersion, error)
}

Saver is used for saving the a2a.Task after updating its state.

type VersionedTask struct {
	Task    *a2a.Task
	Version a2a.TaskVersion
}