agent

type Agent[T any] struct {
	// contains filtered or unexported fields
}

type Cache[S any] interface {
	Set(ctx context.Context, key string, val S) error
	Get(ctx context.Context, key string) (S, bool, error)
	Del(ctx context.Context, key string) error
	Exists(ctx context.Context, key string) (bool, error)
}

type FormFlow[T any] struct {
	// contains filtered or unexported fields
}

type FormSpec[T any] interface {
	JsonSchema() (string, error)

	MissingFacts(current T) []types.FieldInfo
	ValidateFacts(current T) []types.FieldInfo

	Summary(current T) string
}

type HistoryReadWriter interface {
	Load(ctx context.Context) ([]*schema.Message, error)
	Save(ctx context.Context, history []*schema.Message) error
	Clear(ctx context.Context) error

	// Append loads history, appends msgs with de-duplication, trims, then saves.
	// It returns the saved history for convenient passing to adk.AgentInput.
	Append(ctx context.Context, msgs ...*schema.Message) ([]*schema.Message, error)
}

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

type KeepSystemLastNTrimmer struct {
	N int
}

type MemoryCache[S any] struct {
	// contains filtered or unexported fields
}

type Option[T any] func(a *Agent[T])

type Request[T any] struct {
	State       *State[T]         `json:"state" jsonschema:"description=The current state of the form filling process"`
	ChatHistory []*schema.Message `json:"chat_history" jsonschema:"description=The chat history between the user and the agent"`
}

type Response[T any] struct {
	Message  string            `json:"message"`
	State    *State[T]         `json:"state"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type State[T any] struct {
	Phase          types.Phase `` /* 145-byte string literal not displayed */
	LatestQuestion string      `json:"latest_question" jsonschema:"description=The latest question asked to the user"`
	FormState      T           `json:"form_state" jsonschema:"description=The current state of the form being filled"`
}

type StateReadWriter[T any] interface {
	Load(ctx context.Context) (*State[T], error)
	Save(ctx context.Context, state *State[T]) error
	Clear(ctx context.Context) error
}

type StateStore[T any] struct {
	// contains filtered or unexported fields
}

type Store[S any] struct {
	// contains filtered or unexported fields
}

type Trimmer interface {
	Trim(history []*schema.Message) []*schema.Message
}