Documentation
¶
Index ¶
- type BackgroundService
- type FeedEvent
- type WebSocketFeed
- func (f *WebSocketFeed) Broadcast(event FeedEvent)
- func (f *WebSocketFeed) BroadcastCostAlert(message string, usd float64)
- func (f *WebSocketFeed) BroadcastRequest(source, model string, inputTokens, outputTokens int)
- func (f *WebSocketFeed) ExportJSON() ([]byte, error)
- func (f *WebSocketFeed) Subscribe(id string) <-chan FeedEvent
- func (f *WebSocketFeed) SubscriberCount() int
- func (f *WebSocketFeed) Unsubscribe(id string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BackgroundService ¶
type BackgroundService struct {
// contains filtered or unexported fields
}
func NewBackgroundService ¶
func NewBackgroundService() *BackgroundService
func (*BackgroundService) IsRunning ¶
func (s *BackgroundService) IsRunning() bool
func (*BackgroundService) Start ¶
func (s *BackgroundService) Start()
func (*BackgroundService) Status ¶
func (s *BackgroundService) Status() string
func (*BackgroundService) Stop ¶
func (s *BackgroundService) Stop()
type WebSocketFeed ¶
type WebSocketFeed struct {
// contains filtered or unexported fields
}
func NewWebSocketFeed ¶
func NewWebSocketFeed() *WebSocketFeed
func (*WebSocketFeed) Broadcast ¶
func (f *WebSocketFeed) Broadcast(event FeedEvent)
func (*WebSocketFeed) BroadcastCostAlert ¶
func (f *WebSocketFeed) BroadcastCostAlert(message string, usd float64)
func (*WebSocketFeed) BroadcastRequest ¶
func (f *WebSocketFeed) BroadcastRequest(source, model string, inputTokens, outputTokens int)
func (*WebSocketFeed) ExportJSON ¶
func (f *WebSocketFeed) ExportJSON() ([]byte, error)
func (*WebSocketFeed) Subscribe ¶
func (f *WebSocketFeed) Subscribe(id string) <-chan FeedEvent
func (*WebSocketFeed) SubscriberCount ¶
func (f *WebSocketFeed) SubscriberCount() int
func (*WebSocketFeed) Unsubscribe ¶
func (f *WebSocketFeed) Unsubscribe(id string)
Source Files
Click to show internal directories.
Click to hide internal directories.