Documentation ¶
Index ¶
- Variables
- func BroadcastTappedPodsStatus()
- func BroadcastTappedPodsToTappers(nodeToTappedPodMap shared.NodeToPodsMap)
- func BroadcastToBrowserClients(message []byte)
- func BroadcastToTapperClients(message []byte)
- func CheckIsServiceIP(address string) bool
- func HandleTapperIncomingMessage(message []byte, socketOutChannel chan<- *tapApi.OutputChannelItem, ...)
- func InitMaps(extensions map[string]*tapApi.Extension, protocols map[string]*tapApi.Protocol)
- func SendTappedPods(socketId int, nodeToTappedPodMap shared.NodeToPodsMap)
- func SendToSocket(socketId int, message []byte) error
- func StartReadingEntries(harChannel <-chan *tapApi.OutputChannelItem, workingDir *string, ...)
- func StartResolving(namespace string)
- func WebSocketRoutes(app *gin.Engine, eventHandlers EventHandlers)
- type BasenineEntryInserter
- type BasenineEntryStreamer
- type BrowserClient
- type DefaultEntryStreamerSocketConnector
- func (e *DefaultEntryStreamerSocketConnector) CleanupSocket(socketId int)
- func (e *DefaultEntryStreamerSocketConnector) SendEntry(socketId int, entry *tapApi.Entry, params *WebSocketParams) error
- func (e *DefaultEntryStreamerSocketConnector) SendMetadata(socketId int, metadata *basenine.Metadata) error
- func (e *DefaultEntryStreamerSocketConnector) SendToastError(socketId int, err error) error
- type EntryInserter
- type EntryStreamer
- type EntryStreamerSocketConnector
- type EventHandlers
- type RoutesEventHandlers
- type SocketConnection
- type WebSocketParams
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SocketGetBrowserHandler gin.HandlerFunc SocketGetTapperHandler gin.HandlerFunc )
Functions ¶
func BroadcastTappedPodsStatus ¶
func BroadcastTappedPodsStatus()
func BroadcastTappedPodsToTappers ¶
func BroadcastTappedPodsToTappers(nodeToTappedPodMap shared.NodeToPodsMap)
func BroadcastToBrowserClients ¶
func BroadcastToBrowserClients(message []byte)
func BroadcastToTapperClients ¶
func BroadcastToTapperClients(message []byte)
func CheckIsServiceIP ¶
func HandleTapperIncomingMessage ¶
func HandleTapperIncomingMessage(message []byte, socketOutChannel chan<- *tapApi.OutputChannelItem, broadcastMessageFunc func([]byte))
func SendTappedPods ¶
func SendTappedPods(socketId int, nodeToTappedPodMap shared.NodeToPodsMap)
func SendToSocket ¶
func StartReadingEntries ¶
func StartResolving ¶
func StartResolving(namespace string)
func WebSocketRoutes ¶
func WebSocketRoutes(app *gin.Engine, eventHandlers EventHandlers)
Types ¶
type BasenineEntryInserter ¶
type BasenineEntryInserter struct {
// contains filtered or unexported fields
}
func GetBasenineEntryInserterInstance ¶
func GetBasenineEntryInserterInstance() *BasenineEntryInserter
type BasenineEntryStreamer ¶
type BasenineEntryStreamer struct{}
func (*BasenineEntryStreamer) Get ¶
func (e *BasenineEntryStreamer) Get(ctx context.Context, socketId int, params *WebSocketParams) error
type BrowserClient ¶
type BrowserClient struct {
// contains filtered or unexported fields
}
type DefaultEntryStreamerSocketConnector ¶
type DefaultEntryStreamerSocketConnector struct{}
func (*DefaultEntryStreamerSocketConnector) CleanupSocket ¶
func (e *DefaultEntryStreamerSocketConnector) CleanupSocket(socketId int)
func (*DefaultEntryStreamerSocketConnector) SendEntry ¶
func (e *DefaultEntryStreamerSocketConnector) SendEntry(socketId int, entry *tapApi.Entry, params *WebSocketParams) error
func (*DefaultEntryStreamerSocketConnector) SendMetadata ¶
func (e *DefaultEntryStreamerSocketConnector) SendMetadata(socketId int, metadata *basenine.Metadata) error
func (*DefaultEntryStreamerSocketConnector) SendToastError ¶
func (e *DefaultEntryStreamerSocketConnector) SendToastError(socketId int, err error) error
type EntryInserter ¶
type EntryStreamer ¶
type EntryStreamer interface {
Get(ctx context.Context, socketId int, params *WebSocketParams) error
}
type EventHandlers ¶
type RoutesEventHandlers ¶
type RoutesEventHandlers struct { EventHandlers SocketOutChannel chan<- *tapApi.OutputChannelItem }
func (*RoutesEventHandlers) WebSocketConnect ¶
func (h *RoutesEventHandlers) WebSocketConnect(_ *gin.Context, socketId int, isTapper bool)
func (*RoutesEventHandlers) WebSocketDisconnect ¶
func (h *RoutesEventHandlers) WebSocketDisconnect(socketId int, isTapper bool)
func (*RoutesEventHandlers) WebSocketMessage ¶
func (h *RoutesEventHandlers) WebSocketMessage(socketId int, isTapper bool, message []byte)
type SocketConnection ¶
type SocketConnection struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.