agent

type Executor ¶

type Executor struct {
	base.BaseNode
}

func NewExecutor(baseNode base.BaseNode) *Executor

func (p *Executor) Run(ctx context.Context, cli client.Client, args map[string]any) (map[string]any, error)

type StreamHandler ¶

type StreamHandler struct {
	callbacks.SimpleHandler
	// contains filtered or unexported fields
}

StreamHandler is a callback handler that prints to the standard output streaming.

func (handler StreamHandler) HandleStreamingFunc(ctx context.Context, chunk []byte)