chat

Documentation

Index

• type AddToHistoryStep
  • func (a *AddToHistoryStep) Start(ctx context.Context, input string) (steps.StepResult[string], error)
• type EchoStep
  • func NewEchoStep() *EchoStep
  • func (e *EchoStep) Interrupt()
  • func (e *EchoStep) Publish(publisher message.Publisher, topic string) error
  • func (e *EchoStep) Start(ctx context.Context, input []*context2.Message) (steps.StepResult[string], error)
• type Event
• type EventType
• type RunnableStep
  • func (r *RunnableStep) Start(ctx context.Context, input interface{}) (steps.StepResult[string], error)
• type Step
• type StepOption
  • func WithSubscription(publisher message.Publisher, topic string) StepOption

Types

type AddToHistoryStep

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

func (*AddToHistoryStep) Start

func (a *AddToHistoryStep) Start(ctx context.Context, input string) (steps.StepResult[string], error)

type EchoStep

type EchoStep struct {
	TimePerCharacter time.Duration
	// contains filtered or unexported fields
}

func NewEchoStep

func NewEchoStep() *EchoStep

func (*EchoStep) Interrupt

func (e *EchoStep) Interrupt()

func (*EchoStep) Publish

func (e *EchoStep) Publish(publisher message.Publisher, topic string) error

func (*EchoStep) Start

func (e *EchoStep) Start(ctx context.Context, input []*context2.Message) (steps.StepResult[string], error)

type Event

type Event struct {
	Type  EventType `json:"type"`
	Text  string    `json:"text,omitempty"`
	Error error     `json:"error,omitempty"`
}

type EventType

type EventType string

const (
	EventTypePartial   EventType = "partial"
	EventTypeFinal     EventType = "final"
	EventTypeError     EventType = "error"
	EventTypeInterrupt EventType = "interrupt"
)

type RunnableStep

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

func (*RunnableStep) Start

func (r *RunnableStep) Start(ctx context.Context, input interface{}) (steps.StepResult[string], error)

type Step

type Step interface {
	steps.Step[[]*geppetto_context.Message, string]
	Interrupt()
	Publish(publisher message.Publisher, topic string) error
}

type StepOption

type StepOption func(Step) error

func WithSubscription

func WithSubscription(publisher message.Publisher, topic string) StepOption