agent

Documentation

Index

• type Executor
  • 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
  • func (handler StreamHandler) HandleStreamingFunc(ctx context.Context, chunk []byte)

Types

type Executor

type Executor struct {
	base.BaseNode
}

func NewExecutor

func NewExecutor(baseNode base.BaseNode) *Executor

func (*Executor) Run

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 (StreamHandler) HandleStreamingFunc

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