taskupdate

package

v0.3.3 Latest Latest Go to latest Published: Dec 8, 2025 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 *a2a.Task) *Manager

NewManager is a Manager constructor function.

func (mgr *Manager) Process(ctx context.Context, event a2a.Event) (*a2a.Task, 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, cause error) *a2a.Task

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) error
}

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