api

Documentation

Index

• Variables
• func BroadcastTargettedPodsStatus()
• func BroadcastTargettedPodsToWorkers(nodeToTargettedPodMap models.NodeToPodsMap)
• func BroadcastToBrowserClients(message []byte)
• func BroadcastToWorkerClients(message []byte)
• func CheckIsServiceIP(address string) bool
• func HandleWorkerIncomingMessage(message []byte, socketOutChannel chan<- *baseApi.OutputChannelItem, ...)
• func InitMaps(extensions map[string]*baseApi.Extension, ...)
• func SendTargettedPods(socketId int, nodeToTargettedPodMap models.NodeToPodsMap)
• func SendToSocket(socketId int, message []byte) error
• func StartReadingEntries(harChannel <-chan *baseApi.OutputChannelItem, workingDir *string, ...)
• func StartResolving(namespace string)
• func WebSocketRoutes(app *gin.Engine, eventHandlers EventHandlers)
• type BasenineEntryInserter
  • func GetBasenineEntryInserterInstance() *BasenineEntryInserter
  • func (e *BasenineEntryInserter) Insert(entry *api.Entry) error
• type BasenineEntryStreamer
  • func (e *BasenineEntryStreamer) Get(ctx context.Context, socketId int, params *WebSocketParams) error
• type BrowserClient
• type DefaultEntryStreamerSocketConnector
  • func (e *DefaultEntryStreamerSocketConnector) CleanupSocket(socketId int)
  • func (e *DefaultEntryStreamerSocketConnector) SendEntry(socketId int, entry *baseApi.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
  • func (h *RoutesEventHandlers) WebSocketConnect(_ *gin.Context, socketId int, isWorker bool)
  • func (h *RoutesEventHandlers) WebSocketDisconnect(socketId int, isWorker bool)
  • func (h *RoutesEventHandlers) WebSocketMessage(socketId int, isWorker bool, message []byte)
• type SocketConnection
• type WebSocketParams

Variables

var (
	SocketGetBrowserHandler gin.HandlerFunc
	SocketGetWorkerHandler  gin.HandlerFunc
)

Functions

func BroadcastTargettedPodsStatus

func BroadcastTargettedPodsStatus()

func BroadcastTargettedPodsToWorkers

func BroadcastTargettedPodsToWorkers(nodeToTargettedPodMap models.NodeToPodsMap)

func BroadcastToBrowserClients

func BroadcastToBrowserClients(message []byte)

func BroadcastToWorkerClients

func BroadcastToWorkerClients(message []byte)

func CheckIsServiceIP

func CheckIsServiceIP(address string) bool

func HandleWorkerIncomingMessage

func HandleWorkerIncomingMessage(message []byte, socketOutChannel chan<- *baseApi.OutputChannelItem, broadcastMessageFunc func([]byte))

func InitMaps

func InitMaps(extensions map[string]*baseApi.Extension, protocols map[string]*baseApi.Protocol)

func SendTargettedPods

func SendTargettedPods(socketId int, nodeToTargettedPodMap models.NodeToPodsMap)

func SendToSocket

func SendToSocket(socketId int, message []byte) error

func StartReadingEntries

func StartReadingEntries(harChannel <-chan *baseApi.OutputChannelItem, workingDir *string, extensionsMap map[string]*baseApi.Extension)

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

func (*BasenineEntryInserter) Insert

func (e *BasenineEntryInserter) Insert(entry *api.Entry) error

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 *baseApi.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 EntryInserter interface {
	Insert(entry *api.Entry) error
}

type EntryStreamer

type EntryStreamer interface {
	Get(ctx context.Context, socketId int, params *WebSocketParams) error
}

type EntryStreamerSocketConnector

type EntryStreamerSocketConnector interface {
	SendEntry(socketId int, entry *baseApi.Entry, params *WebSocketParams) error
	SendMetadata(socketId int, metadata *basenine.Metadata) error
	SendToastError(socketId int, err error) error
	CleanupSocket(socketId int)
}

type EventHandlers

type EventHandlers interface {
	WebSocketConnect(c *gin.Context, socketId int, isWorker bool)
	WebSocketDisconnect(socketId int, isWorker bool)
	WebSocketMessage(socketId int, isWorker bool, message []byte)
}

type RoutesEventHandlers

type RoutesEventHandlers struct {
	EventHandlers
	SocketOutChannel chan<- *baseApi.OutputChannelItem
}

func (*RoutesEventHandlers) WebSocketConnect

func (h *RoutesEventHandlers) WebSocketConnect(_ *gin.Context, socketId int, isWorker bool)

func (*RoutesEventHandlers) WebSocketDisconnect

func (h *RoutesEventHandlers) WebSocketDisconnect(socketId int, isWorker bool)

func (*RoutesEventHandlers) WebSocketMessage

func (h *RoutesEventHandlers) WebSocketMessage(socketId int, isWorker bool, message []byte)

type SocketConnection

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

type WebSocketParams

type WebSocketParams struct {
	LeftOff           string `json:"leftOff"`
	Query             string `json:"query"`
	EnableFullEntries bool   `json:"enableFullEntries"`
	Fetch             int    `json:"fetch"`
	TimeoutMs         int    `json:"timeoutMs"`
}