rpc

package
v5.0.0-preview.1+incom... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 13, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddScanner

func AddScanner(scanner *share.CLUSScanner)

func CheckPolicySyncStatus

func CheckPolicySyncStatus(ip string, port uint16) (*share.CLUSPolicySyncStatus, error)

func ClearSession

func ClearSession(agentID string, f *share.CLUSFilter) error

func CreateEnforcerServerDest

func CreateEnforcerServerDest(id string, ip string, port uint16)

func DeleteConversation

func DeleteConversation(ip string, port uint16, ops *share.CLUSGraphOps) error

func DeleteEndpoint

func DeleteEndpoint(ip string, port uint16, ops *share.CLUSGraphOps) error

func GetContainerIntercept

func GetContainerIntercept(agentID, id string) (*share.CLUSWorkloadIntercept, error)

func GetContainerLogs

func GetContainerLogs(agentID, id string, start, limit int) ([]byte, error)

func GetControllerCounter

func GetControllerCounter(ip string, port uint16) (*share.CLUSControllerCounter, error)

func GetControllerStat

func GetControllerStat(ip string, port uint16) (*share.CLUSStats, error)

func GetDatapathCounter

func GetDatapathCounter(agentID string) (*share.CLUSDatapathCounter, error)

func GetDerivedDlpRuleEntries

func GetDerivedDlpRuleEntries(agentID string, f *share.CLUSFilter) (*share.CLUSDerivedDlpRuleEntryArray, error)

func GetDerivedDlpRuleMacs

func GetDerivedDlpRuleMacs(agentID string, f *share.CLUSFilter) (*share.CLUSDerivedDlpRuleMacArray, error)

func GetDerivedDlpRules

func GetDerivedDlpRules(agentID string, f *share.CLUSFilter) (*share.CLUSDerivedDlpRuleMap, error)

func GetDerivedPolicyRules

func GetDerivedPolicyRules(agentID string, f *share.CLUSFilter) (*share.CLUSDerivedPolicyRuleMap, error)

func GetDerivedWorkloadFileRule

func GetDerivedWorkloadFileRule(agentID, id string) ([]*share.CLUSDerivedFileRule, error)

func GetDerivedWorkloadProcessRule

func GetDerivedWorkloadProcessRule(agentID, id string) ([]*share.CLUSDerivedProcessRule, error)

func GetFileMonitorFile

func GetFileMonitorFile(agentID string, f *share.CLUSFilter) ([]*share.CLUSFileMonitorFile, error)

func GetMeterList

func GetMeterList(agentID string, f *share.CLUSFilter) ([]*share.CLUSMeter, error)

func GetProcess

func GetProcess(agentID, id string) ([]*share.CLUSProcess, error)

func GetProcessHistory

func GetProcessHistory(agentID, id string) ([]*share.CLUSProcess, error)

func GetSessionCounter

func GetSessionCounter(agentID string) (*share.CLUSSessionCounter, error)

func GetSessionList

func GetSessionList(agentID string, f *share.CLUSFilter) ([]*share.CLUSSession, error)

func GetSnifferPcap

func GetSnifferPcap(agentID string, id string, limit int) ([]byte, error)

func GetSniffers

func GetSniffers(agentID string, f *share.CLUSSnifferFilter) ([]*share.CLUSSniffer, error)

func GetStats

func GetStats(agentID string, f *share.CLUSFilter) (*share.CLUSStats, error)

func Kick

func Kick(agentID string, ctrlID string, reason string) error

func KickLoginSessions

func KickLoginSessions(ip string, port uint16, req share.CLUSKickLoginSessionsRequest) error

func PauseResumeStoreWatcher

func PauseResumeStoreWatcher(ip string, port uint16, req share.CLUSStoreWatcherInfo) error

func Ping

func Ping(scanner string, timeout time.Duration) error

func ProbeContainerMap

func ProbeContainerMap(agentID string) ([]*share.CLUSProbeContainer, error)

func ProbeProcessMap

func ProbeProcessMap(agentID string) ([]*share.CLUSProbeProcess, error)

func ProbeSummary

func ProbeSummary(agentID string) (*share.CLUSProbeSummary, error)

func ProfileController

func ProfileController(ip string, port uint16, req *share.CLUSProfilingRequest) error

func ProfileEnforcer

func ProfileEnforcer(agentID string, req *share.CLUSProfilingRequest) error

func RemoveEnforcerServerDest

func RemoveEnforcerServerDest(id string)

func RemoveScanner

func RemoveScanner(scannerID string)

func ReportConnections

func ReportConnections(ip string, port uint16, conns []*share.CLUSConnection) (*share.RPCVoid, error)

func ReqSync

func ReqSync(ip string, port uint16, category, from string) (*share.CLUSSyncReply, error)

func ReqSyncStream

func ReqSyncStream(ip string, port uint16, category, from string) (*share.CLUSSyncReply, error)

func ResetLoginTokenTimer

func ResetLoginTokenTimer(ip string, port uint16, req share.CLUSLoginTokenInfo) error

func RunDockerBench

func RunDockerBench(agentID string) error

func RunKubernetesBench

func RunKubernetesBench(agentID string) error

func ScanAwsLambdaFunc

func ScanAwsLambdaFunc(ctx context.Context, funcInput *share.CLUSAwsFuncScanInput) (*share.ScanResult, error)

func ScanImage

func ScanImage(scanner string, ctx context.Context, req *share.ScanImageRequest) (*share.ScanResult, error)

func ScanPackage

func ScanPackage(ctx context.Context, pkgs []*share.ScanAppPackage) (*share.ScanResult, error)

func ScanPlatform

func ScanPlatform(scanner string, k8sVersion, ocVersion string, timeout time.Duration) (*share.ScanResult, error)

func ScanRunning

func ScanRunning(scanner string, agentID, id string, objType share.ScanObjectType, timeout time.Duration) (*share.ScanResult, error)

func SetEndpointAlias

func SetEndpointAlias(ip string, port uint16, ops *share.CLUSGraphOps) error

func SnifferCmd

func SnifferCmd(agentID string, req *share.CLUSSnifferRequest) (*share.CLUSSnifferResponse, error)

func TriggerSync

func TriggerSync(ip string, port uint16) error

func TriggerSyncLearnedPolicy

func TriggerSyncLearnedPolicy(ip string, port uint16) error

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL