events

Documentation

Index

• type Emitter
  • func NewEmitter(client kclient.WithWatch) *Emitter
  • func (e *Emitter) ClearProgress(run *v1.Run)
  • func (e *Emitter) Done(run *v1.Run)
  • func (e *Emitter) Submit(run *v1.Run, prg *gptscript.Program, frames gptscript.CallFrames)
  • func (e *Emitter) SubmitProgress(run *v1.Run, progress types.Progress)
  • func (e *Emitter) Watch(ctx context.Context, namespace string, opts WatchOptions) (*v1.Run, chan types.Progress, error)
• type WatchOptions

Types

type Emitter

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

func NewEmitter

func NewEmitter(client kclient.WithWatch) *Emitter

func (*Emitter) ClearProgress

func (e *Emitter) ClearProgress(run *v1.Run)

func (*Emitter) Done

func (e *Emitter) Done(run *v1.Run)

func (*Emitter) Submit

func (e *Emitter) Submit(run *v1.Run, prg *gptscript.Program, frames gptscript.CallFrames)

func (*Emitter) SubmitProgress

func (e *Emitter) SubmitProgress(run *v1.Run, progress types.Progress)

func (*Emitter) Watch

func (e *Emitter) Watch(ctx context.Context, namespace string, opts WatchOptions) (*v1.Run, chan types.Progress, error)

type WatchOptions

type WatchOptions struct {
	History               bool
	LastRunName           string
	MaxRuns               int
	After                 bool
	ThreadName            string
	ThreadResourceVersion string
	Follow                bool
	Run                   *v1.Run
	WaitForThread         bool
}