plugin

Documentation

Index

• Variables
• func ConnectHubbleRelay() *grpc.ClientConn
• func ConvertCiliumFlowToKnoxLog(flow *flow.Flow, dnsToIPs map[string][]string) (types.NetworkLog, bool)
• func ConvertCiliumFlowsToKnoxLogs(targetNamespace string, flows []*flow.Flow, dnsToIPs map[string][]string) []types.NetworkLog
• func ConvertDocsToCiliumFlows(docs []map[string]interface{}) []*flow.Flow
• func ConvertKnoxPoliciesToCiliumPolicies(services []types.Service, policies []types.KnoxNetworkPolicy) []types.CiliumNetworkPolicy
• func ConvertKnoxPolicyToCiliumPolicy(services []types.Service, inPolicy types.KnoxNetworkPolicy) types.CiliumNetworkPolicy
• func ConvertMongoDocsToCiliumFlows(docs []map[string]interface{}) []*flow.Flow
• func ConvertMySQLDocsToCiliumFlows(docs []map[string]interface{}) []*flow.Flow
• func GetCiliumFlowsFromHubble() []*flow.Flow
• func StartHubbleRelay(StopChan chan struct{}, wg *sync.WaitGroup)

Variables

var CiliumFlows []*flow.Flow

CiliumFlows list

var CiliumFlowsMutex *sync.Mutex

CiliumFlowsMutex mutext

var CiliumNSFiler string

Functions

func ConnectHubbleRelay

func ConnectHubbleRelay() *grpc.ClientConn

ConnectHubbleRelay function

func ConvertCiliumFlowToKnoxLog

func ConvertCiliumFlowToKnoxLog(flow *flow.Flow, dnsToIPs map[string][]string) (types.NetworkLog, bool)

ConvertCiliumFlowToKnoxLog function

func ConvertCiliumFlowsToKnoxLogs

func ConvertCiliumFlowsToKnoxLogs(targetNamespace string, flows []*flow.Flow, dnsToIPs map[string][]string) []types.NetworkLog

ConvertCiliumFlowsToKnoxLogs function

func ConvertDocsToCiliumFlows

func ConvertDocsToCiliumFlows(docs []map[string]interface{}) []*flow.Flow

ConvertDocsToCiliumFlows function

func ConvertKnoxPoliciesToCiliumPolicies

func ConvertKnoxPoliciesToCiliumPolicies(services []types.Service, policies []types.KnoxNetworkPolicy) []types.CiliumNetworkPolicy

ConvertKnoxPoliciesToCiliumPolicies function

func ConvertKnoxPolicyToCiliumPolicy

func ConvertKnoxPolicyToCiliumPolicy(services []types.Service, inPolicy types.KnoxNetworkPolicy) types.CiliumNetworkPolicy

ConvertKnoxPolicyToCiliumPolicy function

func ConvertMongoDocsToCiliumFlows

func ConvertMongoDocsToCiliumFlows(docs []map[string]interface{}) []*flow.Flow

ConvertMongoDocsToCiliumFlows function

func ConvertMySQLDocsToCiliumFlows

func ConvertMySQLDocsToCiliumFlows(docs []map[string]interface{}) []*flow.Flow

ConvertMySQLDocsToCiliumFlows function

func GetCiliumFlowsFromHubble

func GetCiliumFlowsFromHubble() []*flow.Flow

GetCiliumFlowsFromHubble function

func StartHubbleRelay

func StartHubbleRelay(StopChan chan struct{}, wg *sync.WaitGroup)

StartHubbleRelay function