server

Documentation

Index

• func HandleHashedSessionID(req *http.Request, gatewayClient *client.Client, ...) error
• func NewGatewayTokenReviewer(gatewayClient *client.Client, dispatcher *dispatcher.Dispatcher) authenticator.Request
• type Options
• type Server
  • func New(ctx context.Context, db *db.DB, tokenService *ephemeral.TokenService, ...) (*Server, error)
  • func (s *Server) AddRoutes(mux *server.Server)

Functions

func HandleHashedSessionID

func HandleHashedSessionID(req *http.Request, gatewayClient *client.Client, dispatcher *dispatcher.Dispatcher, hashedSessionID, namespace, name string) error

func NewGatewayTokenReviewer

func NewGatewayTokenReviewer(gatewayClient *client.Client, dispatcher *dispatcher.Dispatcher) authenticator.Request

Types

type Options

type Options struct {
	Hostname     string
	UIHostname   string `name:"ui-hostname" env:"OBOT_SERVER_UI_HOSTNAME"`
	GatewayDebug bool

	DailyUserPromptTokenLimit     int `usage:"The maximum number of daily user prompt/input token to allow, <= 0 disables the limit" default:"10000000"`     // default is 10 million
	DailyUserCompletionTokenLimit int `usage:"The maximum number of daily user completion/output tokens to allow, <= 0 disables the limit" default:"100000"` // default is 100 thousand
}

type Server

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

func New

func New(ctx context.Context, db *db.DB, tokenService *ephemeral.TokenService, modelProviderDispatcher *dispatcher.Dispatcher, opts Options) (*Server, error)

func (*Server) AddRoutes

func (s *Server) AddRoutes(mux *server.Server)