server

Documentation

Index

• func ContextWithNewRunID(ctx context.Context) context.Context
• func RunIDFromContext(ctx context.Context) string
• type Event
• type Options
• type Server
  • func New(opts *Options) (*Server, error)
  • func (s *Server) Close(closeDaemons bool)
  • func (s *Server) Connect(session *melody.Session)
  • func (s *Server) ServeHTTP(rw http.ResponseWriter, req *http.Request)
  • func (s *Server) Start(ctx context.Context) error
• type Session
  • func (s *Session) Event(event runner.Event)
  • func (s *Session) Pause() func()
  • func (s *Session) Stop(output string, err error)
• type SessionFactory
  • func NewSessionFactory(events *broadcaster.Broadcaster[Event]) *SessionFactory
  • func (s SessionFactory) Pause() func()
  • func (s SessionFactory) Start(ctx context.Context, prg *types.Program, env []string, input string) (runner.Monitor, error)

Functions

func ContextWithNewRunID

func ContextWithNewRunID(ctx context.Context) context.Context

func RunIDFromContext

func RunIDFromContext(ctx context.Context) string

Types

type Event

type Event struct {
	runner.Event `json:",inline"`
	RunID        string         `json:"runID,omitempty"`
	Program      *types.Program `json:"program,omitempty"`
	Input        string         `json:"input,omitempty"`
	Output       string         `json:"output,omitempty"`
	Err          string         `json:"err,omitempty"`
}

type Options

type Options struct {
	ListenAddress string
	GPTScript     gptscript.Options
}

type Server

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

func New

func New(opts *Options) (*Server, error)

func (*Server) Close

func (s *Server) Close(closeDaemons bool)

func (*Server) Connect

func (s *Server) Connect(session *melody.Session)

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

type Session

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

func (*Session) Event

func (s *Session) Event(event runner.Event)

func (*Session) Pause

func (s *Session) Pause() func()

func (*Session) Stop

func (s *Session) Stop(output string, err error)

type SessionFactory

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

func NewSessionFactory

func NewSessionFactory(events *broadcaster.Broadcaster[Event]) *SessionFactory

func (SessionFactory) Pause

func (s SessionFactory) Pause() func()

func (SessionFactory) Start

func (s SessionFactory) Start(ctx context.Context, prg *types.Program, env []string, input string) (runner.Monitor, error)