shared

Documentation

Index

• Constants
• func Contains(slice []string, containsValue string) bool
• func EqualStringSlices(slice1 []string, slice2 []string) bool
• func Unique(slice []string) []string
• type HealthResponse
• type MizuAgentConfig
• type NodeToPodsMap
  • func (np NodeToPodsMap) Summary() map[string][]string
• type OASConfig
• type PodInfo
• type Resources
• type TLSLinkInfo
• type TappedPodStatus
• type TapperStatus
• type VersionResponse
• type WebSocketMessageMetadata
• type WebSocketMessageType
• type WebSocketStatusMessage
  • func CreateWebSocketStatusMessage(tappedPodsStatus []TappedPodStatus) WebSocketStatusMessage
• type WebSocketTapConfigMessage
• type WebSocketTappedPodsMessage
  • func CreateWebSocketTappedPodsMessage(nodeToTappedPodMap NodeToPodsMap) WebSocketTappedPodsMessage

Constants

const (
	MizuFilteringOptionsEnvVar = "SENSITIVE_DATA_FILTERING_OPTIONS"
	HostModeEnvVar             = "HOST_MODE"
	NodeNameEnvVar             = "NODE_NAME"
	ConfigDirPath              = "/app/config/"
	DataDirPath                = "/app/data/"
	ConfigFileName             = "mizu-config.json"
	DefaultApiServerPort       = 8899
	LogLevelEnvVar             = "LOG_LEVEL"
	MizuAgentImageRepo         = "docker.io/up9inc/mizu"
	BasenineHost               = "127.0.0.1"
	BaseninePort               = "9099"
	BasenineReconnectInterval  = 3
)

Functions

func Contains

func Contains(slice []string, containsValue string) bool

func EqualStringSlices

func EqualStringSlices(slice1 []string, slice2 []string) bool

func Unique

func Unique(slice []string) []string

Types

type HealthResponse

type HealthResponse struct {
	TappedPods            []*PodInfo      `json:"tappedPods"`
	ConnectedTappersCount int             `json:"connectedTappersCount"`
	TappersStatus         []*TapperStatus `json:"tappersStatus"`
}

type MizuAgentConfig

type MizuAgentConfig struct {
	MaxDBSizeBytes         int64         `json:"maxDBSizeBytes"`
	InsertionFilter        string        `json:"insertionFilter"`
	AgentImage             string        `json:"agentImage"`
	PullPolicy             string        `json:"pullPolicy"`
	LogLevel               logging.Level `json:"logLevel"`
	TapperResources        Resources     `json:"tapperResources"`
	MizuResourcesNamespace string        `json:"mizuResourceNamespace"`
	AgentDatabasePath      string        `json:"agentDatabasePath"`
	ServiceMap             bool          `json:"serviceMap"`
	OAS                    OASConfig     `json:"oas"`
}

type NodeToPodsMap

type NodeToPodsMap map[string][]v1.Pod

func (NodeToPodsMap) Summary

func (np NodeToPodsMap) Summary() map[string][]string

type OASConfig

type OASConfig struct {
	Enable        bool `yaml:"enabled" default:"true"`
	MaxExampleLen int  `yaml:"max-example-len" default:"10240"`
}

type PodInfo

type PodInfo struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	NodeName  string `json:"nodeName"`
}

type Resources

type Resources struct {
	CpuLimit       string `yaml:"cpu-limit" default:"750m"`
	MemoryLimit    string `yaml:"memory-limit" default:"1Gi"`
	CpuRequests    string `yaml:"cpu-requests" default:"50m"`
	MemoryRequests string `yaml:"memory-requests" default:"50Mi"`
}

type TLSLinkInfo

type TLSLinkInfo struct {
	SourceIP                string `json:"sourceIP"`
	DestinationAddress      string `json:"destinationAddress"`
	ResolvedDestinationName string `json:"resolvedDestinationName"`
	ResolvedSourceName      string `json:"resolvedSourceName"`
}

type TappedPodStatus

type TappedPodStatus struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	IsTapped  bool   `json:"isTapped"`
}

type TapperStatus

type TapperStatus struct {
	TapperName string `json:"tapperName"`
	NodeName   string `json:"nodeName"`
	Status     string `json:"status"`
}

type VersionResponse

type VersionResponse struct {
	Ver string `json:"ver"`
}

type WebSocketMessageMetadata

type WebSocketMessageMetadata struct {
	MessageType WebSocketMessageType `json:"messageType,omitempty"`
}

type WebSocketMessageType

type WebSocketMessageType string

const (
	WebSocketMessageTypeEntry            WebSocketMessageType = "entry"
	WebSocketMessageTypeFullEntry        WebSocketMessageType = "fullEntry"
	WebSocketMessageTypeTappedEntry      WebSocketMessageType = "tappedEntry"
	WebSocketMessageTypeUpdateStatus     WebSocketMessageType = "status"
	WebSocketMessageTypeUpdateTappedPods WebSocketMessageType = "tappedPods"
	WebSocketMessageTypeToast            WebSocketMessageType = "toast"
	WebSocketMessageTypeQueryMetadata    WebSocketMessageType = "queryMetadata"
	WebSocketMessageTypeStartTime        WebSocketMessageType = "startTime"
	WebSocketMessageTypeTapConfig        WebSocketMessageType = "tapConfig"
)

type WebSocketStatusMessage

type WebSocketStatusMessage struct {
	*WebSocketMessageMetadata
	TappingStatus []TappedPodStatus `json:"tappingStatus"`
}

func CreateWebSocketStatusMessage

func CreateWebSocketStatusMessage(tappedPodsStatus []TappedPodStatus) WebSocketStatusMessage

type WebSocketTapConfigMessage

type WebSocketTapConfigMessage struct {
	*WebSocketMessageMetadata
	TapTargets []v1.Pod `json:"pods"`
}

type WebSocketTappedPodsMessage

type WebSocketTappedPodsMessage struct {
	*WebSocketMessageMetadata
	NodeToTappedPodMap NodeToPodsMap `json:"nodeToTappedPodMap"`
}

func CreateWebSocketTappedPodsMessage

func CreateWebSocketTappedPodsMessage(nodeToTappedPodMap NodeToPodsMap) WebSocketTappedPodsMessage