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
	FollowWorkflowExecutions bool
	Run                      *v1.Run
	WaitForThread            bool
}