proxy

Documentation

Index

• type MemoryNotification
• type ResponseCapture
• type RollingBuffer
  • func NewRollingBuffer(max int) *RollingBuffer
  • func (r *RollingBuffer) Bytes() []byte
  • func (r *RollingBuffer) Cap() int
  • func (r *RollingBuffer) Len() int
  • func (r *RollingBuffer) Reset()
  • func (r *RollingBuffer) String() string
  • func (r *RollingBuffer) Write(p []byte) (int, error)
• type Server
  • func NewServer(a *app.App) *Server
  • func (s *Server) Start() error
  • func (s *Server) Stop() error

Types

type MemoryNotification

type MemoryNotification struct {
	RecallCount  int
	RecallStatus recallStatus
}

MemoryNotification describes the recall/notification state for a proxied request.

type ResponseCapture

type ResponseCapture struct {
	ResponseText string
	Model        string
	Timestamp    time.Time
}

ResponseCapture holds response data for extraction

type RollingBuffer

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

RollingBuffer maintains a bounded buffer that keeps only the most recent bytes

func NewRollingBuffer

func NewRollingBuffer(max int) *RollingBuffer

NewRollingBuffer creates a new rolling buffer with the specified maximum size

func (*RollingBuffer) Bytes

func (r *RollingBuffer) Bytes() []byte

Bytes returns the current contents of the buffer

func (*RollingBuffer) Cap

func (r *RollingBuffer) Cap() int

Cap returns the maximum capacity of the buffer

func (*RollingBuffer) Len

func (r *RollingBuffer) Len() int

Len returns the current length of the buffer

func (*RollingBuffer) Reset

func (r *RollingBuffer) Reset()

Reset clears the buffer

func (*RollingBuffer) String

func (r *RollingBuffer) String() string

String returns the buffer contents as a string

func (*RollingBuffer) Write

func (r *RollingBuffer) Write(p []byte) (int, error)

Write adds bytes to the buffer, keeping only the most recent up to max capacity.

type Server

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

Server implements the HTTP proxy server

func NewServer

func NewServer(a *app.App) *Server

NewServer creates a new proxy server

func (*Server) Start

func (s *Server) Start() error

Start starts the proxy server

func (*Server) Stop

func (s *Server) Stop() error

Stop stops the proxy server