Documentation
¶
Index ¶
- Constants
- func CreateBaseEntryWebSocketMessage(base *api.BaseEntry) ([]byte, error)
- func CreateFullEntryWebSocketMessage(entry *api.Entry) ([]byte, error)
- func CreateWebsocketQueryMetadataMessage(base *basenine.Metadata) ([]byte, error)
- func CreateWebsocketStartTimeMessage(base int64) ([]byte, error)
- func CreateWebsocketToastMessage(base *ToastMessage) ([]byte, error)
- func CreateWebsocketWorkerEntryMessage(base *api.OutputChannelItem) ([]byte, error)
- type Config
- type EntriesRequest
- type EntriesResponse
- type HealthResponse
- type NodeToPodsMap
- type OASConfig
- type PodInfo
- type Resources
- type SingleEntryRequest
- type TargettedPodStatus
- type ToastMessage
- type VersionResponse
- type WebSocketEntryMessage
- type WebSocketFullEntryMessage
- type WebSocketMessageMetadata
- type WebSocketMessageType
- type WebSocketQueryMetadataMessage
- type WebSocketStartTimeMessage
- type WebSocketStatusMessage
- type WebSocketTargettedPodsMessage
- type WebSocketToastMessage
- type WebSocketWorkerConfigMessage
- type WebSocketWorkerEntryMessage
- type WorkerStatus
Constants ¶
View Source
const ( ConfigDirPath = "/app/config/" ConfigFileName = "kubeshark-config.json" DataDirPath = "/app/data/" )
Variables ¶
This section is empty.
Functions ¶
func CreateWebsocketToastMessage ¶
func CreateWebsocketToastMessage(base *ToastMessage) ([]byte, error)
func CreateWebsocketWorkerEntryMessage ¶
func CreateWebsocketWorkerEntryMessage(base *api.OutputChannelItem) ([]byte, error)
Types ¶
type Config ¶
type Config struct {
MaxDBSizeBytes int64 `json:"maxDBSizeBytes"`
InsertionFilter string `json:"insertionFilter"`
PullPolicy string `json:"pullPolicy"`
LogLevel logging.Level `json:"logLevel"`
WorkerResources Resources `json:"workerResources"`
ResourcesNamespace string `json:"resourceNamespace"`
DatabasePath string `json:"databasePath"`
ServiceMap bool `json:"serviceMap"`
OAS OASConfig `json:"oas"`
}
type EntriesRequest ¶
type EntriesResponse ¶
type HealthResponse ¶
type HealthResponse struct {
TargettedPods []*PodInfo `json:"targettedPods"`
ConnectedWorkersCount int `json:"connectedWorkersCount"`
WorkersStatus []*WorkerStatus `json:"workersStatus"`
}
type NodeToPodsMap ¶
func (NodeToPodsMap) Summary ¶
func (np NodeToPodsMap) Summary() map[string][]string
type SingleEntryRequest ¶
type SingleEntryRequest struct {
Query string `form:"query"`
}
type TargettedPodStatus ¶
type ToastMessage ¶
type VersionResponse ¶
type VersionResponse struct {
Ver string `json:"ver"`
}
type WebSocketEntryMessage ¶
type WebSocketEntryMessage struct {
*WebSocketMessageMetadata
Data *api.BaseEntry `json:"data,omitempty"`
}
type WebSocketFullEntryMessage ¶
type WebSocketFullEntryMessage struct {
*WebSocketMessageMetadata
Data *api.Entry `json:"data,omitempty"`
}
type WebSocketMessageMetadata ¶
type WebSocketMessageMetadata struct {
MessageType WebSocketMessageType `json:"messageType,omitempty"`
}
type WebSocketMessageType ¶
type WebSocketMessageType string
const ( WebSocketMessageTypeEntry WebSocketMessageType = "entry" WebSocketMessageTypeFullEntry WebSocketMessageType = "fullEntry" WebSocketMessageTypeWorkerEntry WebSocketMessageType = "targettedEntry" WebSocketMessageTypeUpdateStatus WebSocketMessageType = "status" WebSocketMessageTypeUpdateTargettedPods WebSocketMessageType = "targettedPods" WebSocketMessageTypeToast WebSocketMessageType = "toast" WebSocketMessageTypeQueryMetadata WebSocketMessageType = "queryMetadata" WebSocketMessageTypeStartTime WebSocketMessageType = "startTime" WebSocketMessageTypeWorkerConfig WebSocketMessageType = "workerConfig" )
type WebSocketQueryMetadataMessage ¶
type WebSocketQueryMetadataMessage struct {
*WebSocketMessageMetadata
Data *basenine.Metadata `json:"data,omitempty"`
}
type WebSocketStartTimeMessage ¶
type WebSocketStartTimeMessage struct {
*WebSocketMessageMetadata
Data int64 `json:"data"`
}
type WebSocketStatusMessage ¶
type WebSocketStatusMessage struct {
*WebSocketMessageMetadata
TargettingStatus []TargettedPodStatus `json:"targettingStatus"`
}
func CreateWebSocketStatusMessage ¶
func CreateWebSocketStatusMessage(targettedPodsStatus []TargettedPodStatus) WebSocketStatusMessage
type WebSocketTargettedPodsMessage ¶
type WebSocketTargettedPodsMessage struct {
*WebSocketMessageMetadata
NodeToTargettedPodsMap NodeToPodsMap `json:"nodeToTargettedPodsMap"`
}
func CreateWebSocketTargettedPodsMessage ¶
func CreateWebSocketTargettedPodsMessage(nodeToTargettedPodsMap NodeToPodsMap) WebSocketTargettedPodsMessage
type WebSocketToastMessage ¶
type WebSocketToastMessage struct {
*WebSocketMessageMetadata
Data *ToastMessage `json:"data,omitempty"`
}
type WebSocketWorkerConfigMessage ¶
type WebSocketWorkerConfigMessage struct {
*WebSocketMessageMetadata
TargettedPod []v1.Pod `json:"pods"`
}
type WebSocketWorkerEntryMessage ¶
type WebSocketWorkerEntryMessage struct {
*WebSocketMessageMetadata
Data *api.OutputChannelItem
}
type WorkerStatus ¶
Click to show internal directories.
Click to hide internal directories.