agent

package
v0.0.0-...-a27ff91 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const Default_Cidr_IsVip bool = false
View Source 
const Default_FlowAcl_Protocol uint32 = 256
View Source 
const Default_GPIDAgentData_UpdateTime uint32 = 0
View Source 
const Default_GPIDSyncEntry_EpcIdReal uint32 = 0
View Source 
const Default_GPIDSyncEntry_EpcId_0 uint32 = 0
View Source 
const Default_GPIDSyncEntry_EpcId_1 uint32 = 0
View Source 
const Default_GPIDSyncEntry_Ipv4Real uint32 = 0
View Source 
const Default_GPIDSyncEntry_Ipv4_0 uint32 = 0
View Source 
const Default_GPIDSyncEntry_Ipv4_1 uint32 = 0
View Source 
const Default_GPIDSyncEntry_NetnsIdx uint32 = 0
View Source 
const Default_GPIDSyncEntry_PidReal uint32 = 0
View Source 
const Default_GPIDSyncEntry_Pid_0 uint32 = 0
View Source 
const Default_GPIDSyncEntry_Pid_1 uint32 = 0
View Source 
const Default_GPIDSyncEntry_PortReal uint32 = 0
View Source 
const Default_GPIDSyncEntry_Port_0 uint32 = 0
View Source 
const Default_GPIDSyncEntry_Port_1 uint32 = 0
View Source 
const Default_GenesisSyncRequest_Version uint64 = 0
View Source 
const Default_GenesisSyncResponse_Version uint64 = 0
View Source 
const Default_GlobalGPIDEntry_AgentId_0 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_AgentId_1 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_EpcId_0 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_EpcId_1 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Gpid_0 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Gpid_1 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Ipv4_0 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Ipv4_1 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_NetnsIdx uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Pid_0 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Pid_1 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Port_0 uint32 = 0
View Source 
const Default_GlobalGPIDEntry_Port_1 uint32 = 0
View Source 
const Default_Group_EpcId uint32 = 0
View Source 
const Default_InterfaceInfo_NetnsId uint32 = 0
View Source 
const Default_Interface_IsVipInterface bool = false
View Source 
const Default_IpResource_Masklen uint32 = 32
View Source 
const Default_IpResource_SubnetId uint32 = 0
View Source 
const Default_NpbAction_PayloadSlice uint32 = 65535
View Source 
const Default_PluginConfig_UpdateTime uint32 = 0
View Source 
const Default_PluginResponse_UpdateTime uint32 = 0
View Source 
const Default_ProcessInfo_NetnsId uint32 = 0
View Source 
const Default_RealClientToRealServer_AgentIdReal uint32 = 0
View Source 
const Default_RealClientToRealServer_EpcIdReal uint32 = 0
View Source 
const Default_RealClientToRealServer_EpcId_0 uint32 = 0
View Source 
const Default_RealClientToRealServer_EpcId_1 uint32 = 0
View Source 
const Default_RealClientToRealServer_Ipv4Real uint32 = 0
View Source 
const Default_RealClientToRealServer_Ipv4_0 uint32 = 0
View Source 
const Default_RealClientToRealServer_Ipv4_1 uint32 = 0
View Source 
const Default_RealClientToRealServer_PidReal uint32 = 0
View Source 
const Default_RealClientToRealServer_PortReal uint32 = 0
View Source 
const Default_RealClientToRealServer_Port_0 uint32 = 0
View Source 
const Default_RealClientToRealServer_Port_1 uint32 = 0
View Source 
const Default_RemoteExecRequest_BatchLen uint32 = 1048576
View Source 
const Default_RipToVip_EpcId uint32 = 0
View Source 
const Default_RipToVip_RIpv4 uint32 = 0
View Source 
const Default_RipToVip_RPort uint32 = 0
View Source 
const Default_RipToVip_VIpv4 uint32 = 0
View Source 
const Default_RipToVip_VPort uint32 = 0
View Source 
const Default_SyncRequest_ConfigAccepted bool = true
View Source 
const Default_SyncRequest_Exception uint64 = 0
View Source 
const Default_SyncRequest_KubernetesForceWatch bool = false
View Source 
const Default_SyncRequest_VersionAcls uint64 = 0
View Source 
const Default_SyncRequest_VersionGroups uint64 = 0
View Source 
const Default_SyncRequest_VersionPlatformData uint64 = 0
View Source 
const Default_SyncResponse_OnlyPartialFields bool = false
View Source 
const Default_SyncResponse_VersionAcls uint64 = 0
View Source 
const Default_SyncResponse_VersionGroups uint64 = 0
View Source 
const Default_SyncResponse_VersionPlatformData uint64 = 0

Variables

View Source 
var (
	ErrInvalidLengthAgent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAgent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Action_name = map[int32]string{
	1: "PACKET_CAPTURING",
}
View Source 
var Action_value = map[string]int32{
	"PACKET_CAPTURING": 1,
}
View Source 
var AgentIdentifier_name = map[int32]string{
	1: "IP_AND_MAC",
	2: "IP",
}
View Source 
var AgentIdentifier_value = map[string]int32{
	"IP_AND_MAC": 1,
	"IP":         2,
}
View Source 
var AgentType_name = map[int32]string{
	0:  "TT_UNKNOWN",
	1:  "TT_PROCESS",
	2:  "TT_VM",
	3:  "TT_PUBLIC_CLOUD",
	5:  "TT_PHYSICAL_MACHINE",
	6:  "TT_DEDICATED_PHYSICAL_MACHINE",
	7:  "TT_HOST_POD",
	8:  "TT_VM_POD",
	9:  "TT_TUNNEL_DECAPSULATION",
	10: "TT_HYPER_V_COMPUTE",
	11: "TT_HYPER_V_NETWORK",
	12: "TT_K8S_SIDECAR",
}
View Source 
var AgentType_value = map[string]int32{
	"TT_UNKNOWN":                    0,
	"TT_PROCESS":                    1,
	"TT_VM":                         2,
	"TT_PUBLIC_CLOUD":               3,
	"TT_PHYSICAL_MACHINE":           5,
	"TT_DEDICATED_PHYSICAL_MACHINE": 6,
	"TT_HOST_POD":                   7,
	"TT_VM_POD":                     8,
	"TT_TUNNEL_DECAPSULATION":       9,
	"TT_HYPER_V_COMPUTE":            10,
	"TT_HYPER_V_NETWORK":            11,
	"TT_K8S_SIDECAR":                12,
}
View Source 
var CaptureSocketType_name = map[int32]string{
	0: "AUTO",
	1: "AF_PACKET_V1",
	2: "AF_PACKET_V2",
	3: "AF_PACKET_V3",
}
View Source 
var CaptureSocketType_value = map[string]int32{
	"AUTO":         0,
	"AF_PACKET_V1": 1,
	"AF_PACKET_V2": 2,
	"AF_PACKET_V3": 3,
}
View Source 
var CidrType_name = map[int32]string{
	1: "WAN",
	2: "LAN",
}
View Source 
var CidrType_value = map[string]int32{
	"WAN": 1,
	"LAN": 2,
}
View Source 
var CommandType_name = map[int32]string{
	0: "LINUX",
	1: "KUBERNETES",
}
View Source 
var CommandType_value = map[string]int32{
	"LINUX":      0,
	"KUBERNETES": 1,
}
View Source 
var DecapType_name = map[int32]string{
	0: "DECAP_TYPE_NONE",
	1: "DECAP_TYPE_VXLAN",
	2: "DECAP_TYPE_IPIP",
	3: "DECAP_TYPE_TENCENT",
	4: "DECAP_TYPE_GENEVE",
	5: "DECAP_TYPE_VXLAN_NSH",
}
View Source 
var DecapType_value = map[string]int32{
	"DECAP_TYPE_NONE":      0,
	"DECAP_TYPE_VXLAN":     1,
	"DECAP_TYPE_IPIP":      2,
	"DECAP_TYPE_TENCENT":   3,
	"DECAP_TYPE_GENEVE":    4,
	"DECAP_TYPE_VXLAN_NSH": 5,
}
View Source 
var DeviceType_name = map[int32]string{
	0:  "DEVICE_TYPE_UNKNOWN",
	1:  "DEVICE_TYPE_VM",
	2:  "DEVICE_TYPE_VGW",
	3:  "DEVICE_TYPE_THIRD_PARTY_DEVICE",
	4:  "DEVICE_TYPE_VMWAF",
	5:  "DEVICE_TYPE_NSP_VGATEWAY",
	6:  "DEVICE_TYPE_HOST_DEVICE",
	7:  "DEVICE_TYPE_NETWORK_DEVICE",
	9:  "DEVICE_TYPE_DHCP_PORT",
	10: "DEVICE_TYPE_POD",
	11: "DEVICE_TYPE_POD_SERVICE",
	12: "DEVICE_TYPE_REDIS_INSTANCE",
	13: "DEVICE_TYPE_RDS_INSTANCE",
	14: "DEVICE_TYPE_POD_NODE",
	15: "DEVICE_TYPE_LOAD_BALANCE",
	16: "DEVICE_TYPE_NAT_GATEWAY",
}
View Source 
var DeviceType_value = map[string]int32{
	"DEVICE_TYPE_UNKNOWN":            0,
	"DEVICE_TYPE_VM":                 1,
	"DEVICE_TYPE_VGW":                2,
	"DEVICE_TYPE_THIRD_PARTY_DEVICE": 3,
	"DEVICE_TYPE_VMWAF":              4,
	"DEVICE_TYPE_NSP_VGATEWAY":       5,
	"DEVICE_TYPE_HOST_DEVICE":        6,
	"DEVICE_TYPE_NETWORK_DEVICE":     7,
	"DEVICE_TYPE_DHCP_PORT":          9,
	"DEVICE_TYPE_POD":                10,
	"DEVICE_TYPE_POD_SERVICE":        11,
	"DEVICE_TYPE_REDIS_INSTANCE":     12,
	"DEVICE_TYPE_RDS_INSTANCE":       13,
	"DEVICE_TYPE_POD_NODE":           14,
	"DEVICE_TYPE_LOAD_BALANCE":       15,
	"DEVICE_TYPE_NAT_GATEWAY":        16,
}
View Source 
var Direction_name = map[int32]string{
	1: "ALL",
	2: "FORWARD",
	3: "BACKWARD",
}
View Source 
var Direction_value = map[string]int32{
	"ALL":      1,
	"FORWARD":  2,
	"BACKWARD": 3,
}
View Source 
var Exception_name = map[int32]string{
	0:       "NORMAL",
	1:       "DISK_NOT_ENOUGH",
	2:       "MEM_NOT_ENOUGH",
	4:       "COREFILE_TOO_MANY",
	8:       "NPB_FUSE",
	16:      "NPB_BPS_THRESHOLD_EXCEEDED",
	32:      "NPB_NO_GW_ARP",
	64:      "RX_PPS_THRESHOLD_EXCEEDED",
	128:     "ANALYZER_NO_GW_ARP",
	256:     "INVALID_CONFIGURATION",
	512:     "THREAD_THRESHOLD_EXCEEDED",
	1024:    "PROCESS_THRESHOLD_EXCEEDED",
	4096:    "TOO_MANY_POLICIES",
	8192:    "FREE_MEM_EXCEEDED",
	16384:   "LOG_FILE_EXCEEDED",
	32768:   "CONTROLLER_SOCKET_ERROR",
	65536:   "ANALYZER_SOCKET_ERROR",
	131072:  "NPB_SOCKET_ERROR",
	262144:  "INTEGRATION_SOCKET_ERROR",
	524288:  "CGROUPS_CONFIG_ERROR",
	1048576: "SYSTEM_LOAD_CIRCUIT_BREAKER",
	2097152: "DATA_BPS_THRESHOLD_EXCEEDED",
	4194304: "FREE_DISK_CIRCUIT_BREAKER",
	8388608: "KERNEL_VERSION_CIRCUIT_BREAKER",
}
View Source 
var Exception_value = map[string]int32{
	"NORMAL":                         0,
	"DISK_NOT_ENOUGH":                1,
	"MEM_NOT_ENOUGH":                 2,
	"COREFILE_TOO_MANY":              4,
	"NPB_FUSE":                       8,
	"NPB_BPS_THRESHOLD_EXCEEDED":     16,
	"NPB_NO_GW_ARP":                  32,
	"RX_PPS_THRESHOLD_EXCEEDED":      64,
	"ANALYZER_NO_GW_ARP":             128,
	"INVALID_CONFIGURATION":          256,
	"THREAD_THRESHOLD_EXCEEDED":      512,
	"PROCESS_THRESHOLD_EXCEEDED":     1024,
	"TOO_MANY_POLICIES":              4096,
	"FREE_MEM_EXCEEDED":              8192,
	"LOG_FILE_EXCEEDED":              16384,
	"CONTROLLER_SOCKET_ERROR":        32768,
	"ANALYZER_SOCKET_ERROR":          65536,
	"NPB_SOCKET_ERROR":               131072,
	"INTEGRATION_SOCKET_ERROR":       262144,
	"CGROUPS_CONFIG_ERROR":           524288,
	"SYSTEM_LOAD_CIRCUIT_BREAKER":    1048576,
	"DATA_BPS_THRESHOLD_EXCEEDED":    2097152,
	"FREE_DISK_CIRCUIT_BREAKER":      4194304,
	"KERNEL_VERSION_CIRCUIT_BREAKER": 8388608,
}
View Source 
var ExecutionType_name = map[int32]string{
	0: "LIST_COMMAND",
	1: "LIST_NAMESPACE",
	2: "RUN_COMMAND",
	3: "DRY_REPLAY_PCAP",
}
View Source 
var ExecutionType_value = map[string]int32{
	"LIST_COMMAND":    0,
	"LIST_NAMESPACE":  1,
	"RUN_COMMAND":     2,
	"DRY_REPLAY_PCAP": 3,
}
View Source 
var GPIDSyncCompressAlgorithm_name = map[int32]string{
	0: "COMPRESS_ALRO_NONE",
	1: "COMPRESS_ALGO_IGNORE_IF_EQUAL_TO_PREVIOUS",
}
View Source 
var GPIDSyncCompressAlgorithm_value = map[string]int32{
	"COMPRESS_ALRO_NONE":                        0,
	"COMPRESS_ALGO_IGNORE_IF_EQUAL_TO_PREVIOUS": 1,
}
View Source 
var GroupType_name = map[int32]string{
	0: "NAMED",
	1: "ANONYMOUS",
}
View Source 
var GroupType_value = map[string]int32{
	"NAMED":     0,
	"ANONYMOUS": 1,
}
View Source 
var IfMacSource_name = map[int32]string{
	0: "IF_MAC",
	1: "IF_NAME",
	2: "IF_LIBVIRT_XML",
}
View Source 
var IfMacSource_value = map[string]int32{
	"IF_MAC":         0,
	"IF_NAME":        1,
	"IF_LIBVIRT_XML": 2,
}
View Source 
var KubernetesWatchPolicy_name = map[int32]string{
	0: "KWP_NORMAL",
	1: "KWP_WATCH_ONLY",
	2: "KWP_WATCH_DISABLED",
}
View Source 
var KubernetesWatchPolicy_value = map[string]int32{
	"KWP_NORMAL":         0,
	"KWP_WATCH_ONLY":     1,
	"KWP_WATCH_DISABLED": 2,
}
View Source 
var OutputFormat_name = map[int32]string{
	0: "TEXT",
	1: "BINARY",
}
View Source 
var OutputFormat_value = map[string]int32{
	"TEXT":   0,
	"BINARY": 1,
}
View Source 
var PacketCaptureSide_name = map[int32]string{
	1: "SRC",
	2: "DST",
	3: "BOTH",
}
View Source 
var PacketCaptureSide_value = map[string]int32{
	"SRC":  1,
	"DST":  2,
	"BOTH": 3,
}
View Source 
var PacketCaptureType_name = map[int32]string{
	0: "LOCAL",
	1: "MIRROR",
	2: "ANALYZER",
	3: "DECAP",
}
View Source 
var PacketCaptureType_value = map[string]int32{
	"LOCAL":    0,
	"MIRROR":   1,
	"ANALYZER": 2,
	"DECAP":    3,
}
View Source 
var PacketType_name = map[int32]string{
	1: "PACKET",
	2: "SFLOW",
	3: "NETFLOW_V5",
	4: "NETSTREAM_V5",
	5: "NETFLOW_V9",
	6: "NETSTREAM_V9",
}
View Source 
var PacketType_value = map[string]int32{
	"PACKET":       1,
	"SFLOW":        2,
	"NETFLOW_V5":   3,
	"NETSTREAM_V5": 4,
	"NETFLOW_V9":   5,
	"NETSTREAM_V9": 6,
}
View Source 
var ParamType_name = map[int32]string{
	0: "PF_TEXT",
	1: "PF_BOOLEAN",
}
View Source 
var ParamType_value = map[string]int32{
	"PF_TEXT":    0,
	"PF_BOOLEAN": 1,
}
View Source 
var PluginType_name = map[int32]string{
	1: "WASM",
	2: "SO",
}
View Source 
var PluginType_value = map[string]int32{
	"WASM": 1,
	"SO":   2,
}
View Source 
var RoleType_name = map[int32]string{
	0: "ROLE_NONE",
	1: "ROLE_CLIENT",
	2: "ROLE_SERVER",
}
View Source 
var RoleType_value = map[string]int32{
	"ROLE_NONE":   0,
	"ROLE_CLIENT": 1,
	"ROLE_SERVER": 2,
}
View Source 
var ServiceProtocol_name = map[int32]string{
	0: "ANY",
	1: "TCP_SERVICE",
	2: "UDP_SERVICE",
}
View Source 
var ServiceProtocol_value = map[string]int32{
	"ANY":         0,
	"TCP_SERVICE": 1,
	"UDP_SERVICE": 2,
}
View Source 
var SocketType_name = map[int32]string{
	0: "RAW_UDP",
	1: "TCP",
	2: "UDP",
	3: "FILE",
	4: "ZMQ",
}
View Source 
var SocketType_value = map[string]int32{
	"RAW_UDP": 0,
	"TCP":     1,
	"UDP":     2,
	"FILE":    3,
	"ZMQ":     4,
}
View Source 
var State_name = map[int32]string{
	0: "ENVIRONMENT_CHECK",
	1: "DISABLED",
	2: "RUNNING",
	3: "REBOOTING",
	4: "STRESSED",
	5: "RESTRICTED",
}
View Source 
var State_value = map[string]int32{
	"ENVIRONMENT_CHECK": 0,
	"DISABLED":          1,
	"RUNNING":           2,
	"REBOOTING":         3,
	"STRESSED":          4,
	"RESTRICTED":        5,
}
View Source 
var Status_name = map[int32]string{
	0:  "SUCCESS",
	1:  "FAILED",
	2:  "HEARTBEAT",
	10: "CLUSTER_ID_NOT_FOUND",
}
View Source 
var Status_value = map[string]int32{
	"SUCCESS":              0,
	"FAILED":               1,
	"HEARTBEAT":            2,
	"CLUSTER_ID_NOT_FOUND": 10,
}
View Source 
var SysMemoryMetric_name = map[int32]string{
	0: "Free",
	1: "Available",
}
View Source 
var SysMemoryMetric_value = map[string]int32{
	"Free":      0,
	"Available": 1,
}
View Source 
var SystemLoadMetric_name = map[int32]string{
	0: "Load1",
	1: "Load5",
	2: "Load15",
}
View Source 
var SystemLoadMetric_value = map[string]int32{
	"Load1":  0,
	"Load5":  1,
	"Load15": 2,
}
View Source 
var TunnelType_name = map[int32]string{
	0: "VXLAN",
	1: "GRE_ERSPAN",
	2: "PCAP",
	3: "NPB_DROP",
}
View Source 
var TunnelType_value = map[string]int32{
	"VXLAN":      0,
	"GRE_ERSPAN": 1,
	"PCAP":       2,
	"NPB_DROP":   3,
}
View Source 
var VlanMode_name = map[int32]string{
	0: "NONE",
	1: "VLAN",
	2: "QINQ",
}
View Source 
var VlanMode_value = map[string]int32{
	"NONE": 0,
	"VLAN": 1,
	"QINQ": 2,
}

Functions

func RegisterDebugServer 

func RegisterDebugServer(s *grpc.Server, srv DebugServer)

func RegisterSynchronizerServer 

func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)

Types

type Action 

type Action int32
const (
	Action_PACKET_CAPTURING Action = 1
)

func (Action) Enum 

func (x Action) Enum() *Action

func (Action) EnumDescriptor 

func (Action) EnumDescriptor() ([]byte, []int)

func (Action) String 

func (x Action) String() string

func (*Action) UnmarshalJSON 

func (x *Action) UnmarshalJSON(data []byte) error

type AgentCacheRequest 

type AgentCacheRequest struct {
	CtrlIp               *string  `protobuf:"bytes,1,opt,name=ctrl_ip,json=ctrlIp" json:"ctrl_ip,omitempty"`
	CtrlMac              *string  `protobuf:"bytes,2,opt,name=ctrl_mac,json=ctrlMac" json:"ctrl_mac,omitempty"`
	TeamId               *string  `protobuf:"bytes,3,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentCacheRequest) Descriptor 

func (*AgentCacheRequest) Descriptor() ([]byte, []int)

func (*AgentCacheRequest) GetCtrlIp 

func (m *AgentCacheRequest) GetCtrlIp() string

func (*AgentCacheRequest) GetCtrlMac 

func (m *AgentCacheRequest) GetCtrlMac() string

func (*AgentCacheRequest) GetTeamId 

func (m *AgentCacheRequest) GetTeamId() string

func (*AgentCacheRequest) Marshal 

func (m *AgentCacheRequest) Marshal() (dAtA []byte, err error)

func (*AgentCacheRequest) MarshalTo 

func (m *AgentCacheRequest) MarshalTo(dAtA []byte) (int, error)

func (*AgentCacheRequest) MarshalToSizedBuffer 

func (m *AgentCacheRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentCacheRequest) ProtoMessage 

func (*AgentCacheRequest) ProtoMessage()

func (*AgentCacheRequest) Reset 

func (m *AgentCacheRequest) Reset()

func (*AgentCacheRequest) Size 

func (m *AgentCacheRequest) Size() (n int)

func (*AgentCacheRequest) String 

func (m *AgentCacheRequest) String() string

func (*AgentCacheRequest) Unmarshal 

func (m *AgentCacheRequest) Unmarshal(dAtA []byte) error

func (*AgentCacheRequest) XXX_DiscardUnknown 

func (m *AgentCacheRequest) XXX_DiscardUnknown()

func (*AgentCacheRequest) XXX_Marshal 

func (m *AgentCacheRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentCacheRequest) XXX_Merge 

func (m *AgentCacheRequest) XXX_Merge(src proto.Message)

func (*AgentCacheRequest) XXX_Size 

func (m *AgentCacheRequest) XXX_Size() int

func (*AgentCacheRequest) XXX_Unmarshal 

func (m *AgentCacheRequest) XXX_Unmarshal(b []byte) error

type AgentCacheResponse 

type AgentCacheResponse struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentCacheResponse) Descriptor 

func (*AgentCacheResponse) Descriptor() ([]byte, []int)

func (*AgentCacheResponse) GetContent 

func (m *AgentCacheResponse) GetContent() []byte

func (*AgentCacheResponse) Marshal 

func (m *AgentCacheResponse) Marshal() (dAtA []byte, err error)

func (*AgentCacheResponse) MarshalTo 

func (m *AgentCacheResponse) MarshalTo(dAtA []byte) (int, error)

func (*AgentCacheResponse) MarshalToSizedBuffer 

func (m *AgentCacheResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentCacheResponse) ProtoMessage 

func (*AgentCacheResponse) ProtoMessage()

func (*AgentCacheResponse) Reset 

func (m *AgentCacheResponse) Reset()

func (*AgentCacheResponse) Size 

func (m *AgentCacheResponse) Size() (n int)

func (*AgentCacheResponse) String 

func (m *AgentCacheResponse) String() string

func (*AgentCacheResponse) Unmarshal 

func (m *AgentCacheResponse) Unmarshal(dAtA []byte) error

func (*AgentCacheResponse) XXX_DiscardUnknown 

func (m *AgentCacheResponse) XXX_DiscardUnknown()

func (*AgentCacheResponse) XXX_Marshal 

func (m *AgentCacheResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentCacheResponse) XXX_Merge 

func (m *AgentCacheResponse) XXX_Merge(src proto.Message)

func (*AgentCacheResponse) XXX_Size 

func (m *AgentCacheResponse) XXX_Size() int

func (*AgentCacheResponse) XXX_Unmarshal 

func (m *AgentCacheResponse) XXX_Unmarshal(b []byte) error

type AgentId 

type AgentId struct {
	Ip                   *string  `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Mac                  *string  `protobuf:"bytes,2,opt,name=mac" json:"mac,omitempty"`
	TeamId               *string  `protobuf:"bytes,3,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	GroupId              *string  `protobuf:"bytes,4,opt,name=group_id,json=groupId" json:"group_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentId) Descriptor 

func (*AgentId) Descriptor() ([]byte, []int)

func (*AgentId) GetGroupId 

func (m *AgentId) GetGroupId() string

func (*AgentId) GetIp 

func (m *AgentId) GetIp() string

func (*AgentId) GetMac 

func (m *AgentId) GetMac() string

func (*AgentId) GetTeamId 

func (m *AgentId) GetTeamId() string

func (*AgentId) Marshal 

func (m *AgentId) Marshal() (dAtA []byte, err error)

func (*AgentId) MarshalTo 

func (m *AgentId) MarshalTo(dAtA []byte) (int, error)

func (*AgentId) MarshalToSizedBuffer 

func (m *AgentId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentId) ProtoMessage 

func (*AgentId) ProtoMessage()

func (*AgentId) Reset 

func (m *AgentId) Reset()

func (*AgentId) Size 

func (m *AgentId) Size() (n int)

func (*AgentId) String 

func (m *AgentId) String() string

func (*AgentId) Unmarshal 

func (m *AgentId) Unmarshal(dAtA []byte) error

func (*AgentId) XXX_DiscardUnknown 

func (m *AgentId) XXX_DiscardUnknown()

func (*AgentId) XXX_Marshal 

func (m *AgentId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentId) XXX_Merge 

func (m *AgentId) XXX_Merge(src proto.Message)

func (*AgentId) XXX_Size 

func (m *AgentId) XXX_Size() int

func (*AgentId) XXX_Unmarshal 

func (m *AgentId) XXX_Unmarshal(b []byte) error

type AgentIdentifier 

type AgentIdentifier int32
const (
	AgentIdentifier_IP_AND_MAC AgentIdentifier = 1
	AgentIdentifier_IP         AgentIdentifier = 2
)
const Default_SyncRequest_AgentUniqueIdentifier AgentIdentifier = AgentIdentifier_IP_AND_MAC

func (AgentIdentifier) Enum 

func (x AgentIdentifier) Enum() *AgentIdentifier

func (AgentIdentifier) EnumDescriptor 

func (AgentIdentifier) EnumDescriptor() ([]byte, []int)

func (AgentIdentifier) String 

func (x AgentIdentifier) String() string

func (*AgentIdentifier) UnmarshalJSON 

func (x *AgentIdentifier) UnmarshalJSON(data []byte) error

type AgentType 

type AgentType int32
const (
	AgentType_TT_UNKNOWN      AgentType = 0
	AgentType_TT_PROCESS      AgentType = 1
	AgentType_TT_VM           AgentType = 2
	AgentType_TT_PUBLIC_CLOUD AgentType = 3
	// _ = 4;                              // --deprecated--
	AgentType_TT_PHYSICAL_MACHINE           AgentType = 5
	AgentType_TT_DEDICATED_PHYSICAL_MACHINE AgentType = 6
	AgentType_TT_HOST_POD                   AgentType = 7
	AgentType_TT_VM_POD                     AgentType = 8
	AgentType_TT_TUNNEL_DECAPSULATION       AgentType = 9
	AgentType_TT_HYPER_V_COMPUTE            AgentType = 10
	AgentType_TT_HYPER_V_NETWORK            AgentType = 11
	AgentType_TT_K8S_SIDECAR                AgentType = 12
)

func (AgentType) Enum 

func (x AgentType) Enum() *AgentType

func (AgentType) EnumDescriptor 

func (AgentType) EnumDescriptor() ([]byte, []int)

func (AgentType) String 

func (x AgentType) String() string

func (*AgentType) UnmarshalJSON 

func (x *AgentType) UnmarshalJSON(data []byte) error

type CaptureNetworkType 

type CaptureNetworkType struct {
	CaptureNetworkType   *uint32     `protobuf:"varint,1,opt,name=capture_network_type,json=captureNetworkType" json:"capture_network_type,omitempty"`
	PacketType           *PacketType `protobuf:"varint,2,opt,name=packet_type,json=packetType,enum=agent.PacketType" json:"packet_type,omitempty"`
	Vlan                 *uint32     `protobuf:"varint,3,opt,name=vlan" json:"vlan,omitempty"`
	SourceIp             *string     `protobuf:"bytes,4,opt,name=source_ip,json=sourceIp" json:"source_ip,omitempty"`
	CaptureNetworkPort   *uint32     `protobuf:"varint,5,opt,name=capture_network_port,json=captureNetworkPort" json:"capture_network_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CaptureNetworkType) Descriptor 

func (*CaptureNetworkType) Descriptor() ([]byte, []int)

func (*CaptureNetworkType) GetCaptureNetworkPort 

func (m *CaptureNetworkType) GetCaptureNetworkPort() uint32

func (*CaptureNetworkType) GetCaptureNetworkType 

func (m *CaptureNetworkType) GetCaptureNetworkType() uint32

func (*CaptureNetworkType) GetPacketType 

func (m *CaptureNetworkType) GetPacketType() PacketType

func (*CaptureNetworkType) GetSourceIp 

func (m *CaptureNetworkType) GetSourceIp() string

func (*CaptureNetworkType) GetVlan 

func (m *CaptureNetworkType) GetVlan() uint32

func (*CaptureNetworkType) Marshal 

func (m *CaptureNetworkType) Marshal() (dAtA []byte, err error)

func (*CaptureNetworkType) MarshalTo 

func (m *CaptureNetworkType) MarshalTo(dAtA []byte) (int, error)

func (*CaptureNetworkType) MarshalToSizedBuffer 

func (m *CaptureNetworkType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CaptureNetworkType) ProtoMessage 

func (*CaptureNetworkType) ProtoMessage()

func (*CaptureNetworkType) Reset 

func (m *CaptureNetworkType) Reset()

func (*CaptureNetworkType) Size 

func (m *CaptureNetworkType) Size() (n int)

func (*CaptureNetworkType) String 

func (m *CaptureNetworkType) String() string

func (*CaptureNetworkType) Unmarshal 

func (m *CaptureNetworkType) Unmarshal(dAtA []byte) error

func (*CaptureNetworkType) XXX_DiscardUnknown 

func (m *CaptureNetworkType) XXX_DiscardUnknown()

func (*CaptureNetworkType) XXX_Marshal 

func (m *CaptureNetworkType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CaptureNetworkType) XXX_Merge 

func (m *CaptureNetworkType) XXX_Merge(src proto.Message)

func (*CaptureNetworkType) XXX_Size 

func (m *CaptureNetworkType) XXX_Size() int

func (*CaptureNetworkType) XXX_Unmarshal 

func (m *CaptureNetworkType) XXX_Unmarshal(b []byte) error

type CaptureSocketType 

type CaptureSocketType int32
const (
	CaptureSocketType_AUTO         CaptureSocketType = 0
	CaptureSocketType_AF_PACKET_V1 CaptureSocketType = 1
	CaptureSocketType_AF_PACKET_V2 CaptureSocketType = 2
	CaptureSocketType_AF_PACKET_V3 CaptureSocketType = 3
)

func (CaptureSocketType) Enum 

func (x CaptureSocketType) Enum() *CaptureSocketType

func (CaptureSocketType) EnumDescriptor 

func (CaptureSocketType) EnumDescriptor() ([]byte, []int)

func (CaptureSocketType) String 

func (x CaptureSocketType) String() string

func (*CaptureSocketType) UnmarshalJSON 

func (x *CaptureSocketType) UnmarshalJSON(data []byte) error

type Cidr 

type Cidr struct {
	Prefix               *string   `protobuf:"bytes,1,opt,name=prefix" json:"prefix,omitempty"`
	Type                 *CidrType `protobuf:"varint,2,opt,name=type,enum=agent.CidrType" json:"type,omitempty"`
	EpcId                *int32    `protobuf:"varint,3,opt,name=epc_id,json=epcId" json:"epc_id,omitempty"`
	RegionId             *uint32   `protobuf:"varint,4,opt,name=region_id,json=regionId" json:"region_id,omitempty"`
	TunnelId             *uint32   `protobuf:"varint,5,opt,name=tunnel_id,json=tunnelId" json:"tunnel_id,omitempty"`
	IsVip                *bool     `protobuf:"varint,20,opt,name=is_vip,json=isVip,def=0" json:"is_vip,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Cidr) Descriptor 

func (*Cidr) Descriptor() ([]byte, []int)

func (*Cidr) GetEpcId 

func (m *Cidr) GetEpcId() int32

func (*Cidr) GetIsVip 

func (m *Cidr) GetIsVip() bool

func (*Cidr) GetPrefix 

func (m *Cidr) GetPrefix() string

func (*Cidr) GetRegionId 

func (m *Cidr) GetRegionId() uint32

func (*Cidr) GetTunnelId 

func (m *Cidr) GetTunnelId() uint32

func (*Cidr) GetType 

func (m *Cidr) GetType() CidrType

func (*Cidr) Marshal 

func (m *Cidr) Marshal() (dAtA []byte, err error)

func (*Cidr) MarshalTo 

func (m *Cidr) MarshalTo(dAtA []byte) (int, error)

func (*Cidr) MarshalToSizedBuffer 

func (m *Cidr) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cidr) ProtoMessage 

func (*Cidr) ProtoMessage()

func (*Cidr) Reset 

func (m *Cidr) Reset()

func (*Cidr) Size 

func (m *Cidr) Size() (n int)

func (*Cidr) String 

func (m *Cidr) String() string

func (*Cidr) Unmarshal 

func (m *Cidr) Unmarshal(dAtA []byte) error

func (*Cidr) XXX_DiscardUnknown 

func (m *Cidr) XXX_DiscardUnknown()

func (*Cidr) XXX_Marshal 

func (m *Cidr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cidr) XXX_Merge 

func (m *Cidr) XXX_Merge(src proto.Message)

func (*Cidr) XXX_Size 

func (m *Cidr) XXX_Size() int

func (*Cidr) XXX_Unmarshal 

func (m *Cidr) XXX_Unmarshal(b []byte) error

type CidrType 

type CidrType int32
const (
	CidrType_WAN CidrType = 1
	CidrType_LAN CidrType = 2
)

func (CidrType) Enum 

func (x CidrType) Enum() *CidrType

func (CidrType) EnumDescriptor 

func (CidrType) EnumDescriptor() ([]byte, []int)

func (CidrType) String 

func (x CidrType) String() string

func (*CidrType) UnmarshalJSON 

func (x *CidrType) UnmarshalJSON(data []byte) error

type CommandParam 

type CommandParam struct {
	Name                 *string    `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Regex                *string    `protobuf:"bytes,2,opt,name=regex" json:"regex,omitempty"`
	Required             *bool      `protobuf:"varint,3,opt,name=required" json:"required,omitempty"`
	ParamType            *ParamType `protobuf:"varint,4,opt,name=param_type,json=paramType,enum=agent.ParamType" json:"param_type,omitempty"`
	Description          *string    `protobuf:"bytes,5,opt,name=description" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CommandParam) Descriptor 

func (*CommandParam) Descriptor() ([]byte, []int)

func (*CommandParam) GetDescription 

func (m *CommandParam) GetDescription() string

func (*CommandParam) GetName 

func (m *CommandParam) GetName() string

func (*CommandParam) GetParamType 

func (m *CommandParam) GetParamType() ParamType

func (*CommandParam) GetRegex 

func (m *CommandParam) GetRegex() string

func (*CommandParam) GetRequired 

func (m *CommandParam) GetRequired() bool

func (*CommandParam) Marshal 

func (m *CommandParam) Marshal() (dAtA []byte, err error)

func (*CommandParam) MarshalTo 

func (m *CommandParam) MarshalTo(dAtA []byte) (int, error)

func (*CommandParam) MarshalToSizedBuffer 

func (m *CommandParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandParam) ProtoMessage 

func (*CommandParam) ProtoMessage()

func (*CommandParam) Reset 

func (m *CommandParam) Reset()

func (*CommandParam) Size 

func (m *CommandParam) Size() (n int)

func (*CommandParam) String 

func (m *CommandParam) String() string

func (*CommandParam) Unmarshal 

func (m *CommandParam) Unmarshal(dAtA []byte) error

func (*CommandParam) XXX_DiscardUnknown 

func (m *CommandParam) XXX_DiscardUnknown()

func (*CommandParam) XXX_Marshal 

func (m *CommandParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandParam) XXX_Merge 

func (m *CommandParam) XXX_Merge(src proto.Message)

func (*CommandParam) XXX_Size 

func (m *CommandParam) XXX_Size() int

func (*CommandParam) XXX_Unmarshal 

func (m *CommandParam) XXX_Unmarshal(b []byte) error

type CommandType 

type CommandType int32
const (
	CommandType_LINUX      CommandType = 0
	CommandType_KUBERNETES CommandType = 1
)

func (CommandType) Enum 

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor 

func (CommandType) EnumDescriptor() ([]byte, []int)

func (CommandType) String 

func (x CommandType) String() string

func (*CommandType) UnmarshalJSON 

func (x *CommandType) UnmarshalJSON(data []byte) error

type Container 

type Container struct {
	PodId                *uint32  `protobuf:"varint,1,opt,name=pod_id,json=podId" json:"pod_id,omitempty"`
	ContainerId          *string  `protobuf:"bytes,2,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Container) Descriptor 

func (*Container) Descriptor() ([]byte, []int)

func (*Container) GetContainerId 

func (m *Container) GetContainerId() string

func (*Container) GetPodId 

func (m *Container) GetPodId() uint32

func (*Container) Marshal 

func (m *Container) Marshal() (dAtA []byte, err error)

func (*Container) MarshalTo 

func (m *Container) MarshalTo(dAtA []byte) (int, error)

func (*Container) MarshalToSizedBuffer 

func (m *Container) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) Size 

func (m *Container) Size() (n int)

func (*Container) String 

func (m *Container) String() string

func (*Container) Unmarshal 

func (m *Container) Unmarshal(dAtA []byte) error

func (*Container) XXX_DiscardUnknown 

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal 

func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Container) XXX_Merge 

func (m *Container) XXX_Merge(src proto.Message)

func (*Container) XXX_Size 

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal 

func (m *Container) XXX_Unmarshal(b []byte) error

type CustomAppConfig 

type CustomAppConfig struct {
	Version    *uint64 `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	Compressed *bool   `protobuf:"varint,2,opt,name=compressed" json:"compressed,omitempty"`
	// config string that is one of:
	// - UTF-8 encoded YAML
	// - ZSTD compressed UTF-8 encoded YAML (if `compressed` is true)
	Configs              []byte   `protobuf:"bytes,10,opt,name=configs" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CustomAppConfig) Descriptor 

func (*CustomAppConfig) Descriptor() ([]byte, []int)

func (*CustomAppConfig) GetCompressed 

func (m *CustomAppConfig) GetCompressed() bool

func (*CustomAppConfig) GetConfigs 

func (m *CustomAppConfig) GetConfigs() []byte

func (*CustomAppConfig) GetVersion 

func (m *CustomAppConfig) GetVersion() uint64

func (*CustomAppConfig) Marshal 

func (m *CustomAppConfig) Marshal() (dAtA []byte, err error)

func (*CustomAppConfig) MarshalTo 

func (m *CustomAppConfig) MarshalTo(dAtA []byte) (int, error)

func (*CustomAppConfig) MarshalToSizedBuffer 

func (m *CustomAppConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CustomAppConfig) ProtoMessage 

func (*CustomAppConfig) ProtoMessage()

func (*CustomAppConfig) Reset 

func (m *CustomAppConfig) Reset()

func (*CustomAppConfig) Size 

func (m *CustomAppConfig) Size() (n int)

func (*CustomAppConfig) String 

func (m *CustomAppConfig) String() string

func (*CustomAppConfig) Unmarshal 

func (m *CustomAppConfig) Unmarshal(dAtA []byte) error

func (*CustomAppConfig) XXX_DiscardUnknown 

func (m *CustomAppConfig) XXX_DiscardUnknown()

func (*CustomAppConfig) XXX_Marshal 

func (m *CustomAppConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CustomAppConfig) XXX_Merge 

func (m *CustomAppConfig) XXX_Merge(src proto.Message)

func (*CustomAppConfig) XXX_Size 

func (m *CustomAppConfig) XXX_Size() int

func (*CustomAppConfig) XXX_Unmarshal 

func (m *CustomAppConfig) XXX_Unmarshal(b []byte) error

type DataChunk 

type DataChunk struct {
	Errno   *int32 `protobuf:"varint,1,opt,name=errno" json:"errno,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content" json:"content,omitempty"`
	// will only be populated in the last segment
	// also used as end of result
	Md5                  *string  `protobuf:"bytes,3,opt,name=md5" json:"md5,omitempty"`
	TotalLen             *uint64  `protobuf:"varint,4,opt,name=total_len,json=totalLen" json:"total_len,omitempty"`
	PktCount             *uint32  `protobuf:"varint,5,opt,name=pkt_count,json=pktCount" json:"pkt_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataChunk) Descriptor 

func (*DataChunk) Descriptor() ([]byte, []int)

func (*DataChunk) GetContent 

func (m *DataChunk) GetContent() []byte

func (*DataChunk) GetErrno 

func (m *DataChunk) GetErrno() int32

func (*DataChunk) GetMd5 

func (m *DataChunk) GetMd5() string

func (*DataChunk) GetPktCount 

func (m *DataChunk) GetPktCount() uint32

func (*DataChunk) GetTotalLen 

func (m *DataChunk) GetTotalLen() uint64

func (*DataChunk) Marshal 

func (m *DataChunk) Marshal() (dAtA []byte, err error)

func (*DataChunk) MarshalTo 

func (m *DataChunk) MarshalTo(dAtA []byte) (int, error)

func (*DataChunk) MarshalToSizedBuffer 

func (m *DataChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataChunk) ProtoMessage 

func (*DataChunk) ProtoMessage()

func (*DataChunk) Reset 

func (m *DataChunk) Reset()

func (*DataChunk) Size 

func (m *DataChunk) Size() (n int)

func (*DataChunk) String 

func (m *DataChunk) String() string

func (*DataChunk) Unmarshal 

func (m *DataChunk) Unmarshal(dAtA []byte) error

func (*DataChunk) XXX_DiscardUnknown 

func (m *DataChunk) XXX_DiscardUnknown()

func (*DataChunk) XXX_Marshal 

func (m *DataChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataChunk) XXX_Merge 

func (m *DataChunk) XXX_Merge(src proto.Message)

func (*DataChunk) XXX_Size 

func (m *DataChunk) XXX_Size() int

func (*DataChunk) XXX_Unmarshal 

func (m *DataChunk) XXX_Unmarshal(b []byte) error

type DebugClient 

type DebugClient interface {
	DebugGPIDGlobalData(ctx context.Context, in *GPIDSyncRequest, opts ...grpc.CallOption) (*GPIDGlobalData, error)
	DebugGPIDAgentData(ctx context.Context, in *GPIDSyncRequest, opts ...grpc.CallOption) (*GPIDAgentData, error)
	DebugRealGlobalData(ctx context.Context, in *GPIDSyncRequest, opts ...grpc.CallOption) (*RealGlobalData, error)
	DebugRIPToVIP(ctx context.Context, in *GPIDSyncRequest, opts ...grpc.CallOption) (*RVData, error)
	DebugAgentCache(ctx context.Context, in *AgentCacheRequest, opts ...grpc.CallOption) (*AgentCacheResponse, error)
}

DebugClient is the client API for Debug service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDebugClient 

func NewDebugClient(cc *grpc.ClientConn) DebugClient

type DebugServer 

type DebugServer interface {
	DebugGPIDGlobalData(context.Context, *GPIDSyncRequest) (*GPIDGlobalData, error)
	DebugGPIDAgentData(context.Context, *GPIDSyncRequest) (*GPIDAgentData, error)
	DebugRealGlobalData(context.Context, *GPIDSyncRequest) (*RealGlobalData, error)
	DebugRIPToVIP(context.Context, *GPIDSyncRequest) (*RVData, error)
	DebugAgentCache(context.Context, *AgentCacheRequest) (*AgentCacheResponse, error)
}

DebugServer is the server API for Debug service.

type DecapType 

type DecapType int32
const (
	DecapType_DECAP_TYPE_NONE      DecapType = 0
	DecapType_DECAP_TYPE_VXLAN     DecapType = 1
	DecapType_DECAP_TYPE_IPIP      DecapType = 2
	DecapType_DECAP_TYPE_TENCENT   DecapType = 3
	DecapType_DECAP_TYPE_GENEVE    DecapType = 4
	DecapType_DECAP_TYPE_VXLAN_NSH DecapType = 5
)

func (DecapType) Enum 

func (x DecapType) Enum() *DecapType

func (DecapType) EnumDescriptor 

func (DecapType) EnumDescriptor() ([]byte, []int)

func (DecapType) String 

func (x DecapType) String() string

func (*DecapType) UnmarshalJSON 

func (x *DecapType) UnmarshalJSON(data []byte) error

type DeviceType 

type DeviceType int32
const (
	DeviceType_DEVICE_TYPE_UNKNOWN            DeviceType = 0
	DeviceType_DEVICE_TYPE_VM                 DeviceType = 1
	DeviceType_DEVICE_TYPE_VGW                DeviceType = 2
	DeviceType_DEVICE_TYPE_THIRD_PARTY_DEVICE DeviceType = 3
	DeviceType_DEVICE_TYPE_VMWAF              DeviceType = 4
	DeviceType_DEVICE_TYPE_NSP_VGATEWAY       DeviceType = 5
	DeviceType_DEVICE_TYPE_HOST_DEVICE        DeviceType = 6
	DeviceType_DEVICE_TYPE_NETWORK_DEVICE     DeviceType = 7
	DeviceType_DEVICE_TYPE_DHCP_PORT          DeviceType = 9
	DeviceType_DEVICE_TYPE_POD                DeviceType = 10
	DeviceType_DEVICE_TYPE_POD_SERVICE        DeviceType = 11
	DeviceType_DEVICE_TYPE_REDIS_INSTANCE     DeviceType = 12
	DeviceType_DEVICE_TYPE_RDS_INSTANCE       DeviceType = 13
	DeviceType_DEVICE_TYPE_POD_NODE           DeviceType = 14
	DeviceType_DEVICE_TYPE_LOAD_BALANCE       DeviceType = 15
	DeviceType_DEVICE_TYPE_NAT_GATEWAY        DeviceType = 16
)

func (DeviceType) Enum 

func (x DeviceType) Enum() *DeviceType

func (DeviceType) EnumDescriptor 

func (DeviceType) EnumDescriptor() ([]byte, []int)

func (DeviceType) String 

func (x DeviceType) String() string

func (*DeviceType) UnmarshalJSON 

func (x *DeviceType) UnmarshalJSON(data []byte) error

type Direction 

type Direction int32
const (
	Direction_ALL      Direction = 1
	Direction_FORWARD  Direction = 2
	Direction_BACKWARD Direction = 3
)
const Default_NpbAction_Direction Direction = Direction_ALL

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor 

func (Direction) EnumDescriptor() ([]byte, []int)

func (Direction) String 

func (x Direction) String() string

func (*Direction) UnmarshalJSON 

func (x *Direction) UnmarshalJSON(data []byte) error

type DynamicConfig 

type DynamicConfig struct {
	KubernetesApiEnabled *bool      `protobuf:"varint,1,opt,name=kubernetes_api_enabled,json=kubernetesApiEnabled" json:"kubernetes_api_enabled,omitempty"`
	Enabled              *bool      `protobuf:"varint,2,opt,name=enabled" json:"enabled,omitempty"`
	RegionId             *uint32    `protobuf:"varint,10,opt,name=region_id,json=regionId" json:"region_id,omitempty"`
	PodClusterId         *uint32    `protobuf:"varint,11,opt,name=pod_cluster_id,json=podClusterId" json:"pod_cluster_id,omitempty"`
	VpcId                *uint32    `protobuf:"varint,12,opt,name=vpc_id,json=vpcId" json:"vpc_id,omitempty"`
	AgentId              *uint32    `protobuf:"varint,13,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	TeamId               *uint32    `protobuf:"varint,14,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	OrganizeId           *uint32    `protobuf:"varint,15,opt,name=organize_id,json=organizeId" json:"organize_id,omitempty"`
	AgentType            *AgentType `protobuf:"varint,16,opt,name=agent_type,json=agentType,enum=agent.AgentType" json:"agent_type,omitempty"`
	SecretKey            *string    `protobuf:"bytes,20,opt,name=secret_key,json=secretKey" json:"secret_key,omitempty"`
	Hostname             *string    `protobuf:"bytes,21,opt,name=hostname" json:"hostname,omitempty"`
	GroupId              *string    `protobuf:"bytes,22,opt,name=group_id,json=groupId" json:"group_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DynamicConfig) Descriptor 

func (*DynamicConfig) Descriptor() ([]byte, []int)

func (*DynamicConfig) GetAgentId 

func (m *DynamicConfig) GetAgentId() uint32

func (*DynamicConfig) GetAgentType 

func (m *DynamicConfig) GetAgentType() AgentType

func (*DynamicConfig) GetEnabled 

func (m *DynamicConfig) GetEnabled() bool

func (*DynamicConfig) GetGroupId 

func (m *DynamicConfig) GetGroupId() string

func (*DynamicConfig) GetHostname 

func (m *DynamicConfig) GetHostname() string

func (*DynamicConfig) GetKubernetesApiEnabled 

func (m *DynamicConfig) GetKubernetesApiEnabled() bool

func (*DynamicConfig) GetOrganizeId 

func (m *DynamicConfig) GetOrganizeId() uint32

func (*DynamicConfig) GetPodClusterId 

func (m *DynamicConfig) GetPodClusterId() uint32

func (*DynamicConfig) GetRegionId 

func (m *DynamicConfig) GetRegionId() uint32

func (*DynamicConfig) GetSecretKey 

func (m *DynamicConfig) GetSecretKey() string

func (*DynamicConfig) GetTeamId 

func (m *DynamicConfig) GetTeamId() uint32

func (*DynamicConfig) GetVpcId 

func (m *DynamicConfig) GetVpcId() uint32

func (*DynamicConfig) Marshal 

func (m *DynamicConfig) Marshal() (dAtA []byte, err error)

func (*DynamicConfig) MarshalTo 

func (m *DynamicConfig) MarshalTo(dAtA []byte) (int, error)

func (*DynamicConfig) MarshalToSizedBuffer 

func (m *DynamicConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DynamicConfig) ProtoMessage 

func (*DynamicConfig) ProtoMessage()

func (*DynamicConfig) Reset 

func (m *DynamicConfig) Reset()

func (*DynamicConfig) Size 

func (m *DynamicConfig) Size() (n int)

func (*DynamicConfig) String 

func (m *DynamicConfig) String() string

func (*DynamicConfig) Unmarshal 

func (m *DynamicConfig) Unmarshal(dAtA []byte) error

func (*DynamicConfig) XXX_DiscardUnknown 

func (m *DynamicConfig) XXX_DiscardUnknown()

func (*DynamicConfig) XXX_Marshal 

func (m *DynamicConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicConfig) XXX_Merge 

func (m *DynamicConfig) XXX_Merge(src proto.Message)

func (*DynamicConfig) XXX_Size 

func (m *DynamicConfig) XXX_Size() int

func (*DynamicConfig) XXX_Unmarshal 

func (m *DynamicConfig) XXX_Unmarshal(b []byte) error

type Exception 

type Exception int32
const (
	Exception_NORMAL                     Exception = 0
	Exception_DISK_NOT_ENOUGH            Exception = 1
	Exception_MEM_NOT_ENOUGH             Exception = 2
	Exception_COREFILE_TOO_MANY          Exception = 4
	Exception_NPB_FUSE                   Exception = 8
	Exception_NPB_BPS_THRESHOLD_EXCEEDED Exception = 16
	Exception_NPB_NO_GW_ARP              Exception = 32
	Exception_RX_PPS_THRESHOLD_EXCEEDED  Exception = 64
	Exception_ANALYZER_NO_GW_ARP         Exception = 128
	Exception_INVALID_CONFIGURATION      Exception = 256
	Exception_THREAD_THRESHOLD_EXCEEDED  Exception = 512
	Exception_PROCESS_THRESHOLD_EXCEEDED Exception = 1024
	// _  = 2048; // deprecate
	Exception_TOO_MANY_POLICIES              Exception = 4096
	Exception_FREE_MEM_EXCEEDED              Exception = 8192
	Exception_LOG_FILE_EXCEEDED              Exception = 16384
	Exception_CONTROLLER_SOCKET_ERROR        Exception = 32768
	Exception_ANALYZER_SOCKET_ERROR          Exception = 65536
	Exception_NPB_SOCKET_ERROR               Exception = 131072
	Exception_INTEGRATION_SOCKET_ERROR       Exception = 262144
	Exception_CGROUPS_CONFIG_ERROR           Exception = 524288
	Exception_SYSTEM_LOAD_CIRCUIT_BREAKER    Exception = 1048576
	Exception_DATA_BPS_THRESHOLD_EXCEEDED    Exception = 2097152
	Exception_FREE_DISK_CIRCUIT_BREAKER      Exception = 4194304
	Exception_KERNEL_VERSION_CIRCUIT_BREAKER Exception = 8388608
)

func (Exception) Enum 

func (x Exception) Enum() *Exception

func (Exception) EnumDescriptor 

func (Exception) EnumDescriptor() ([]byte, []int)

func (Exception) String 

func (x Exception) String() string

func (*Exception) UnmarshalJSON 

func (x *Exception) UnmarshalJSON(data []byte) error

type ExecutionType 

type ExecutionType int32
const (
	ExecutionType_LIST_COMMAND   ExecutionType = 0
	ExecutionType_LIST_NAMESPACE ExecutionType = 1
	ExecutionType_RUN_COMMAND    ExecutionType = 2
	// Sending pcap to agent for biz protocol inferencing and biz decoding.
	// Large pcap should be split into chunks in multiple `RemoteExecRequest`s (in `command_data`).
	// Application protocol and server port can be specified in `params` with the following keys:
	// - l7_protocol
	// - server_port
	// If protocol and server port are set, agent will not try to infer them.
	ExecutionType_DRY_REPLAY_PCAP ExecutionType = 3
)

func (ExecutionType) Enum 

func (x ExecutionType) Enum() *ExecutionType

func (ExecutionType) EnumDescriptor 

func (ExecutionType) EnumDescriptor() ([]byte, []int)

func (ExecutionType) String 

func (x ExecutionType) String() string

func (*ExecutionType) UnmarshalJSON 

func (x *ExecutionType) UnmarshalJSON(data []byte) error

type FlowAcl 

type FlowAcl struct {
	Id                   *uint32      `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	CaptureNetworkType   *uint32      `protobuf:"varint,2,opt,name=capture_network_type,json=captureNetworkType" json:"capture_network_type,omitempty"`
	Protocol             *uint32      `protobuf:"varint,3,opt,name=protocol,def=256" json:"protocol,omitempty"`
	SrcPorts             *string      `protobuf:"bytes,4,opt,name=src_ports,json=srcPorts" json:"src_ports,omitempty"`
	DstPorts             *string      `protobuf:"bytes,5,opt,name=dst_ports,json=dstPorts" json:"dst_ports,omitempty"`
	NpbActions           []*NpbAction `protobuf:"bytes,6,rep,name=npb_actions,json=npbActions" json:"npb_actions,omitempty"`
	SrcGroupIds          []int32      `protobuf:"varint,7,rep,name=src_group_ids,json=srcGroupIds" json:"src_group_ids,omitempty"`
	DstGroupIds          []int32      `protobuf:"varint,8,rep,name=dst_group_ids,json=dstGroupIds" json:"dst_group_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

字段含义查看README

func (*FlowAcl) Descriptor 

func (*FlowAcl) Descriptor() ([]byte, []int)

func (*FlowAcl) GetCaptureNetworkType 

func (m *FlowAcl) GetCaptureNetworkType() uint32

func (*FlowAcl) GetDstGroupIds 

func (m *FlowAcl) GetDstGroupIds() []int32

func (*FlowAcl) GetDstPorts 

func (m *FlowAcl) GetDstPorts() string

func (*FlowAcl) GetId 

func (m *FlowAcl) GetId() uint32

func (*FlowAcl) GetNpbActions 

func (m *FlowAcl) GetNpbActions() []*NpbAction

func (*FlowAcl) GetProtocol 

func (m *FlowAcl) GetProtocol() uint32

func (*FlowAcl) GetSrcGroupIds 

func (m *FlowAcl) GetSrcGroupIds() []int32

func (*FlowAcl) GetSrcPorts 

func (m *FlowAcl) GetSrcPorts() string

func (*FlowAcl) Marshal 

func (m *FlowAcl) Marshal() (dAtA []byte, err error)

func (*FlowAcl) MarshalTo 

func (m *FlowAcl) MarshalTo(dAtA []byte) (int, error)

func (*FlowAcl) MarshalToSizedBuffer 

func (m *FlowAcl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowAcl) ProtoMessage 

func (*FlowAcl) ProtoMessage()

func (*FlowAcl) Reset 

func (m *FlowAcl) Reset()

func (*FlowAcl) Size 

func (m *FlowAcl) Size() (n int)

func (*FlowAcl) String 

func (m *FlowAcl) String() string

func (*FlowAcl) Unmarshal 

func (m *FlowAcl) Unmarshal(dAtA []byte) error

func (*FlowAcl) XXX_DiscardUnknown 

func (m *FlowAcl) XXX_DiscardUnknown()

func (*FlowAcl) XXX_Marshal 

func (m *FlowAcl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowAcl) XXX_Merge 

func (m *FlowAcl) XXX_Merge(src proto.Message)

func (*FlowAcl) XXX_Size 

func (m *FlowAcl) XXX_Size() int

func (*FlowAcl) XXX_Unmarshal 

func (m *FlowAcl) XXX_Unmarshal(b []byte) error

type FlowAcls 

type FlowAcls struct {
	FlowAcl              []*FlowAcl `protobuf:"bytes,1,rep,name=flow_acl,json=flowAcl" json:"flow_acl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*FlowAcls) Descriptor 

func (*FlowAcls) Descriptor() ([]byte, []int)

func (*FlowAcls) GetFlowAcl 

func (m *FlowAcls) GetFlowAcl() []*FlowAcl

func (*FlowAcls) Marshal 

func (m *FlowAcls) Marshal() (dAtA []byte, err error)

func (*FlowAcls) MarshalTo 

func (m *FlowAcls) MarshalTo(dAtA []byte) (int, error)

func (*FlowAcls) MarshalToSizedBuffer 

func (m *FlowAcls) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FlowAcls) ProtoMessage 

func (*FlowAcls) ProtoMessage()

func (*FlowAcls) Reset 

func (m *FlowAcls) Reset()

func (*FlowAcls) Size 

func (m *FlowAcls) Size() (n int)

func (*FlowAcls) String 

func (m *FlowAcls) String() string

func (*FlowAcls) Unmarshal 

func (m *FlowAcls) Unmarshal(dAtA []byte) error

func (*FlowAcls) XXX_DiscardUnknown 

func (m *FlowAcls) XXX_DiscardUnknown()

func (*FlowAcls) XXX_Marshal 

func (m *FlowAcls) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowAcls) XXX_Merge 

func (m *FlowAcls) XXX_Merge(src proto.Message)

func (*FlowAcls) XXX_Size 

func (m *FlowAcls) XXX_Size() int

func (*FlowAcls) XXX_Unmarshal 

func (m *FlowAcls) XXX_Unmarshal(b []byte) error

type GPIDAgentData 

type GPIDAgentData struct {
	UpdateTime           *uint32          `protobuf:"varint,1,opt,name=update_time,json=updateTime,def=0" json:"update_time,omitempty"`
	SyncRequest          *GPIDSyncRequest `protobuf:"bytes,2,opt,name=sync_request,json=syncRequest" json:"sync_request,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GPIDAgentData) Descriptor 

func (*GPIDAgentData) Descriptor() ([]byte, []int)

func (*GPIDAgentData) GetSyncRequest 

func (m *GPIDAgentData) GetSyncRequest() *GPIDSyncRequest

func (*GPIDAgentData) GetUpdateTime 

func (m *GPIDAgentData) GetUpdateTime() uint32

func (*GPIDAgentData) Marshal 

func (m *GPIDAgentData) Marshal() (dAtA []byte, err error)

func (*GPIDAgentData) MarshalTo 

func (m *GPIDAgentData) MarshalTo(dAtA []byte) (int, error)

func (*GPIDAgentData) MarshalToSizedBuffer 

func (m *GPIDAgentData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GPIDAgentData) ProtoMessage 

func (*GPIDAgentData) ProtoMessage()

func (*GPIDAgentData) Reset 

func (m *GPIDAgentData) Reset()

func (*GPIDAgentData) Size 

func (m *GPIDAgentData) Size() (n int)

func (*GPIDAgentData) String 

func (m *GPIDAgentData) String() string

func (*GPIDAgentData) Unmarshal 

func (m *GPIDAgentData) Unmarshal(dAtA []byte) error

func (*GPIDAgentData) XXX_DiscardUnknown 

func (m *GPIDAgentData) XXX_DiscardUnknown()

func (*GPIDAgentData) XXX_Marshal 

func (m *GPIDAgentData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPIDAgentData) XXX_Merge 

func (m *GPIDAgentData) XXX_Merge(src proto.Message)

func (*GPIDAgentData) XXX_Size 

func (m *GPIDAgentData) XXX_Size() int

func (*GPIDAgentData) XXX_Unmarshal 

func (m *GPIDAgentData) XXX_Unmarshal(b []byte) error

type GPIDGlobalData 

type GPIDGlobalData struct {
	Entries              []*GlobalGPIDEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GPIDGlobalData) Descriptor 

func (*GPIDGlobalData) Descriptor() ([]byte, []int)

func (*GPIDGlobalData) GetEntries 

func (m *GPIDGlobalData) GetEntries() []*GlobalGPIDEntry

func (*GPIDGlobalData) Marshal 

func (m *GPIDGlobalData) Marshal() (dAtA []byte, err error)

func (*GPIDGlobalData) MarshalTo 

func (m *GPIDGlobalData) MarshalTo(dAtA []byte) (int, error)

func (*GPIDGlobalData) MarshalToSizedBuffer 

func (m *GPIDGlobalData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GPIDGlobalData) ProtoMessage 

func (*GPIDGlobalData) ProtoMessage()

func (*GPIDGlobalData) Reset 

func (m *GPIDGlobalData) Reset()

func (*GPIDGlobalData) Size 

func (m *GPIDGlobalData) Size() (n int)

func (*GPIDGlobalData) String 

func (m *GPIDGlobalData) String() string

func (*GPIDGlobalData) Unmarshal 

func (m *GPIDGlobalData) Unmarshal(dAtA []byte) error

func (*GPIDGlobalData) XXX_DiscardUnknown 

func (m *GPIDGlobalData) XXX_DiscardUnknown()

func (*GPIDGlobalData) XXX_Marshal 

func (m *GPIDGlobalData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPIDGlobalData) XXX_Merge 

func (m *GPIDGlobalData) XXX_Merge(src proto.Message)

func (*GPIDGlobalData) XXX_Size 

func (m *GPIDGlobalData) XXX_Size() int

func (*GPIDGlobalData) XXX_Unmarshal 

func (m *GPIDGlobalData) XXX_Unmarshal(b []byte) error

type GPIDSyncCompressAlgorithm 

type GPIDSyncCompressAlgorithm int32
const (
	GPIDSyncCompressAlgorithm_COMPRESS_ALRO_NONE GPIDSyncCompressAlgorithm = 0
	// Before assigning a value to an array, we use the following algorithm to
	// compress the original data:
	// 1) Data is sorted by the order of fields in the entry of the array. The
	//    order of the fields is carefully designed. The more likely a field is
	//    repeated, the higher its order will be.
	// 2) For each entry, if one of its fields is equal to the corresponding
	//    field of the previous entry, then its field is assigned a value of 0.
	//    When a field in Protobuf have a default value of 0, this allows us
	//    to achieve very efficient compression.
	GPIDSyncCompressAlgorithm_COMPRESS_ALGO_IGNORE_IF_EQUAL_TO_PREVIOUS GPIDSyncCompressAlgorithm = 1
)
const Default_GPIDSyncRequest_EntriesCompressAlgorithm GPIDSyncCompressAlgorithm = GPIDSyncCompressAlgorithm_COMPRESS_ALRO_NONE
const Default_GPIDSyncResponse_EntriesCompressAlgorithm GPIDSyncCompressAlgorithm = GPIDSyncCompressAlgorithm_COMPRESS_ALRO_NONE

func (GPIDSyncCompressAlgorithm) Enum 

func (x GPIDSyncCompressAlgorithm) Enum() *GPIDSyncCompressAlgorithm

func (GPIDSyncCompressAlgorithm) EnumDescriptor 

func (GPIDSyncCompressAlgorithm) EnumDescriptor() ([]byte, []int)

func (GPIDSyncCompressAlgorithm) String 

func (x GPIDSyncCompressAlgorithm) String() string

func (*GPIDSyncCompressAlgorithm) UnmarshalJSON 

func (x *GPIDSyncCompressAlgorithm) UnmarshalJSON(data []byte) error

type GPIDSyncEntry 

type GPIDSyncEntry struct {
	Protocol *ServiceProtocol `protobuf:"varint,1,opt,name=protocol,enum=agent.ServiceProtocol,def=0" json:"protocol,omitempty"`
	// server side
	EpcId_1 *uint32 `protobuf:"varint,2,opt,name=epc_id_1,json=epcId1,def=0" json:"epc_id_1,omitempty"`
	Ipv4_1  *uint32 `protobuf:"varint,3,opt,name=ipv4_1,json=ipv41,def=0" json:"ipv4_1,omitempty"`
	Port_1  *uint32 `protobuf:"varint,4,opt,name=port_1,json=port1,def=0" json:"port_1,omitempty"`
	Pid_1   *uint32 `protobuf:"varint,5,opt,name=pid_1,json=pid1,def=0" json:"pid_1,omitempty"`
	// client side
	EpcId_0 *uint32 `protobuf:"varint,6,opt,name=epc_id_0,json=epcId0,def=0" json:"epc_id_0,omitempty"`
	Ipv4_0  *uint32 `protobuf:"varint,7,opt,name=ipv4_0,json=ipv40,def=0" json:"ipv4_0,omitempty"`
	Port_0  *uint32 `protobuf:"varint,8,opt,name=port_0,json=port0,def=0" json:"port_0,omitempty"`
	Pid_0   *uint32 `protobuf:"varint,9,opt,name=pid_0,json=pid0,def=0" json:"pid_0,omitempty"`
	// real ip (before or after NAT)
	EpcIdReal *uint32   `protobuf:"varint,10,opt,name=epc_id_real,json=epcIdReal,def=0" json:"epc_id_real,omitempty"`
	Ipv4Real  *uint32   `protobuf:"varint,11,opt,name=ipv4_real,json=ipv4Real,def=0" json:"ipv4_real,omitempty"`
	PortReal  *uint32   `protobuf:"varint,12,opt,name=port_real,json=portReal,def=0" json:"port_real,omitempty"`
	PidReal   *uint32   `protobuf:"varint,13,opt,name=pid_real,json=pidReal,def=0" json:"pid_real,omitempty"`
	RoleReal  *RoleType `protobuf:"varint,14,opt,name=role_real,json=roleReal,enum=agent.RoleType,def=0" json:"role_real,omitempty"`
	// the net namespace index,  neither netns id nor netns inode
	NetnsIdx             *uint32  `protobuf:"varint,15,opt,name=netns_idx,json=netnsIdx,def=0" json:"netns_idx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GPIDSyncEntry) Descriptor 

func (*GPIDSyncEntry) Descriptor() ([]byte, []int)

func (*GPIDSyncEntry) GetEpcIdReal 

func (m *GPIDSyncEntry) GetEpcIdReal() uint32

func (*GPIDSyncEntry) GetEpcId_0 

func (m *GPIDSyncEntry) GetEpcId_0() uint32

func (*GPIDSyncEntry) GetEpcId_1 

func (m *GPIDSyncEntry) GetEpcId_1() uint32

func (*GPIDSyncEntry) GetIpv4Real 

func (m *GPIDSyncEntry) GetIpv4Real() uint32

func (*GPIDSyncEntry) GetIpv4_0 

func (m *GPIDSyncEntry) GetIpv4_0() uint32

func (*GPIDSyncEntry) GetIpv4_1 

func (m *GPIDSyncEntry) GetIpv4_1() uint32

func (*GPIDSyncEntry) GetNetnsIdx 

func (m *GPIDSyncEntry) GetNetnsIdx() uint32

func (*GPIDSyncEntry) GetPidReal 

func (m *GPIDSyncEntry) GetPidReal() uint32

func (*GPIDSyncEntry) GetPid_0 

func (m *GPIDSyncEntry) GetPid_0() uint32

func (*GPIDSyncEntry) GetPid_1 

func (m *GPIDSyncEntry) GetPid_1() uint32

func (*GPIDSyncEntry) GetPortReal 

func (m *GPIDSyncEntry) GetPortReal() uint32

func (*GPIDSyncEntry) GetPort_0 

func (m *GPIDSyncEntry) GetPort_0() uint32

func (*GPIDSyncEntry) GetPort_1 

func (m *GPIDSyncEntry) GetPort_1() uint32

func (*GPIDSyncEntry) GetProtocol 

func (m *GPIDSyncEntry) GetProtocol() ServiceProtocol

func (*GPIDSyncEntry) GetRoleReal 

func (m *GPIDSyncEntry) GetRoleReal() RoleType

func (*GPIDSyncEntry) Marshal 

func (m *GPIDSyncEntry) Marshal() (dAtA []byte, err error)

func (*GPIDSyncEntry) MarshalTo 

func (m *GPIDSyncEntry) MarshalTo(dAtA []byte) (int, error)

func (*GPIDSyncEntry) MarshalToSizedBuffer 

func (m *GPIDSyncEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GPIDSyncEntry) ProtoMessage 

func (*GPIDSyncEntry) ProtoMessage()

func (*GPIDSyncEntry) Reset 

func (m *GPIDSyncEntry) Reset()

func (*GPIDSyncEntry) Size 

func (m *GPIDSyncEntry) Size() (n int)

func (*GPIDSyncEntry) String 

func (m *GPIDSyncEntry) String() string

func (*GPIDSyncEntry) Unmarshal 

func (m *GPIDSyncEntry) Unmarshal(dAtA []byte) error

func (*GPIDSyncEntry) XXX_DiscardUnknown 

func (m *GPIDSyncEntry) XXX_DiscardUnknown()

func (*GPIDSyncEntry) XXX_Marshal 

func (m *GPIDSyncEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPIDSyncEntry) XXX_Merge 

func (m *GPIDSyncEntry) XXX_Merge(src proto.Message)

func (*GPIDSyncEntry) XXX_Size 

func (m *GPIDSyncEntry) XXX_Size() int

func (*GPIDSyncEntry) XXX_Unmarshal 

func (m *GPIDSyncEntry) XXX_Unmarshal(b []byte) error

type GPIDSyncRequest 

type GPIDSyncRequest struct {
	CtrlIp                   *string                    `protobuf:"bytes,1,opt,name=ctrl_ip,json=ctrlIp" json:"ctrl_ip,omitempty"`
	CtrlMac                  *string                    `protobuf:"bytes,2,opt,name=ctrl_mac,json=ctrlMac" json:"ctrl_mac,omitempty"`
	AgentId                  *uint32                    `protobuf:"varint,3,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	EntriesCompressAlgorithm *GPIDSyncCompressAlgorithm `` /* 172-byte string literal not displayed */
	TeamId                   *string                    `protobuf:"bytes,5,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	Entries                  []*GPIDSyncEntry           `protobuf:"bytes,10,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                   `json:"-"`
	XXX_unrecognized         []byte                     `json:"-"`
	XXX_sizecache            int32                      `json:"-"`
}

func (*GPIDSyncRequest) Descriptor 

func (*GPIDSyncRequest) Descriptor() ([]byte, []int)

func (*GPIDSyncRequest) GetAgentId 

func (m *GPIDSyncRequest) GetAgentId() uint32

func (*GPIDSyncRequest) GetCtrlIp 

func (m *GPIDSyncRequest) GetCtrlIp() string

func (*GPIDSyncRequest) GetCtrlMac 

func (m *GPIDSyncRequest) GetCtrlMac() string

func (*GPIDSyncRequest) GetEntries 

func (m *GPIDSyncRequest) GetEntries() []*GPIDSyncEntry

func (*GPIDSyncRequest) GetEntriesCompressAlgorithm 

func (m *GPIDSyncRequest) GetEntriesCompressAlgorithm() GPIDSyncCompressAlgorithm

func (*GPIDSyncRequest) GetTeamId 

func (m *GPIDSyncRequest) GetTeamId() string

func (*GPIDSyncRequest) Marshal 

func (m *GPIDSyncRequest) Marshal() (dAtA []byte, err error)

func (*GPIDSyncRequest) MarshalTo 

func (m *GPIDSyncRequest) MarshalTo(dAtA []byte) (int, error)

func (*GPIDSyncRequest) MarshalToSizedBuffer 

func (m *GPIDSyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GPIDSyncRequest) ProtoMessage 

func (*GPIDSyncRequest) ProtoMessage()

func (*GPIDSyncRequest) Reset 

func (m *GPIDSyncRequest) Reset()

func (*GPIDSyncRequest) Size 

func (m *GPIDSyncRequest) Size() (n int)

func (*GPIDSyncRequest) String 

func (m *GPIDSyncRequest) String() string

func (*GPIDSyncRequest) Unmarshal 

func (m *GPIDSyncRequest) Unmarshal(dAtA []byte) error

func (*GPIDSyncRequest) XXX_DiscardUnknown 

func (m *GPIDSyncRequest) XXX_DiscardUnknown()

func (*GPIDSyncRequest) XXX_Marshal 

func (m *GPIDSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPIDSyncRequest) XXX_Merge 

func (m *GPIDSyncRequest) XXX_Merge(src proto.Message)

func (*GPIDSyncRequest) XXX_Size 

func (m *GPIDSyncRequest) XXX_Size() int

func (*GPIDSyncRequest) XXX_Unmarshal 

func (m *GPIDSyncRequest) XXX_Unmarshal(b []byte) error

type GPIDSyncResponse 

type GPIDSyncResponse struct {
	EntriesCompressAlgorithm *GPIDSyncCompressAlgorithm `` /* 172-byte string literal not displayed */
	Entries                  []*GPIDSyncEntry           `protobuf:"bytes,2,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                   `json:"-"`
	XXX_unrecognized         []byte                     `json:"-"`
	XXX_sizecache            int32                      `json:"-"`
}

func (*GPIDSyncResponse) Descriptor 

func (*GPIDSyncResponse) Descriptor() ([]byte, []int)

func (*GPIDSyncResponse) GetEntries 

func (m *GPIDSyncResponse) GetEntries() []*GPIDSyncEntry

func (*GPIDSyncResponse) GetEntriesCompressAlgorithm 

func (m *GPIDSyncResponse) GetEntriesCompressAlgorithm() GPIDSyncCompressAlgorithm

func (*GPIDSyncResponse) Marshal 

func (m *GPIDSyncResponse) Marshal() (dAtA []byte, err error)

func (*GPIDSyncResponse) MarshalTo 

func (m *GPIDSyncResponse) MarshalTo(dAtA []byte) (int, error)

func (*GPIDSyncResponse) MarshalToSizedBuffer 

func (m *GPIDSyncResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GPIDSyncResponse) ProtoMessage 

func (*GPIDSyncResponse) ProtoMessage()

func (*GPIDSyncResponse) Reset 

func (m *GPIDSyncResponse) Reset()

func (*GPIDSyncResponse) Size 

func (m *GPIDSyncResponse) Size() (n int)

func (*GPIDSyncResponse) String 

func (m *GPIDSyncResponse) String() string

func (*GPIDSyncResponse) Unmarshal 

func (m *GPIDSyncResponse) Unmarshal(dAtA []byte) error

func (*GPIDSyncResponse) XXX_DiscardUnknown 

func (m *GPIDSyncResponse) XXX_DiscardUnknown()

func (*GPIDSyncResponse) XXX_Marshal 

func (m *GPIDSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPIDSyncResponse) XXX_Merge 

func (m *GPIDSyncResponse) XXX_Merge(src proto.Message)

func (*GPIDSyncResponse) XXX_Size 

func (m *GPIDSyncResponse) XXX_Size() int

func (*GPIDSyncResponse) XXX_Unmarshal 

func (m *GPIDSyncResponse) XXX_Unmarshal(b []byte) error

type GenesisPlatformData 

type GenesisPlatformData struct {
	Ips                  []*Ip            `protobuf:"bytes,7,rep,name=ips" json:"ips,omitempty"`
	PlatformEnabled      *bool            `protobuf:"varint,10,opt,name=platform_enabled,json=platformEnabled" json:"platform_enabled,omitempty"`
	RawHostname          *string          `protobuf:"bytes,11,opt,name=raw_hostname,json=rawHostname" json:"raw_hostname,omitempty"`
	RawAllVmXml          *string          `protobuf:"bytes,12,opt,name=raw_all_vm_xml,json=rawAllVmXml" json:"raw_all_vm_xml,omitempty"`
	RawVmStates          *string          `protobuf:"bytes,13,opt,name=raw_vm_states,json=rawVmStates" json:"raw_vm_states,omitempty"`
	RawOvsInterfaces     *string          `protobuf:"bytes,14,opt,name=raw_ovs_interfaces,json=rawOvsInterfaces" json:"raw_ovs_interfaces,omitempty"`
	RawOvsPorts          *string          `protobuf:"bytes,15,opt,name=raw_ovs_ports,json=rawOvsPorts" json:"raw_ovs_ports,omitempty"`
	RawBrctlShow         *string          `protobuf:"bytes,16,opt,name=raw_brctl_show,json=rawBrctlShow" json:"raw_brctl_show,omitempty"`
	RawVlanConfig        *string          `protobuf:"bytes,17,opt,name=raw_vlan_config,json=rawVlanConfig" json:"raw_vlan_config,omitempty"`
	LldpInfo             []*Lldp          `protobuf:"bytes,20,rep,name=lldp_info,json=lldpInfo" json:"lldp_info,omitempty"`
	RawIpNetns           []string         `protobuf:"bytes,30,rep,name=raw_ip_netns,json=rawIpNetns" json:"raw_ip_netns,omitempty"`
	RawIpAddrs           []string         `protobuf:"bytes,31,rep,name=raw_ip_addrs,json=rawIpAddrs" json:"raw_ip_addrs,omitempty"`
	Interfaces           []*InterfaceInfo `protobuf:"bytes,32,rep,name=interfaces" json:"interfaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GenesisPlatformData) Descriptor 

func (*GenesisPlatformData) Descriptor() ([]byte, []int)

func (*GenesisPlatformData) GetInterfaces 

func (m *GenesisPlatformData) GetInterfaces() []*InterfaceInfo

func (*GenesisPlatformData) GetIps 

func (m *GenesisPlatformData) GetIps() []*Ip

func (*GenesisPlatformData) GetLldpInfo 

func (m *GenesisPlatformData) GetLldpInfo() []*Lldp

func (*GenesisPlatformData) GetPlatformEnabled 

func (m *GenesisPlatformData) GetPlatformEnabled() bool

func (*GenesisPlatformData) GetRawAllVmXml 

func (m *GenesisPlatformData) GetRawAllVmXml() string

func (*GenesisPlatformData) GetRawBrctlShow 

func (m *GenesisPlatformData) GetRawBrctlShow() string

func (*GenesisPlatformData) GetRawHostname 

func (m *GenesisPlatformData) GetRawHostname() string

func (*GenesisPlatformData) GetRawIpAddrs 

func (m *GenesisPlatformData) GetRawIpAddrs() []string

func (*GenesisPlatformData) GetRawIpNetns 

func (m *GenesisPlatformData) GetRawIpNetns() []string

func (*GenesisPlatformData) GetRawOvsInterfaces 

func (m *GenesisPlatformData) GetRawOvsInterfaces() string

func (*GenesisPlatformData) GetRawOvsPorts 

func (m *GenesisPlatformData) GetRawOvsPorts() string

func (*GenesisPlatformData) GetRawVlanConfig 

func (m *GenesisPlatformData) GetRawVlanConfig() string

func (*GenesisPlatformData) GetRawVmStates 

func (m *GenesisPlatformData) GetRawVmStates() string

func (*GenesisPlatformData) Marshal 

func (m *GenesisPlatformData) Marshal() (dAtA []byte, err error)

func (*GenesisPlatformData) MarshalTo 

func (m *GenesisPlatformData) MarshalTo(dAtA []byte) (int, error)

func (*GenesisPlatformData) MarshalToSizedBuffer 

func (m *GenesisPlatformData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisPlatformData) ProtoMessage 

func (*GenesisPlatformData) ProtoMessage()

func (*GenesisPlatformData) Reset 

func (m *GenesisPlatformData) Reset()

func (*GenesisPlatformData) Size 

func (m *GenesisPlatformData) Size() (n int)

func (*GenesisPlatformData) String 

func (m *GenesisPlatformData) String() string

func (*GenesisPlatformData) Unmarshal 

func (m *GenesisPlatformData) Unmarshal(dAtA []byte) error

func (*GenesisPlatformData) XXX_DiscardUnknown 

func (m *GenesisPlatformData) XXX_DiscardUnknown()

func (*GenesisPlatformData) XXX_Marshal 

func (m *GenesisPlatformData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisPlatformData) XXX_Merge 

func (m *GenesisPlatformData) XXX_Merge(src proto.Message)

func (*GenesisPlatformData) XXX_Size 

func (m *GenesisPlatformData) XXX_Size() int

func (*GenesisPlatformData) XXX_Unmarshal 

func (m *GenesisPlatformData) XXX_Unmarshal(b []byte) error

type GenesisProcessData 

type GenesisProcessData struct {
	ProcessEntries       []*ProcessInfo `protobuf:"bytes,5,rep,name=process_entries,json=processEntries" json:"process_entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GenesisProcessData) Descriptor 

func (*GenesisProcessData) Descriptor() ([]byte, []int)

func (*GenesisProcessData) GetProcessEntries 

func (m *GenesisProcessData) GetProcessEntries() []*ProcessInfo

func (*GenesisProcessData) Marshal 

func (m *GenesisProcessData) Marshal() (dAtA []byte, err error)

func (*GenesisProcessData) MarshalTo 

func (m *GenesisProcessData) MarshalTo(dAtA []byte) (int, error)

func (*GenesisProcessData) MarshalToSizedBuffer 

func (m *GenesisProcessData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisProcessData) ProtoMessage 

func (*GenesisProcessData) ProtoMessage()

func (*GenesisProcessData) Reset 

func (m *GenesisProcessData) Reset()

func (*GenesisProcessData) Size 

func (m *GenesisProcessData) Size() (n int)

func (*GenesisProcessData) String 

func (m *GenesisProcessData) String() string

func (*GenesisProcessData) Unmarshal 

func (m *GenesisProcessData) Unmarshal(dAtA []byte) error

func (*GenesisProcessData) XXX_DiscardUnknown 

func (m *GenesisProcessData) XXX_DiscardUnknown()

func (*GenesisProcessData) XXX_Marshal 

func (m *GenesisProcessData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisProcessData) XXX_Merge 

func (m *GenesisProcessData) XXX_Merge(src proto.Message)

func (*GenesisProcessData) XXX_Size 

func (m *GenesisProcessData) XXX_Size() int

func (*GenesisProcessData) XXX_Unmarshal 

func (m *GenesisProcessData) XXX_Unmarshal(b []byte) error

type GenesisSyncRequest 

type GenesisSyncRequest struct {
	Version              *uint64              `protobuf:"varint,1,opt,name=version,def=0" json:"version,omitempty"`
	AgentType            *AgentType           `protobuf:"varint,2,opt,name=agent_type,json=agentType,enum=agent.AgentType" json:"agent_type,omitempty"`
	SourceIp             *string              `protobuf:"bytes,3,opt,name=source_ip,json=sourceIp" json:"source_ip,omitempty"`
	AgentId              *uint32              `protobuf:"varint,4,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	KubernetesClusterId  *string              `protobuf:"bytes,5,opt,name=kubernetes_cluster_id,json=kubernetesClusterId" json:"kubernetes_cluster_id,omitempty"`
	NatIp                *string              `protobuf:"bytes,6,opt,name=nat_ip,json=natIp" json:"nat_ip,omitempty"`
	TeamId               *string              `protobuf:"bytes,7,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	PlatformData         *GenesisPlatformData `protobuf:"bytes,9,opt,name=platform_data,json=platformData" json:"platform_data,omitempty"`
	ProcessData          *GenesisProcessData  `protobuf:"bytes,10,opt,name=process_data,json=processData" json:"process_data,omitempty"`
	AgentInfo            *AgentId             `protobuf:"bytes,11,opt,name=agent_info,json=agentInfo" json:"agent_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*GenesisSyncRequest) Descriptor 

func (*GenesisSyncRequest) Descriptor() ([]byte, []int)

func (*GenesisSyncRequest) GetAgentId 

func (m *GenesisSyncRequest) GetAgentId() uint32

func (*GenesisSyncRequest) GetAgentInfo 

func (m *GenesisSyncRequest) GetAgentInfo() *AgentId

func (*GenesisSyncRequest) GetAgentType 

func (m *GenesisSyncRequest) GetAgentType() AgentType

func (*GenesisSyncRequest) GetKubernetesClusterId 

func (m *GenesisSyncRequest) GetKubernetesClusterId() string

func (*GenesisSyncRequest) GetNatIp 

func (m *GenesisSyncRequest) GetNatIp() string

func (*GenesisSyncRequest) GetPlatformData 

func (m *GenesisSyncRequest) GetPlatformData() *GenesisPlatformData

func (*GenesisSyncRequest) GetProcessData 

func (m *GenesisSyncRequest) GetProcessData() *GenesisProcessData

func (*GenesisSyncRequest) GetSourceIp 

func (m *GenesisSyncRequest) GetSourceIp() string

func (*GenesisSyncRequest) GetTeamId 

func (m *GenesisSyncRequest) GetTeamId() string

func (*GenesisSyncRequest) GetVersion 

func (m *GenesisSyncRequest) GetVersion() uint64

func (*GenesisSyncRequest) Marshal 

func (m *GenesisSyncRequest) Marshal() (dAtA []byte, err error)

func (*GenesisSyncRequest) MarshalTo 

func (m *GenesisSyncRequest) MarshalTo(dAtA []byte) (int, error)

func (*GenesisSyncRequest) MarshalToSizedBuffer 

func (m *GenesisSyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisSyncRequest) ProtoMessage 

func (*GenesisSyncRequest) ProtoMessage()

func (*GenesisSyncRequest) Reset 

func (m *GenesisSyncRequest) Reset()

func (*GenesisSyncRequest) Size 

func (m *GenesisSyncRequest) Size() (n int)

func (*GenesisSyncRequest) String 

func (m *GenesisSyncRequest) String() string

func (*GenesisSyncRequest) Unmarshal 

func (m *GenesisSyncRequest) Unmarshal(dAtA []byte) error

func (*GenesisSyncRequest) XXX_DiscardUnknown 

func (m *GenesisSyncRequest) XXX_DiscardUnknown()

func (*GenesisSyncRequest) XXX_Marshal 

func (m *GenesisSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisSyncRequest) XXX_Merge 

func (m *GenesisSyncRequest) XXX_Merge(src proto.Message)

func (*GenesisSyncRequest) XXX_Size 

func (m *GenesisSyncRequest) XXX_Size() int

func (*GenesisSyncRequest) XXX_Unmarshal 

func (m *GenesisSyncRequest) XXX_Unmarshal(b []byte) error

type GenesisSyncResponse 

type GenesisSyncResponse struct {
	Version              *uint64  `protobuf:"varint,1,opt,name=version,def=0" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenesisSyncResponse) Descriptor 

func (*GenesisSyncResponse) Descriptor() ([]byte, []int)

func (*GenesisSyncResponse) GetVersion 

func (m *GenesisSyncResponse) GetVersion() uint64

func (*GenesisSyncResponse) Marshal 

func (m *GenesisSyncResponse) Marshal() (dAtA []byte, err error)

func (*GenesisSyncResponse) MarshalTo 

func (m *GenesisSyncResponse) MarshalTo(dAtA []byte) (int, error)

func (*GenesisSyncResponse) MarshalToSizedBuffer 

func (m *GenesisSyncResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisSyncResponse) ProtoMessage 

func (*GenesisSyncResponse) ProtoMessage()

func (*GenesisSyncResponse) Reset 

func (m *GenesisSyncResponse) Reset()

func (*GenesisSyncResponse) Size 

func (m *GenesisSyncResponse) Size() (n int)

func (*GenesisSyncResponse) String 

func (m *GenesisSyncResponse) String() string

func (*GenesisSyncResponse) Unmarshal 

func (m *GenesisSyncResponse) Unmarshal(dAtA []byte) error

func (*GenesisSyncResponse) XXX_DiscardUnknown 

func (m *GenesisSyncResponse) XXX_DiscardUnknown()

func (*GenesisSyncResponse) XXX_Marshal 

func (m *GenesisSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisSyncResponse) XXX_Merge 

func (m *GenesisSyncResponse) XXX_Merge(src proto.Message)

func (*GenesisSyncResponse) XXX_Size 

func (m *GenesisSyncResponse) XXX_Size() int

func (*GenesisSyncResponse) XXX_Unmarshal 

func (m *GenesisSyncResponse) XXX_Unmarshal(b []byte) error

type GlobalGPIDEntry 

type GlobalGPIDEntry struct {
	Protocol *ServiceProtocol `protobuf:"varint,1,opt,name=protocol,enum=agent.ServiceProtocol,def=0" json:"protocol,omitempty"`
	// server side
	AgentId_1 *uint32 `protobuf:"varint,2,opt,name=agent_id_1,json=agentId1,def=0" json:"agent_id_1,omitempty"`
	EpcId_1   *uint32 `protobuf:"varint,3,opt,name=epc_id_1,json=epcId1,def=0" json:"epc_id_1,omitempty"`
	Ipv4_1    *uint32 `protobuf:"varint,4,opt,name=ipv4_1,json=ipv41,def=0" json:"ipv4_1,omitempty"`
	Port_1    *uint32 `protobuf:"varint,5,opt,name=port_1,json=port1,def=0" json:"port_1,omitempty"`
	Pid_1     *uint32 `protobuf:"varint,6,opt,name=pid_1,json=pid1,def=0" json:"pid_1,omitempty"`
	Gpid_1    *uint32 `protobuf:"varint,7,opt,name=gpid_1,json=gpid1,def=0" json:"gpid_1,omitempty"`
	// client side
	AgentId_0            *uint32  `protobuf:"varint,8,opt,name=agent_id_0,json=agentId0,def=0" json:"agent_id_0,omitempty"`
	EpcId_0              *uint32  `protobuf:"varint,9,opt,name=epc_id_0,json=epcId0,def=0" json:"epc_id_0,omitempty"`
	Ipv4_0               *uint32  `protobuf:"varint,10,opt,name=ipv4_0,json=ipv40,def=0" json:"ipv4_0,omitempty"`
	Port_0               *uint32  `protobuf:"varint,11,opt,name=port_0,json=port0,def=0" json:"port_0,omitempty"`
	Pid_0                *uint32  `protobuf:"varint,12,opt,name=pid_0,json=pid0,def=0" json:"pid_0,omitempty"`
	Gpid_0               *uint32  `protobuf:"varint,13,opt,name=gpid_0,json=gpid0,def=0" json:"gpid_0,omitempty"`
	NetnsIdx             *uint32  `protobuf:"varint,14,opt,name=netns_idx,json=netnsIdx,def=0" json:"netns_idx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GlobalGPIDEntry) Descriptor 

func (*GlobalGPIDEntry) Descriptor() ([]byte, []int)

func (*GlobalGPIDEntry) GetAgentId_0 

func (m *GlobalGPIDEntry) GetAgentId_0() uint32

func (*GlobalGPIDEntry) GetAgentId_1 

func (m *GlobalGPIDEntry) GetAgentId_1() uint32

func (*GlobalGPIDEntry) GetEpcId_0 

func (m *GlobalGPIDEntry) GetEpcId_0() uint32

func (*GlobalGPIDEntry) GetEpcId_1 

func (m *GlobalGPIDEntry) GetEpcId_1() uint32

func (*GlobalGPIDEntry) GetGpid_0 

func (m *GlobalGPIDEntry) GetGpid_0() uint32

func (*GlobalGPIDEntry) GetGpid_1 

func (m *GlobalGPIDEntry) GetGpid_1() uint32

func (*GlobalGPIDEntry) GetIpv4_0 

func (m *GlobalGPIDEntry) GetIpv4_0() uint32

func (*GlobalGPIDEntry) GetIpv4_1 

func (m *GlobalGPIDEntry) GetIpv4_1() uint32

func (*GlobalGPIDEntry) GetNetnsIdx 

func (m *GlobalGPIDEntry) GetNetnsIdx() uint32

func (*GlobalGPIDEntry) GetPid_0 

func (m *GlobalGPIDEntry) GetPid_0() uint32

func (*GlobalGPIDEntry) GetPid_1 

func (m *GlobalGPIDEntry) GetPid_1() uint32

func (*GlobalGPIDEntry) GetPort_0 

func (m *GlobalGPIDEntry) GetPort_0() uint32

func (*GlobalGPIDEntry) GetPort_1 

func (m *GlobalGPIDEntry) GetPort_1() uint32

func (*GlobalGPIDEntry) GetProtocol 

func (m *GlobalGPIDEntry) GetProtocol() ServiceProtocol

func (*GlobalGPIDEntry) Marshal 

func (m *GlobalGPIDEntry) Marshal() (dAtA []byte, err error)

func (*GlobalGPIDEntry) MarshalTo 

func (m *GlobalGPIDEntry) MarshalTo(dAtA []byte) (int, error)

func (*GlobalGPIDEntry) MarshalToSizedBuffer 

func (m *GlobalGPIDEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalGPIDEntry) ProtoMessage 

func (*GlobalGPIDEntry) ProtoMessage()

func (*GlobalGPIDEntry) Reset 

func (m *GlobalGPIDEntry) Reset()

func (*GlobalGPIDEntry) Size 

func (m *GlobalGPIDEntry) Size() (n int)

func (*GlobalGPIDEntry) String 

func (m *GlobalGPIDEntry) String() string

func (*GlobalGPIDEntry) Unmarshal 

func (m *GlobalGPIDEntry) Unmarshal(dAtA []byte) error

func (*GlobalGPIDEntry) XXX_DiscardUnknown 

func (m *GlobalGPIDEntry) XXX_DiscardUnknown()

func (*GlobalGPIDEntry) XXX_Marshal 

func (m *GlobalGPIDEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalGPIDEntry) XXX_Merge 

func (m *GlobalGPIDEntry) XXX_Merge(src proto.Message)

func (*GlobalGPIDEntry) XXX_Size 

func (m *GlobalGPIDEntry) XXX_Size() int

func (*GlobalGPIDEntry) XXX_Unmarshal 

func (m *GlobalGPIDEntry) XXX_Unmarshal(b []byte) error

type Group 

type Group struct {
	Id                   *uint32    `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	EpcId                *uint32    `protobuf:"varint,2,opt,name=epc_id,json=epcId,def=0" json:"epc_id,omitempty"`
	Type                 *GroupType `protobuf:"varint,3,opt,name=type,enum=agent.GroupType" json:"type,omitempty"`
	Ips                  []string   `protobuf:"bytes,5,rep,name=ips" json:"ips,omitempty"`
	IpRanges             []string   `protobuf:"bytes,6,rep,name=ip_ranges,json=ipRanges" json:"ip_ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

字段含义查看README

func (*Group) Descriptor 

func (*Group) Descriptor() ([]byte, []int)

func (*Group) GetEpcId 

func (m *Group) GetEpcId() uint32

func (*Group) GetId 

func (m *Group) GetId() uint32

func (*Group) GetIpRanges 

func (m *Group) GetIpRanges() []string

func (*Group) GetIps 

func (m *Group) GetIps() []string

func (*Group) GetType 

func (m *Group) GetType() GroupType

func (*Group) Marshal 

func (m *Group) Marshal() (dAtA []byte, err error)

func (*Group) MarshalTo 

func (m *Group) MarshalTo(dAtA []byte) (int, error)

func (*Group) MarshalToSizedBuffer 

func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) Size 

func (m *Group) Size() (n int)

func (*Group) String 

func (m *Group) String() string

func (*Group) Unmarshal 

func (m *Group) Unmarshal(dAtA []byte) error

func (*Group) XXX_DiscardUnknown 

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal 

func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Group) XXX_Merge 

func (m *Group) XXX_Merge(src proto.Message)

func (*Group) XXX_Size 

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal 

func (m *Group) XXX_Unmarshal(b []byte) error

type GroupType 

type GroupType int32
const (
	GroupType_NAMED     GroupType = 0
	GroupType_ANONYMOUS GroupType = 1
)

func (GroupType) Enum 

func (x GroupType) Enum() *GroupType

func (GroupType) EnumDescriptor 

func (GroupType) EnumDescriptor() ([]byte, []int)

func (GroupType) String 

func (x GroupType) String() string

func (*GroupType) UnmarshalJSON 

func (x *GroupType) UnmarshalJSON(data []byte) error

type Groups 

type Groups struct {
	Groups               []*Group `protobuf:"bytes,1,rep,name=groups" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Groups) Descriptor 

func (*Groups) Descriptor() ([]byte, []int)

func (*Groups) GetGroups 

func (m *Groups) GetGroups() []*Group

func (*Groups) Marshal 

func (m *Groups) Marshal() (dAtA []byte, err error)

func (*Groups) MarshalTo 

func (m *Groups) MarshalTo(dAtA []byte) (int, error)

func (*Groups) MarshalToSizedBuffer 

func (m *Groups) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Groups) ProtoMessage 

func (*Groups) ProtoMessage()

func (*Groups) Reset 

func (m *Groups) Reset()

func (*Groups) Size 

func (m *Groups) Size() (n int)

func (*Groups) String 

func (m *Groups) String() string

func (*Groups) Unmarshal 

func (m *Groups) Unmarshal(dAtA []byte) error

func (*Groups) XXX_DiscardUnknown 

func (m *Groups) XXX_DiscardUnknown()

func (*Groups) XXX_Marshal 

func (m *Groups) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Groups) XXX_Merge 

func (m *Groups) XXX_Merge(src proto.Message)

func (*Groups) XXX_Size 

func (m *Groups) XXX_Size() int

func (*Groups) XXX_Unmarshal 

func (m *Groups) XXX_Unmarshal(b []byte) error

type IfMacSource 

type IfMacSource int32
const (
	IfMacSource_IF_MAC         IfMacSource = 0
	IfMacSource_IF_NAME        IfMacSource = 1
	IfMacSource_IF_LIBVIRT_XML IfMacSource = 2
)

func (IfMacSource) Enum 

func (x IfMacSource) Enum() *IfMacSource

func (IfMacSource) EnumDescriptor 

func (IfMacSource) EnumDescriptor() ([]byte, []int)

func (IfMacSource) String 

func (x IfMacSource) String() string

func (*IfMacSource) UnmarshalJSON 

func (x *IfMacSource) UnmarshalJSON(data []byte) error

type Interface 

type Interface struct {
	Id                   *uint32       `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	DeviceType           *DeviceType   `protobuf:"varint,2,opt,name=device_type,json=deviceType,enum=agent.DeviceType" json:"device_type,omitempty"`
	IfType               *uint32       `protobuf:"varint,3,opt,name=if_type,json=ifType" json:"if_type,omitempty"`
	EpcId                *uint32       `protobuf:"varint,4,opt,name=epc_id,json=epcId" json:"epc_id,omitempty"`
	IpResources          []*IpResource `protobuf:"bytes,5,rep,name=ip_resources,json=ipResources" json:"ip_resources,omitempty"`
	RegionId             *uint32       `protobuf:"varint,6,opt,name=region_id,json=regionId" json:"region_id,omitempty"`
	Mac                  *uint64       `protobuf:"varint,7,opt,name=mac" json:"mac,omitempty"`
	PodNodeId            *uint32       `protobuf:"varint,8,opt,name=pod_node_id,json=podNodeId" json:"pod_node_id,omitempty"`
	PodClusterId         *uint32       `protobuf:"varint,9,opt,name=pod_cluster_id,json=podClusterId" json:"pod_cluster_id,omitempty"`
	IsVipInterface       *bool         `protobuf:"varint,10,opt,name=is_vip_interface,json=isVipInterface,def=0" json:"is_vip_interface,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Interface) Descriptor 

func (*Interface) Descriptor() ([]byte, []int)

func (*Interface) GetDeviceType 

func (m *Interface) GetDeviceType() DeviceType

func (*Interface) GetEpcId 

func (m *Interface) GetEpcId() uint32

func (*Interface) GetId 

func (m *Interface) GetId() uint32

func (*Interface) GetIfType 

func (m *Interface) GetIfType() uint32

func (*Interface) GetIpResources 

func (m *Interface) GetIpResources() []*IpResource

func (*Interface) GetIsVipInterface 

func (m *Interface) GetIsVipInterface() bool

func (*Interface) GetMac 

func (m *Interface) GetMac() uint64

func (*Interface) GetPodClusterId 

func (m *Interface) GetPodClusterId() uint32

func (*Interface) GetPodNodeId 

func (m *Interface) GetPodNodeId() uint32

func (*Interface) GetRegionId 

func (m *Interface) GetRegionId() uint32

func (*Interface) Marshal 

func (m *Interface) Marshal() (dAtA []byte, err error)

func (*Interface) MarshalTo 

func (m *Interface) MarshalTo(dAtA []byte) (int, error)

func (*Interface) MarshalToSizedBuffer 

func (m *Interface) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Interface) ProtoMessage 

func (*Interface) ProtoMessage()

func (*Interface) Reset 

func (m *Interface) Reset()

func (*Interface) Size 

func (m *Interface) Size() (n int)

func (*Interface) String 

func (m *Interface) String() string

func (*Interface) Unmarshal 

func (m *Interface) Unmarshal(dAtA []byte) error

func (*Interface) XXX_DiscardUnknown 

func (m *Interface) XXX_DiscardUnknown()

func (*Interface) XXX_Marshal 

func (m *Interface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Interface) XXX_Merge 

func (m *Interface) XXX_Merge(src proto.Message)

func (*Interface) XXX_Size 

func (m *Interface) XXX_Size() int

func (*Interface) XXX_Unmarshal 

func (m *Interface) XXX_Unmarshal(b []byte) error

type InterfaceInfo 

type InterfaceInfo struct {
	Mac *uint64 `protobuf:"varint,1,opt,name=mac" json:"mac,omitempty"`
	// ip/masklen
	Ip                   []string `protobuf:"bytes,2,rep,name=ip" json:"ip,omitempty"`
	Name                 *string  `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
	DeviceId             *string  `protobuf:"bytes,4,opt,name=device_id,json=deviceId" json:"device_id,omitempty"`
	TapIndex             *uint32  `protobuf:"varint,5,opt,name=tap_index,json=tapIndex" json:"tap_index,omitempty"`
	DeviceName           *string  `protobuf:"bytes,6,opt,name=device_name,json=deviceName" json:"device_name,omitempty"`
	Netns                *string  `protobuf:"bytes,7,opt,name=netns,def=" json:"netns,omitempty"`
	NetnsId              *uint32  `protobuf:"varint,8,opt,name=netns_id,json=netnsId,def=0" json:"netns_id,omitempty"`
	IfType               *string  `protobuf:"bytes,9,opt,name=if_type,json=ifType,def=" json:"if_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InterfaceInfo) Descriptor 

func (*InterfaceInfo) Descriptor() ([]byte, []int)

func (*InterfaceInfo) GetDeviceId 

func (m *InterfaceInfo) GetDeviceId() string

func (*InterfaceInfo) GetDeviceName 

func (m *InterfaceInfo) GetDeviceName() string

func (*InterfaceInfo) GetIfType 

func (m *InterfaceInfo) GetIfType() string

func (*InterfaceInfo) GetIp 

func (m *InterfaceInfo) GetIp() []string

func (*InterfaceInfo) GetMac 

func (m *InterfaceInfo) GetMac() uint64

func (*InterfaceInfo) GetName 

func (m *InterfaceInfo) GetName() string

func (*InterfaceInfo) GetNetns 

func (m *InterfaceInfo) GetNetns() string

func (*InterfaceInfo) GetNetnsId 

func (m *InterfaceInfo) GetNetnsId() uint32

func (*InterfaceInfo) GetTapIndex 

func (m *InterfaceInfo) GetTapIndex() uint32

func (*InterfaceInfo) Marshal 

func (m *InterfaceInfo) Marshal() (dAtA []byte, err error)

func (*InterfaceInfo) MarshalTo 

func (m *InterfaceInfo) MarshalTo(dAtA []byte) (int, error)

func (*InterfaceInfo) MarshalToSizedBuffer 

func (m *InterfaceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InterfaceInfo) ProtoMessage 

func (*InterfaceInfo) ProtoMessage()

func (*InterfaceInfo) Reset 

func (m *InterfaceInfo) Reset()

func (*InterfaceInfo) Size 

func (m *InterfaceInfo) Size() (n int)

func (*InterfaceInfo) String 

func (m *InterfaceInfo) String() string

func (*InterfaceInfo) Unmarshal 

func (m *InterfaceInfo) Unmarshal(dAtA []byte) error

func (*InterfaceInfo) XXX_DiscardUnknown 

func (m *InterfaceInfo) XXX_DiscardUnknown()

func (*InterfaceInfo) XXX_Marshal 

func (m *InterfaceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InterfaceInfo) XXX_Merge 

func (m *InterfaceInfo) XXX_Merge(src proto.Message)

func (*InterfaceInfo) XXX_Size 

func (m *InterfaceInfo) XXX_Size() int

func (*InterfaceInfo) XXX_Unmarshal 

func (m *InterfaceInfo) XXX_Unmarshal(b []byte) error

type Ip 

type Ip struct {
	LastSeen             *uint32  `protobuf:"varint,2,opt,name=last_seen,json=lastSeen" json:"last_seen,omitempty"`
	Mac                  *uint64  `protobuf:"varint,3,opt,name=mac" json:"mac,omitempty"`
	Ip                   []byte   `protobuf:"bytes,4,opt,name=ip" json:"ip,omitempty"`
	PortUuid             *string  `protobuf:"bytes,9,opt,name=port_uuid,json=portUuid" json:"port_uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ip) Descriptor 

func (*Ip) Descriptor() ([]byte, []int)

func (*Ip) GetIp 

func (m *Ip) GetIp() []byte

func (*Ip) GetLastSeen 

func (m *Ip) GetLastSeen() uint32

func (*Ip) GetMac 

func (m *Ip) GetMac() uint64

func (*Ip) GetPortUuid 

func (m *Ip) GetPortUuid() string

func (*Ip) Marshal 

func (m *Ip) Marshal() (dAtA []byte, err error)

func (*Ip) MarshalTo 

func (m *Ip) MarshalTo(dAtA []byte) (int, error)

func (*Ip) MarshalToSizedBuffer 

func (m *Ip) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ip) ProtoMessage 

func (*Ip) ProtoMessage()

func (*Ip) Reset 

func (m *Ip) Reset()

func (*Ip) Size 

func (m *Ip) Size() (n int)

func (*Ip) String 

func (m *Ip) String() string

func (*Ip) Unmarshal 

func (m *Ip) Unmarshal(dAtA []byte) error

func (*Ip) XXX_DiscardUnknown 

func (m *Ip) XXX_DiscardUnknown()

func (*Ip) XXX_Marshal 

func (m *Ip) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ip) XXX_Merge 

func (m *Ip) XXX_Merge(src proto.Message)

func (*Ip) XXX_Size 

func (m *Ip) XXX_Size() int

func (*Ip) XXX_Unmarshal 

func (m *Ip) XXX_Unmarshal(b []byte) error

type IpResource 

type IpResource struct {
	Ip                   *string  `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Masklen              *uint32  `protobuf:"varint,2,opt,name=masklen,def=32" json:"masklen,omitempty"`
	SubnetId             *uint32  `protobuf:"varint,3,opt,name=subnet_id,json=subnetId,def=0" json:"subnet_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IpResource) Descriptor 

func (*IpResource) Descriptor() ([]byte, []int)

func (*IpResource) GetIp 

func (m *IpResource) GetIp() string

func (*IpResource) GetMasklen 

func (m *IpResource) GetMasklen() uint32

func (*IpResource) GetSubnetId 

func (m *IpResource) GetSubnetId() uint32

func (*IpResource) Marshal 

func (m *IpResource) Marshal() (dAtA []byte, err error)

func (*IpResource) MarshalTo 

func (m *IpResource) MarshalTo(dAtA []byte) (int, error)

func (*IpResource) MarshalToSizedBuffer 

func (m *IpResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IpResource) ProtoMessage 

func (*IpResource) ProtoMessage()

func (*IpResource) Reset 

func (m *IpResource) Reset()

func (*IpResource) Size 

func (m *IpResource) Size() (n int)

func (*IpResource) String 

func (m *IpResource) String() string

func (*IpResource) Unmarshal 

func (m *IpResource) Unmarshal(dAtA []byte) error

func (*IpResource) XXX_DiscardUnknown 

func (m *IpResource) XXX_DiscardUnknown()

func (*IpResource) XXX_Marshal 

func (m *IpResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IpResource) XXX_Merge 

func (m *IpResource) XXX_Merge(src proto.Message)

func (*IpResource) XXX_Size 

func (m *IpResource) XXX_Size() int

func (*IpResource) XXX_Unmarshal 

func (m *IpResource) XXX_Unmarshal(b []byte) error

type KubernetesAPIInfo 

type KubernetesAPIInfo struct {
	Type                 *string  `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Info                 *string  `protobuf:"bytes,2,opt,name=info" json:"info,omitempty"`
	CompressedInfo       []byte   `protobuf:"bytes,3,opt,name=compressed_info,json=compressedInfo" json:"compressed_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubernetesAPIInfo) Descriptor 

func (*KubernetesAPIInfo) Descriptor() ([]byte, []int)

func (*KubernetesAPIInfo) GetCompressedInfo 

func (m *KubernetesAPIInfo) GetCompressedInfo() []byte

func (*KubernetesAPIInfo) GetInfo 

func (m *KubernetesAPIInfo) GetInfo() string

func (*KubernetesAPIInfo) GetType 

func (m *KubernetesAPIInfo) GetType() string

func (*KubernetesAPIInfo) Marshal 

func (m *KubernetesAPIInfo) Marshal() (dAtA []byte, err error)

func (*KubernetesAPIInfo) MarshalTo 

func (m *KubernetesAPIInfo) MarshalTo(dAtA []byte) (int, error)

func (*KubernetesAPIInfo) MarshalToSizedBuffer 

func (m *KubernetesAPIInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KubernetesAPIInfo) ProtoMessage 

func (*KubernetesAPIInfo) ProtoMessage()

func (*KubernetesAPIInfo) Reset 

func (m *KubernetesAPIInfo) Reset()

func (*KubernetesAPIInfo) Size 

func (m *KubernetesAPIInfo) Size() (n int)

func (*KubernetesAPIInfo) String 

func (m *KubernetesAPIInfo) String() string

func (*KubernetesAPIInfo) Unmarshal 

func (m *KubernetesAPIInfo) Unmarshal(dAtA []byte) error

func (*KubernetesAPIInfo) XXX_DiscardUnknown 

func (m *KubernetesAPIInfo) XXX_DiscardUnknown()

func (*KubernetesAPIInfo) XXX_Marshal 

func (m *KubernetesAPIInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubernetesAPIInfo) XXX_Merge 

func (m *KubernetesAPIInfo) XXX_Merge(src proto.Message)

func (*KubernetesAPIInfo) XXX_Size 

func (m *KubernetesAPIInfo) XXX_Size() int

func (*KubernetesAPIInfo) XXX_Unmarshal 

func (m *KubernetesAPIInfo) XXX_Unmarshal(b []byte) error

type KubernetesAPISyncRequest 

type KubernetesAPISyncRequest struct {
	ClusterId            *string              `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId" json:"cluster_id,omitempty"`
	Version              *uint64              `protobuf:"varint,2,opt,name=version" json:"version,omitempty"`
	ErrorMsg             *string              `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"`
	AgentId              *uint32              `protobuf:"varint,4,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	SourceIp             *string              `protobuf:"bytes,5,opt,name=source_ip,json=sourceIp" json:"source_ip,omitempty"`
	TeamId               *string              `protobuf:"bytes,6,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	Entries              []*KubernetesAPIInfo `protobuf:"bytes,10,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*KubernetesAPISyncRequest) Descriptor 

func (*KubernetesAPISyncRequest) Descriptor() ([]byte, []int)

func (*KubernetesAPISyncRequest) GetAgentId 

func (m *KubernetesAPISyncRequest) GetAgentId() uint32

func (*KubernetesAPISyncRequest) GetClusterId 

func (m *KubernetesAPISyncRequest) GetClusterId() string

func (*KubernetesAPISyncRequest) GetEntries 

func (m *KubernetesAPISyncRequest) GetEntries() []*KubernetesAPIInfo

func (*KubernetesAPISyncRequest) GetErrorMsg 

func (m *KubernetesAPISyncRequest) GetErrorMsg() string

func (*KubernetesAPISyncRequest) GetSourceIp 

func (m *KubernetesAPISyncRequest) GetSourceIp() string

func (*KubernetesAPISyncRequest) GetTeamId 

func (m *KubernetesAPISyncRequest) GetTeamId() string

func (*KubernetesAPISyncRequest) GetVersion 

func (m *KubernetesAPISyncRequest) GetVersion() uint64

func (*KubernetesAPISyncRequest) Marshal 

func (m *KubernetesAPISyncRequest) Marshal() (dAtA []byte, err error)

func (*KubernetesAPISyncRequest) MarshalTo 

func (m *KubernetesAPISyncRequest) MarshalTo(dAtA []byte) (int, error)

func (*KubernetesAPISyncRequest) MarshalToSizedBuffer 

func (m *KubernetesAPISyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KubernetesAPISyncRequest) ProtoMessage 

func (*KubernetesAPISyncRequest) ProtoMessage()

func (*KubernetesAPISyncRequest) Reset 

func (m *KubernetesAPISyncRequest) Reset()

func (*KubernetesAPISyncRequest) Size 

func (m *KubernetesAPISyncRequest) Size() (n int)

func (*KubernetesAPISyncRequest) String 

func (m *KubernetesAPISyncRequest) String() string

func (*KubernetesAPISyncRequest) Unmarshal 

func (m *KubernetesAPISyncRequest) Unmarshal(dAtA []byte) error

func (*KubernetesAPISyncRequest) XXX_DiscardUnknown 

func (m *KubernetesAPISyncRequest) XXX_DiscardUnknown()

func (*KubernetesAPISyncRequest) XXX_Marshal 

func (m *KubernetesAPISyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubernetesAPISyncRequest) XXX_Merge 

func (m *KubernetesAPISyncRequest) XXX_Merge(src proto.Message)

func (*KubernetesAPISyncRequest) XXX_Size 

func (m *KubernetesAPISyncRequest) XXX_Size() int

func (*KubernetesAPISyncRequest) XXX_Unmarshal 

func (m *KubernetesAPISyncRequest) XXX_Unmarshal(b []byte) error

type KubernetesAPISyncResponse 

type KubernetesAPISyncResponse struct {
	Version              *uint64  `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubernetesAPISyncResponse) Descriptor 

func (*KubernetesAPISyncResponse) Descriptor() ([]byte, []int)

func (*KubernetesAPISyncResponse) GetVersion 

func (m *KubernetesAPISyncResponse) GetVersion() uint64

func (*KubernetesAPISyncResponse) Marshal 

func (m *KubernetesAPISyncResponse) Marshal() (dAtA []byte, err error)

func (*KubernetesAPISyncResponse) MarshalTo 

func (m *KubernetesAPISyncResponse) MarshalTo(dAtA []byte) (int, error)

func (*KubernetesAPISyncResponse) MarshalToSizedBuffer 

func (m *KubernetesAPISyncResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KubernetesAPISyncResponse) ProtoMessage 

func (*KubernetesAPISyncResponse) ProtoMessage()

func (*KubernetesAPISyncResponse) Reset 

func (m *KubernetesAPISyncResponse) Reset()

func (*KubernetesAPISyncResponse) Size 

func (m *KubernetesAPISyncResponse) Size() (n int)

func (*KubernetesAPISyncResponse) String 

func (m *KubernetesAPISyncResponse) String() string

func (*KubernetesAPISyncResponse) Unmarshal 

func (m *KubernetesAPISyncResponse) Unmarshal(dAtA []byte) error

func (*KubernetesAPISyncResponse) XXX_DiscardUnknown 

func (m *KubernetesAPISyncResponse) XXX_DiscardUnknown()

func (*KubernetesAPISyncResponse) XXX_Marshal 

func (m *KubernetesAPISyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubernetesAPISyncResponse) XXX_Merge 

func (m *KubernetesAPISyncResponse) XXX_Merge(src proto.Message)

func (*KubernetesAPISyncResponse) XXX_Size 

func (m *KubernetesAPISyncResponse) XXX_Size() int

func (*KubernetesAPISyncResponse) XXX_Unmarshal 

func (m *KubernetesAPISyncResponse) XXX_Unmarshal(b []byte) error

type KubernetesClusterIDRequest 

type KubernetesClusterIDRequest struct {
	CaMd5                 *string  `protobuf:"bytes,1,opt,name=ca_md5,json=caMd5" json:"ca_md5,omitempty"`
	TeamId                *string  `protobuf:"bytes,2,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	KubernetesClusterName *string  `protobuf:"bytes,46,opt,name=kubernetes_cluster_name,json=kubernetesClusterName" json:"kubernetes_cluster_name,omitempty"`
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*KubernetesClusterIDRequest) Descriptor 

func (*KubernetesClusterIDRequest) Descriptor() ([]byte, []int)

func (*KubernetesClusterIDRequest) GetCaMd5 

func (m *KubernetesClusterIDRequest) GetCaMd5() string

func (*KubernetesClusterIDRequest) GetKubernetesClusterName 

func (m *KubernetesClusterIDRequest) GetKubernetesClusterName() string

func (*KubernetesClusterIDRequest) GetTeamId 

func (m *KubernetesClusterIDRequest) GetTeamId() string

func (*KubernetesClusterIDRequest) Marshal 

func (m *KubernetesClusterIDRequest) Marshal() (dAtA []byte, err error)

func (*KubernetesClusterIDRequest) MarshalTo 

func (m *KubernetesClusterIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*KubernetesClusterIDRequest) MarshalToSizedBuffer 

func (m *KubernetesClusterIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KubernetesClusterIDRequest) ProtoMessage 

func (*KubernetesClusterIDRequest) ProtoMessage()

func (*KubernetesClusterIDRequest) Reset 

func (m *KubernetesClusterIDRequest) Reset()

func (*KubernetesClusterIDRequest) Size 

func (m *KubernetesClusterIDRequest) Size() (n int)

func (*KubernetesClusterIDRequest) String 

func (m *KubernetesClusterIDRequest) String() string

func (*KubernetesClusterIDRequest) Unmarshal 

func (m *KubernetesClusterIDRequest) Unmarshal(dAtA []byte) error

func (*KubernetesClusterIDRequest) XXX_DiscardUnknown 

func (m *KubernetesClusterIDRequest) XXX_DiscardUnknown()

func (*KubernetesClusterIDRequest) XXX_Marshal 

func (m *KubernetesClusterIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubernetesClusterIDRequest) XXX_Merge 

func (m *KubernetesClusterIDRequest) XXX_Merge(src proto.Message)

func (*KubernetesClusterIDRequest) XXX_Size 

func (m *KubernetesClusterIDRequest) XXX_Size() int

func (*KubernetesClusterIDRequest) XXX_Unmarshal 

func (m *KubernetesClusterIDRequest) XXX_Unmarshal(b []byte) error

type KubernetesClusterIDResponse 

type KubernetesClusterIDResponse struct {
	ErrorMsg             *string  `protobuf:"bytes,1,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"`
	ClusterId            *string  `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId" json:"cluster_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubernetesClusterIDResponse) Descriptor 

func (*KubernetesClusterIDResponse) Descriptor() ([]byte, []int)

func (*KubernetesClusterIDResponse) GetClusterId 

func (m *KubernetesClusterIDResponse) GetClusterId() string

func (*KubernetesClusterIDResponse) GetErrorMsg 

func (m *KubernetesClusterIDResponse) GetErrorMsg() string

func (*KubernetesClusterIDResponse) Marshal 

func (m *KubernetesClusterIDResponse) Marshal() (dAtA []byte, err error)

func (*KubernetesClusterIDResponse) MarshalTo 

func (m *KubernetesClusterIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*KubernetesClusterIDResponse) MarshalToSizedBuffer 

func (m *KubernetesClusterIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KubernetesClusterIDResponse) ProtoMessage 

func (*KubernetesClusterIDResponse) ProtoMessage()

func (*KubernetesClusterIDResponse) Reset 

func (m *KubernetesClusterIDResponse) Reset()

func (*KubernetesClusterIDResponse) Size 

func (m *KubernetesClusterIDResponse) Size() (n int)

func (*KubernetesClusterIDResponse) String 

func (m *KubernetesClusterIDResponse) String() string

func (*KubernetesClusterIDResponse) Unmarshal 

func (m *KubernetesClusterIDResponse) Unmarshal(dAtA []byte) error

func (*KubernetesClusterIDResponse) XXX_DiscardUnknown 

func (m *KubernetesClusterIDResponse) XXX_DiscardUnknown()

func (*KubernetesClusterIDResponse) XXX_Marshal 

func (m *KubernetesClusterIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubernetesClusterIDResponse) XXX_Merge 

func (m *KubernetesClusterIDResponse) XXX_Merge(src proto.Message)

func (*KubernetesClusterIDResponse) XXX_Size 

func (m *KubernetesClusterIDResponse) XXX_Size() int

func (*KubernetesClusterIDResponse) XXX_Unmarshal 

func (m *KubernetesClusterIDResponse) XXX_Unmarshal(b []byte) error

type KubernetesWatchPolicy 

type KubernetesWatchPolicy int32
const (
	KubernetesWatchPolicy_KWP_NORMAL         KubernetesWatchPolicy = 0
	KubernetesWatchPolicy_KWP_WATCH_ONLY     KubernetesWatchPolicy = 1
	KubernetesWatchPolicy_KWP_WATCH_DISABLED KubernetesWatchPolicy = 2
)

func (KubernetesWatchPolicy) Enum 

func (x KubernetesWatchPolicy) Enum() *KubernetesWatchPolicy

func (KubernetesWatchPolicy) EnumDescriptor 

func (KubernetesWatchPolicy) EnumDescriptor() ([]byte, []int)

func (KubernetesWatchPolicy) String 

func (x KubernetesWatchPolicy) String() string

func (*KubernetesWatchPolicy) UnmarshalJSON 

func (x *KubernetesWatchPolicy) UnmarshalJSON(data []byte) error

type LinuxNamespace 

type LinuxNamespace struct {
	Id                   *uint64  `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	NsType               *string  `protobuf:"bytes,2,opt,name=ns_type,json=nsType" json:"ns_type,omitempty"`
	User                 *string  `protobuf:"bytes,3,opt,name=user" json:"user,omitempty"`
	Pid                  *uint32  `protobuf:"varint,4,opt,name=pid" json:"pid,omitempty"`
	Cmd                  *string  `protobuf:"bytes,5,opt,name=cmd" json:"cmd,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LinuxNamespace) Descriptor 

func (*LinuxNamespace) Descriptor() ([]byte, []int)

func (*LinuxNamespace) GetCmd 

func (m *LinuxNamespace) GetCmd() string

func (*LinuxNamespace) GetId 

func (m *LinuxNamespace) GetId() uint64

func (*LinuxNamespace) GetNsType 

func (m *LinuxNamespace) GetNsType() string

func (*LinuxNamespace) GetPid 

func (m *LinuxNamespace) GetPid() uint32

func (*LinuxNamespace) GetUser 

func (m *LinuxNamespace) GetUser() string

func (*LinuxNamespace) Marshal 

func (m *LinuxNamespace) Marshal() (dAtA []byte, err error)

func (*LinuxNamespace) MarshalTo 

func (m *LinuxNamespace) MarshalTo(dAtA []byte) (int, error)

func (*LinuxNamespace) MarshalToSizedBuffer 

func (m *LinuxNamespace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LinuxNamespace) ProtoMessage 

func (*LinuxNamespace) ProtoMessage()

func (*LinuxNamespace) Reset 

func (m *LinuxNamespace) Reset()

func (*LinuxNamespace) Size 

func (m *LinuxNamespace) Size() (n int)

func (*LinuxNamespace) String 

func (m *LinuxNamespace) String() string

func (*LinuxNamespace) Unmarshal 

func (m *LinuxNamespace) Unmarshal(dAtA []byte) error

func (*LinuxNamespace) XXX_DiscardUnknown 

func (m *LinuxNamespace) XXX_DiscardUnknown()

func (*LinuxNamespace) XXX_Marshal 

func (m *LinuxNamespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LinuxNamespace) XXX_Merge 

func (m *LinuxNamespace) XXX_Merge(src proto.Message)

func (*LinuxNamespace) XXX_Size 

func (m *LinuxNamespace) XXX_Size() int

func (*LinuxNamespace) XXX_Unmarshal 

func (m *LinuxNamespace) XXX_Unmarshal(b []byte) error

type Lldp 

type Lldp struct {
	Interface            *string  `protobuf:"bytes,1,opt,name=interface" json:"interface,omitempty"`
	SystemName           *string  `protobuf:"bytes,2,opt,name=system_name,json=systemName" json:"system_name,omitempty"`
	ManagementAddress    *string  `protobuf:"bytes,5,opt,name=management_address,json=managementAddress" json:"management_address,omitempty"`
	PortId               *string  `protobuf:"bytes,10,opt,name=port_id,json=portId" json:"port_id,omitempty"`
	PortDescription      *string  `protobuf:"bytes,11,opt,name=port_description,json=portDescription" json:"port_description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Lldp) Descriptor 

func (*Lldp) Descriptor() ([]byte, []int)

func (*Lldp) GetInterface 

func (m *Lldp) GetInterface() string

func (*Lldp) GetManagementAddress 

func (m *Lldp) GetManagementAddress() string

func (*Lldp) GetPortDescription 

func (m *Lldp) GetPortDescription() string

func (*Lldp) GetPortId 

func (m *Lldp) GetPortId() string

func (*Lldp) GetSystemName 

func (m *Lldp) GetSystemName() string

func (*Lldp) Marshal 

func (m *Lldp) Marshal() (dAtA []byte, err error)

func (*Lldp) MarshalTo 

func (m *Lldp) MarshalTo(dAtA []byte) (int, error)

func (*Lldp) MarshalToSizedBuffer 

func (m *Lldp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Lldp) ProtoMessage 

func (*Lldp) ProtoMessage()

func (*Lldp) Reset 

func (m *Lldp) Reset()

func (*Lldp) Size 

func (m *Lldp) Size() (n int)

func (*Lldp) String 

func (m *Lldp) String() string

func (*Lldp) Unmarshal 

func (m *Lldp) Unmarshal(dAtA []byte) error

func (*Lldp) XXX_DiscardUnknown 

func (m *Lldp) XXX_DiscardUnknown()

func (*Lldp) XXX_Marshal 

func (m *Lldp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Lldp) XXX_Merge 

func (m *Lldp) XXX_Merge(src proto.Message)

func (*Lldp) XXX_Size 

func (m *Lldp) XXX_Size() int

func (*Lldp) XXX_Unmarshal 

func (m *Lldp) XXX_Unmarshal(b []byte) error

type NpbAction 

type NpbAction struct {
	TunnelType           *TunnelType        `protobuf:"varint,1,opt,name=tunnel_type,json=tunnelType,enum=agent.TunnelType,def=0" json:"tunnel_type,omitempty"`
	TunnelId             *uint32            `protobuf:"varint,2,opt,name=tunnel_id,json=tunnelId" json:"tunnel_id,omitempty"`
	TunnelIp             *string            `protobuf:"bytes,3,opt,name=tunnel_ip,json=tunnelIp" json:"tunnel_ip,omitempty"`
	PacketCaptureSide    *PacketCaptureSide `` /* 137-byte string literal not displayed */
	PayloadSlice         *uint32            `protobuf:"varint,5,opt,name=payload_slice,json=payloadSlice,def=65535" json:"payload_slice,omitempty"`
	NpbAclGroupId        *uint32            `protobuf:"varint,6,opt,name=npb_acl_group_id,json=npbAclGroupId" json:"npb_acl_group_id,omitempty"`
	TunnelIpId           *uint32            `protobuf:"varint,7,opt,name=tunnel_ip_id,json=tunnelIpId" json:"tunnel_ip_id,omitempty"`
	Direction            *Direction         `protobuf:"varint,8,opt,name=direction,enum=agent.Direction,def=1" json:"direction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*NpbAction) Descriptor 

func (*NpbAction) Descriptor() ([]byte, []int)

func (*NpbAction) GetDirection 

func (m *NpbAction) GetDirection() Direction

func (*NpbAction) GetNpbAclGroupId 

func (m *NpbAction) GetNpbAclGroupId() uint32

func (*NpbAction) GetPacketCaptureSide 

func (m *NpbAction) GetPacketCaptureSide() PacketCaptureSide

func (*NpbAction) GetPayloadSlice 

func (m *NpbAction) GetPayloadSlice() uint32

func (*NpbAction) GetTunnelId 

func (m *NpbAction) GetTunnelId() uint32

func (*NpbAction) GetTunnelIp 

func (m *NpbAction) GetTunnelIp() string

func (*NpbAction) GetTunnelIpId 

func (m *NpbAction) GetTunnelIpId() uint32

func (*NpbAction) GetTunnelType 

func (m *NpbAction) GetTunnelType() TunnelType

func (*NpbAction) Marshal 

func (m *NpbAction) Marshal() (dAtA []byte, err error)

func (*NpbAction) MarshalTo 

func (m *NpbAction) MarshalTo(dAtA []byte) (int, error)

func (*NpbAction) MarshalToSizedBuffer 

func (m *NpbAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NpbAction) ProtoMessage 

func (*NpbAction) ProtoMessage()

func (*NpbAction) Reset 

func (m *NpbAction) Reset()

func (*NpbAction) Size 

func (m *NpbAction) Size() (n int)

func (*NpbAction) String 

func (m *NpbAction) String() string

func (*NpbAction) Unmarshal 

func (m *NpbAction) Unmarshal(dAtA []byte) error

func (*NpbAction) XXX_DiscardUnknown 

func (m *NpbAction) XXX_DiscardUnknown()

func (*NpbAction) XXX_Marshal 

func (m *NpbAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NpbAction) XXX_Merge 

func (m *NpbAction) XXX_Merge(src proto.Message)

func (*NpbAction) XXX_Size 

func (m *NpbAction) XXX_Size() int

func (*NpbAction) XXX_Unmarshal 

func (m *NpbAction) XXX_Unmarshal(b []byte) error

type NtpRequest 

type NtpRequest struct {
	CtrlIp               *string  `protobuf:"bytes,1,opt,name=ctrl_ip,json=ctrlIp" json:"ctrl_ip,omitempty"`
	Request              []byte   `protobuf:"bytes,10,opt,name=request" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NtpRequest) Descriptor 

func (*NtpRequest) Descriptor() ([]byte, []int)

func (*NtpRequest) GetCtrlIp 

func (m *NtpRequest) GetCtrlIp() string

func (*NtpRequest) GetRequest 

func (m *NtpRequest) GetRequest() []byte

func (*NtpRequest) Marshal 

func (m *NtpRequest) Marshal() (dAtA []byte, err error)

func (*NtpRequest) MarshalTo 

func (m *NtpRequest) MarshalTo(dAtA []byte) (int, error)

func (*NtpRequest) MarshalToSizedBuffer 

func (m *NtpRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NtpRequest) ProtoMessage 

func (*NtpRequest) ProtoMessage()

func (*NtpRequest) Reset 

func (m *NtpRequest) Reset()

func (*NtpRequest) Size 

func (m *NtpRequest) Size() (n int)

func (*NtpRequest) String 

func (m *NtpRequest) String() string

func (*NtpRequest) Unmarshal 

func (m *NtpRequest) Unmarshal(dAtA []byte) error

func (*NtpRequest) XXX_DiscardUnknown 

func (m *NtpRequest) XXX_DiscardUnknown()

func (*NtpRequest) XXX_Marshal 

func (m *NtpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NtpRequest) XXX_Merge 

func (m *NtpRequest) XXX_Merge(src proto.Message)

func (*NtpRequest) XXX_Size 

func (m *NtpRequest) XXX_Size() int

func (*NtpRequest) XXX_Unmarshal 

func (m *NtpRequest) XXX_Unmarshal(b []byte) error

type NtpResponse 

type NtpResponse struct {
	Response             []byte   `protobuf:"bytes,1,opt,name=response" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NtpResponse) Descriptor 

func (*NtpResponse) Descriptor() ([]byte, []int)

func (*NtpResponse) GetResponse 

func (m *NtpResponse) GetResponse() []byte

func (*NtpResponse) Marshal 

func (m *NtpResponse) Marshal() (dAtA []byte, err error)

func (*NtpResponse) MarshalTo 

func (m *NtpResponse) MarshalTo(dAtA []byte) (int, error)

func (*NtpResponse) MarshalToSizedBuffer 

func (m *NtpResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NtpResponse) ProtoMessage 

func (*NtpResponse) ProtoMessage()

func (*NtpResponse) Reset 

func (m *NtpResponse) Reset()

func (*NtpResponse) Size 

func (m *NtpResponse) Size() (n int)

func (*NtpResponse) String 

func (m *NtpResponse) String() string

func (*NtpResponse) Unmarshal 

func (m *NtpResponse) Unmarshal(dAtA []byte) error

func (*NtpResponse) XXX_DiscardUnknown 

func (m *NtpResponse) XXX_DiscardUnknown()

func (*NtpResponse) XXX_Marshal 

func (m *NtpResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NtpResponse) XXX_Merge 

func (m *NtpResponse) XXX_Merge(src proto.Message)

func (*NtpResponse) XXX_Size 

func (m *NtpResponse) XXX_Size() int

func (*NtpResponse) XXX_Unmarshal 

func (m *NtpResponse) XXX_Unmarshal(b []byte) error

type OutputFormat 

type OutputFormat int32
const (
	OutputFormat_TEXT   OutputFormat = 0
	OutputFormat_BINARY OutputFormat = 1
)

func (OutputFormat) Enum 

func (x OutputFormat) Enum() *OutputFormat

func (OutputFormat) EnumDescriptor 

func (OutputFormat) EnumDescriptor() ([]byte, []int)

func (OutputFormat) String 

func (x OutputFormat) String() string

func (*OutputFormat) UnmarshalJSON 

func (x *OutputFormat) UnmarshalJSON(data []byte) error

type PacketCaptureSide 

type PacketCaptureSide int32
const (
	PacketCaptureSide_SRC  PacketCaptureSide = 1
	PacketCaptureSide_DST  PacketCaptureSide = 2
	PacketCaptureSide_BOTH PacketCaptureSide = 3
)

func (PacketCaptureSide) Enum 

func (x PacketCaptureSide) Enum() *PacketCaptureSide

func (PacketCaptureSide) EnumDescriptor 

func (PacketCaptureSide) EnumDescriptor() ([]byte, []int)

func (PacketCaptureSide) String 

func (x PacketCaptureSide) String() string

func (*PacketCaptureSide) UnmarshalJSON 

func (x *PacketCaptureSide) UnmarshalJSON(data []byte) error

type PacketCaptureType 

type PacketCaptureType int32
const (
	PacketCaptureType_LOCAL    PacketCaptureType = 0
	PacketCaptureType_MIRROR   PacketCaptureType = 1
	PacketCaptureType_ANALYZER PacketCaptureType = 2
	PacketCaptureType_DECAP    PacketCaptureType = 3
)
const Default_SyncRequest_PacketCaptureType PacketCaptureType = PacketCaptureType_LOCAL

func (PacketCaptureType) Enum 

func (x PacketCaptureType) Enum() *PacketCaptureType

func (PacketCaptureType) EnumDescriptor 

func (PacketCaptureType) EnumDescriptor() ([]byte, []int)

func (PacketCaptureType) String 

func (x PacketCaptureType) String() string

func (*PacketCaptureType) UnmarshalJSON 

func (x *PacketCaptureType) UnmarshalJSON(data []byte) error

type PacketType 

type PacketType int32
const (
	PacketType_PACKET       PacketType = 1
	PacketType_SFLOW        PacketType = 2
	PacketType_NETFLOW_V5   PacketType = 3
	PacketType_NETSTREAM_V5 PacketType = 4
	PacketType_NETFLOW_V9   PacketType = 5
	PacketType_NETSTREAM_V9 PacketType = 6
)

func (PacketType) Enum 

func (x PacketType) Enum() *PacketType

func (PacketType) EnumDescriptor 

func (PacketType) EnumDescriptor() ([]byte, []int)

func (PacketType) String 

func (x PacketType) String() string

func (*PacketType) UnmarshalJSON 

func (x *PacketType) UnmarshalJSON(data []byte) error

type ParamType 

type ParamType int32
const (
	ParamType_PF_TEXT    ParamType = 0
	ParamType_PF_BOOLEAN ParamType = 1
)

func (ParamType) Enum 

func (x ParamType) Enum() *ParamType

func (ParamType) EnumDescriptor 

func (ParamType) EnumDescriptor() ([]byte, []int)

func (ParamType) String 

func (x ParamType) String() string

func (*ParamType) UnmarshalJSON 

func (x *ParamType) UnmarshalJSON(data []byte) error

type Parameter 

type Parameter struct {
	Key                  *string  `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value                *string  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Parameter) Descriptor 

func (*Parameter) Descriptor() ([]byte, []int)

func (*Parameter) GetKey 

func (m *Parameter) GetKey() string

func (*Parameter) GetValue 

func (m *Parameter) GetValue() string

func (*Parameter) Marshal 

func (m *Parameter) Marshal() (dAtA []byte, err error)

func (*Parameter) MarshalTo 

func (m *Parameter) MarshalTo(dAtA []byte) (int, error)

func (*Parameter) MarshalToSizedBuffer 

func (m *Parameter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) Size 

func (m *Parameter) Size() (n int)

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) Unmarshal 

func (m *Parameter) Unmarshal(dAtA []byte) error

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Parameter) XXX_Merge 

func (m *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

func (m *Parameter) XXX_Unmarshal(b []byte) error

type Pcap 

type Pcap struct {
	FlowId               *uint64  `protobuf:"varint,1,opt,name=flow_id,json=flowId" json:"flow_id,omitempty"`
	StartTime            *uint64  `protobuf:"varint,2,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	EndTime              *uint64  `protobuf:"varint,3,opt,name=end_time,json=endTime" json:"end_time,omitempty"`
	PacketCount          *uint32  `protobuf:"varint,4,opt,name=packet_count,json=packetCount" json:"packet_count,omitempty"`
	PacketRecords        []byte   `protobuf:"bytes,5,opt,name=packet_records,json=packetRecords" json:"packet_records,omitempty"`
	AclGids              []uint32 `protobuf:"varint,6,rep,name=acl_gids,json=aclGids" json:"acl_gids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pcap) Descriptor 

func (*Pcap) Descriptor() ([]byte, []int)

func (*Pcap) GetAclGids 

func (m *Pcap) GetAclGids() []uint32

func (*Pcap) GetEndTime 

func (m *Pcap) GetEndTime() uint64

func (*Pcap) GetFlowId 

func (m *Pcap) GetFlowId() uint64

func (*Pcap) GetPacketCount 

func (m *Pcap) GetPacketCount() uint32

func (*Pcap) GetPacketRecords 

func (m *Pcap) GetPacketRecords() []byte

func (*Pcap) GetStartTime 

func (m *Pcap) GetStartTime() uint64

func (*Pcap) Marshal 

func (m *Pcap) Marshal() (dAtA []byte, err error)

func (*Pcap) MarshalTo 

func (m *Pcap) MarshalTo(dAtA []byte) (int, error)

func (*Pcap) MarshalToSizedBuffer 

func (m *Pcap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pcap) ProtoMessage 

func (*Pcap) ProtoMessage()

func (*Pcap) Reset 

func (m *Pcap) Reset()

func (*Pcap) Size 

func (m *Pcap) Size() (n int)

func (*Pcap) String 

func (m *Pcap) String() string

func (*Pcap) Unmarshal 

func (m *Pcap) Unmarshal(dAtA []byte) error

func (*Pcap) XXX_DiscardUnknown 

func (m *Pcap) XXX_DiscardUnknown()

func (*Pcap) XXX_Marshal 

func (m *Pcap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pcap) XXX_Merge 

func (m *Pcap) XXX_Merge(src proto.Message)

func (*Pcap) XXX_Size 

func (m *Pcap) XXX_Size() int

func (*Pcap) XXX_Unmarshal 

func (m *Pcap) XXX_Unmarshal(b []byte) error

type PcapBatch 

type PcapBatch struct {
	Magic                *uint32  `protobuf:"varint,1,opt,name=magic" json:"magic,omitempty"`
	Batches              []*Pcap  `protobuf:"bytes,2,rep,name=batches" json:"batches,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PcapBatch) Descriptor 

func (*PcapBatch) Descriptor() ([]byte, []int)

func (*PcapBatch) GetBatches 

func (m *PcapBatch) GetBatches() []*Pcap

func (*PcapBatch) GetMagic 

func (m *PcapBatch) GetMagic() uint32

func (*PcapBatch) Marshal 

func (m *PcapBatch) Marshal() (dAtA []byte, err error)

func (*PcapBatch) MarshalTo 

func (m *PcapBatch) MarshalTo(dAtA []byte) (int, error)

func (*PcapBatch) MarshalToSizedBuffer 

func (m *PcapBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PcapBatch) ProtoMessage 

func (*PcapBatch) ProtoMessage()

func (*PcapBatch) Reset 

func (m *PcapBatch) Reset()

func (*PcapBatch) Size 

func (m *PcapBatch) Size() (n int)

func (*PcapBatch) String 

func (m *PcapBatch) String() string

func (*PcapBatch) Unmarshal 

func (m *PcapBatch) Unmarshal(dAtA []byte) error

func (*PcapBatch) XXX_DiscardUnknown 

func (m *PcapBatch) XXX_DiscardUnknown()

func (*PcapBatch) XXX_Marshal 

func (m *PcapBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PcapBatch) XXX_Merge 

func (m *PcapBatch) XXX_Merge(src proto.Message)

func (*PcapBatch) XXX_Size 

func (m *PcapBatch) XXX_Size() int

func (*PcapBatch) XXX_Unmarshal 

func (m *PcapBatch) XXX_Unmarshal(b []byte) error

type PeerConnection 

type PeerConnection struct {
	Id                   *uint32  `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	LocalEpcId           *uint32  `protobuf:"varint,2,opt,name=local_epc_id,json=localEpcId" json:"local_epc_id,omitempty"`
	RemoteEpcId          *uint32  `protobuf:"varint,3,opt,name=remote_epc_id,json=remoteEpcId" json:"remote_epc_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerConnection) Descriptor 

func (*PeerConnection) Descriptor() ([]byte, []int)

func (*PeerConnection) GetId 

func (m *PeerConnection) GetId() uint32

func (*PeerConnection) GetLocalEpcId 

func (m *PeerConnection) GetLocalEpcId() uint32

func (*PeerConnection) GetRemoteEpcId 

func (m *PeerConnection) GetRemoteEpcId() uint32

func (*PeerConnection) Marshal 

func (m *PeerConnection) Marshal() (dAtA []byte, err error)

func (*PeerConnection) MarshalTo 

func (m *PeerConnection) MarshalTo(dAtA []byte) (int, error)

func (*PeerConnection) MarshalToSizedBuffer 

func (m *PeerConnection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeerConnection) ProtoMessage 

func (*PeerConnection) ProtoMessage()

func (*PeerConnection) Reset 

func (m *PeerConnection) Reset()

func (*PeerConnection) Size 

func (m *PeerConnection) Size() (n int)

func (*PeerConnection) String 

func (m *PeerConnection) String() string

func (*PeerConnection) Unmarshal 

func (m *PeerConnection) Unmarshal(dAtA []byte) error

func (*PeerConnection) XXX_DiscardUnknown 

func (m *PeerConnection) XXX_DiscardUnknown()

func (*PeerConnection) XXX_Marshal 

func (m *PeerConnection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerConnection) XXX_Merge 

func (m *PeerConnection) XXX_Merge(src proto.Message)

func (*PeerConnection) XXX_Size 

func (m *PeerConnection) XXX_Size() int

func (*PeerConnection) XXX_Unmarshal 

func (m *PeerConnection) XXX_Unmarshal(b []byte) error

type PlatformData 

type PlatformData struct {
	Interfaces           []*Interface      `protobuf:"bytes,1,rep,name=interfaces" json:"interfaces,omitempty"`
	PeerConnections      []*PeerConnection `protobuf:"bytes,3,rep,name=peer_connections,json=peerConnections" json:"peer_connections,omitempty"`
	Cidrs                []*Cidr           `protobuf:"bytes,4,rep,name=cidrs" json:"cidrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PlatformData) Descriptor 

func (*PlatformData) Descriptor() ([]byte, []int)

func (*PlatformData) GetCidrs 

func (m *PlatformData) GetCidrs() []*Cidr

func (*PlatformData) GetInterfaces 

func (m *PlatformData) GetInterfaces() []*Interface

func (*PlatformData) GetPeerConnections 

func (m *PlatformData) GetPeerConnections() []*PeerConnection

func (*PlatformData) Marshal 

func (m *PlatformData) Marshal() (dAtA []byte, err error)

func (*PlatformData) MarshalTo 

func (m *PlatformData) MarshalTo(dAtA []byte) (int, error)

func (*PlatformData) MarshalToSizedBuffer 

func (m *PlatformData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlatformData) ProtoMessage 

func (*PlatformData) ProtoMessage()

func (*PlatformData) Reset 

func (m *PlatformData) Reset()

func (*PlatformData) Size 

func (m *PlatformData) Size() (n int)

func (*PlatformData) String 

func (m *PlatformData) String() string

func (*PlatformData) Unmarshal 

func (m *PlatformData) Unmarshal(dAtA []byte) error

func (*PlatformData) XXX_DiscardUnknown 

func (m *PlatformData) XXX_DiscardUnknown()

func (*PlatformData) XXX_Marshal 

func (m *PlatformData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlatformData) XXX_Merge 

func (m *PlatformData) XXX_Merge(src proto.Message)

func (*PlatformData) XXX_Size 

func (m *PlatformData) XXX_Size() int

func (*PlatformData) XXX_Unmarshal 

func (m *PlatformData) XXX_Unmarshal(b []byte) error

type PluginConfig 

type PluginConfig struct {
	UpdateTime           *uint32  `protobuf:"varint,1,opt,name=update_time,json=updateTime,def=0" json:"update_time,omitempty"`
	WasmPlugins          []string `protobuf:"bytes,2,rep,name=wasm_plugins,json=wasmPlugins" json:"wasm_plugins,omitempty"`
	SoPlugins            []string `protobuf:"bytes,3,rep,name=so_plugins,json=soPlugins" json:"so_plugins,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PluginConfig) Descriptor 

func (*PluginConfig) Descriptor() ([]byte, []int)

func (*PluginConfig) GetSoPlugins 

func (m *PluginConfig) GetSoPlugins() []string

func (*PluginConfig) GetUpdateTime 

func (m *PluginConfig) GetUpdateTime() uint32

func (*PluginConfig) GetWasmPlugins 

func (m *PluginConfig) GetWasmPlugins() []string

func (*PluginConfig) Marshal 

func (m *PluginConfig) Marshal() (dAtA []byte, err error)

func (*PluginConfig) MarshalTo 

func (m *PluginConfig) MarshalTo(dAtA []byte) (int, error)

func (*PluginConfig) MarshalToSizedBuffer 

func (m *PluginConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PluginConfig) ProtoMessage 

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) Reset 

func (m *PluginConfig) Reset()

func (*PluginConfig) Size 

func (m *PluginConfig) Size() (n int)

func (*PluginConfig) String 

func (m *PluginConfig) String() string

func (*PluginConfig) Unmarshal 

func (m *PluginConfig) Unmarshal(dAtA []byte) error

func (*PluginConfig) XXX_DiscardUnknown 

func (m *PluginConfig) XXX_DiscardUnknown()

func (*PluginConfig) XXX_Marshal 

func (m *PluginConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginConfig) XXX_Merge 

func (m *PluginConfig) XXX_Merge(src proto.Message)

func (*PluginConfig) XXX_Size 

func (m *PluginConfig) XXX_Size() int

func (*PluginConfig) XXX_Unmarshal 

func (m *PluginConfig) XXX_Unmarshal(b []byte) error

type PluginRequest 

type PluginRequest struct {
	CtrlIp               *string     `protobuf:"bytes,1,opt,name=ctrl_ip,json=ctrlIp" json:"ctrl_ip,omitempty"`
	CtrlMac              *string     `protobuf:"bytes,2,opt,name=ctrl_mac,json=ctrlMac" json:"ctrl_mac,omitempty"`
	PluginType           *PluginType `protobuf:"varint,3,opt,name=plugin_type,json=pluginType,enum=agent.PluginType" json:"plugin_type,omitempty"`
	PluginName           *string     `protobuf:"bytes,4,opt,name=plugin_name,json=pluginName" json:"plugin_name,omitempty"`
	TeamId               *string     `protobuf:"bytes,5,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PluginRequest) Descriptor 

func (*PluginRequest) Descriptor() ([]byte, []int)

func (*PluginRequest) GetCtrlIp 

func (m *PluginRequest) GetCtrlIp() string

func (*PluginRequest) GetCtrlMac 

func (m *PluginRequest) GetCtrlMac() string

func (*PluginRequest) GetPluginName 

func (m *PluginRequest) GetPluginName() string

func (*PluginRequest) GetPluginType 

func (m *PluginRequest) GetPluginType() PluginType

func (*PluginRequest) GetTeamId 

func (m *PluginRequest) GetTeamId() string

func (*PluginRequest) Marshal 

func (m *PluginRequest) Marshal() (dAtA []byte, err error)

func (*PluginRequest) MarshalTo 

func (m *PluginRequest) MarshalTo(dAtA []byte) (int, error)

func (*PluginRequest) MarshalToSizedBuffer 

func (m *PluginRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PluginRequest) ProtoMessage 

func (*PluginRequest) ProtoMessage()

func (*PluginRequest) Reset 

func (m *PluginRequest) Reset()

func (*PluginRequest) Size 

func (m *PluginRequest) Size() (n int)

func (*PluginRequest) String 

func (m *PluginRequest) String() string

func (*PluginRequest) Unmarshal 

func (m *PluginRequest) Unmarshal(dAtA []byte) error

func (*PluginRequest) XXX_DiscardUnknown 

func (m *PluginRequest) XXX_DiscardUnknown()

func (*PluginRequest) XXX_Marshal 

func (m *PluginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginRequest) XXX_Merge 

func (m *PluginRequest) XXX_Merge(src proto.Message)

func (*PluginRequest) XXX_Size 

func (m *PluginRequest) XXX_Size() int

func (*PluginRequest) XXX_Unmarshal 

func (m *PluginRequest) XXX_Unmarshal(b []byte) error

type PluginResponse 

type PluginResponse struct {
	Status               *Status  `protobuf:"varint,1,opt,name=status,enum=agent.Status" json:"status,omitempty"`
	Content              []byte   `protobuf:"bytes,2,opt,name=content" json:"content,omitempty"`
	Md5                  *string  `protobuf:"bytes,3,opt,name=md5" json:"md5,omitempty"`
	TotalLen             *uint64  `protobuf:"varint,4,opt,name=total_len,json=totalLen" json:"total_len,omitempty"`
	PktCount             *uint32  `protobuf:"varint,5,opt,name=pkt_count,json=pktCount" json:"pkt_count,omitempty"`
	UpdateTime           *uint32  `protobuf:"varint,6,opt,name=update_time,json=updateTime,def=0" json:"update_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PluginResponse) Descriptor 

func (*PluginResponse) Descriptor() ([]byte, []int)

func (*PluginResponse) GetContent 

func (m *PluginResponse) GetContent() []byte

func (*PluginResponse) GetMd5 

func (m *PluginResponse) GetMd5() string

func (*PluginResponse) GetPktCount 

func (m *PluginResponse) GetPktCount() uint32

func (*PluginResponse) GetStatus 

func (m *PluginResponse) GetStatus() Status

func (*PluginResponse) GetTotalLen 

func (m *PluginResponse) GetTotalLen() uint64

func (*PluginResponse) GetUpdateTime 

func (m *PluginResponse) GetUpdateTime() uint32

func (*PluginResponse) Marshal 

func (m *PluginResponse) Marshal() (dAtA []byte, err error)

func (*PluginResponse) MarshalTo 

func (m *PluginResponse) MarshalTo(dAtA []byte) (int, error)

func (*PluginResponse) MarshalToSizedBuffer 

func (m *PluginResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PluginResponse) ProtoMessage 

func (*PluginResponse) ProtoMessage()

func (*PluginResponse) Reset 

func (m *PluginResponse) Reset()

func (*PluginResponse) Size 

func (m *PluginResponse) Size() (n int)

func (*PluginResponse) String 

func (m *PluginResponse) String() string

func (*PluginResponse) Unmarshal 

func (m *PluginResponse) Unmarshal(dAtA []byte) error

func (*PluginResponse) XXX_DiscardUnknown 

func (m *PluginResponse) XXX_DiscardUnknown()

func (*PluginResponse) XXX_Marshal 

func (m *PluginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginResponse) XXX_Merge 

func (m *PluginResponse) XXX_Merge(src proto.Message)

func (*PluginResponse) XXX_Size 

func (m *PluginResponse) XXX_Size() int

func (*PluginResponse) XXX_Unmarshal 

func (m *PluginResponse) XXX_Unmarshal(b []byte) error

type PluginType 

type PluginType int32
const (
	PluginType_WASM PluginType = 1
	PluginType_SO   PluginType = 2
)

func (PluginType) Enum 

func (x PluginType) Enum() *PluginType

func (PluginType) EnumDescriptor 

func (PluginType) EnumDescriptor() ([]byte, []int)

func (PluginType) String 

func (x PluginType) String() string

func (*PluginType) UnmarshalJSON 

func (x *PluginType) UnmarshalJSON(data []byte) error

type ProcessInfo 

type ProcessInfo struct {
	Name                 *string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Pid                  *uint64  `protobuf:"varint,2,opt,name=pid" json:"pid,omitempty"`
	ProcessName          *string  `protobuf:"bytes,3,opt,name=process_name,json=processName" json:"process_name,omitempty"`
	Cmdline              *string  `protobuf:"bytes,4,opt,name=cmdline" json:"cmdline,omitempty"`
	User                 *string  `protobuf:"bytes,5,opt,name=user" json:"user,omitempty"`
	StartTime            *uint32  `protobuf:"varint,6,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	NetnsId              *uint32  `protobuf:"varint,7,opt,name=netns_id,json=netnsId,def=0" json:"netns_id,omitempty"`
	ContainerId          *string  `protobuf:"bytes,8,opt,name=container_id,json=containerId,def=" json:"container_id,omitempty"`
	OsAppTags            []*Tag   `protobuf:"bytes,11,rep,name=os_app_tags,json=osAppTags" json:"os_app_tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessInfo) Descriptor 

func (*ProcessInfo) Descriptor() ([]byte, []int)

func (*ProcessInfo) GetCmdline 

func (m *ProcessInfo) GetCmdline() string

func (*ProcessInfo) GetContainerId 

func (m *ProcessInfo) GetContainerId() string

func (*ProcessInfo) GetName 

func (m *ProcessInfo) GetName() string

func (*ProcessInfo) GetNetnsId 

func (m *ProcessInfo) GetNetnsId() uint32

func (*ProcessInfo) GetOsAppTags 

func (m *ProcessInfo) GetOsAppTags() []*Tag

func (*ProcessInfo) GetPid 

func (m *ProcessInfo) GetPid() uint64

func (*ProcessInfo) GetProcessName 

func (m *ProcessInfo) GetProcessName() string

func (*ProcessInfo) GetStartTime 

func (m *ProcessInfo) GetStartTime() uint32

func (*ProcessInfo) GetUser 

func (m *ProcessInfo) GetUser() string

func (*ProcessInfo) Marshal 

func (m *ProcessInfo) Marshal() (dAtA []byte, err error)

func (*ProcessInfo) MarshalTo 

func (m *ProcessInfo) MarshalTo(dAtA []byte) (int, error)

func (*ProcessInfo) MarshalToSizedBuffer 

func (m *ProcessInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) Reset 

func (m *ProcessInfo) Reset()

func (*ProcessInfo) Size 

func (m *ProcessInfo) Size() (n int)

func (*ProcessInfo) String 

func (m *ProcessInfo) String() string

func (*ProcessInfo) Unmarshal 

func (m *ProcessInfo) Unmarshal(dAtA []byte) error

func (*ProcessInfo) XXX_DiscardUnknown 

func (m *ProcessInfo) XXX_DiscardUnknown()

func (*ProcessInfo) XXX_Marshal 

func (m *ProcessInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessInfo) XXX_Merge 

func (m *ProcessInfo) XXX_Merge(src proto.Message)

func (*ProcessInfo) XXX_Size 

func (m *ProcessInfo) XXX_Size() int

func (*ProcessInfo) XXX_Unmarshal 

func (m *ProcessInfo) XXX_Unmarshal(b []byte) error

type RVData 

type RVData struct {
	Entries              []*RipToVip `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RVData) Descriptor 

func (*RVData) Descriptor() ([]byte, []int)

func (*RVData) GetEntries 

func (m *RVData) GetEntries() []*RipToVip

func (*RVData) Marshal 

func (m *RVData) Marshal() (dAtA []byte, err error)

func (*RVData) MarshalTo 

func (m *RVData) MarshalTo(dAtA []byte) (int, error)

func (*RVData) MarshalToSizedBuffer 

func (m *RVData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RVData) ProtoMessage 

func (*RVData) ProtoMessage()

func (*RVData) Reset 

func (m *RVData) Reset()

func (*RVData) Size 

func (m *RVData) Size() (n int)

func (*RVData) String 

func (m *RVData) String() string

func (*RVData) Unmarshal 

func (m *RVData) Unmarshal(dAtA []byte) error

func (*RVData) XXX_DiscardUnknown 

func (m *RVData) XXX_DiscardUnknown()

func (*RVData) XXX_Marshal 

func (m *RVData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RVData) XXX_Merge 

func (m *RVData) XXX_Merge(src proto.Message)

func (*RVData) XXX_Size 

func (m *RVData) XXX_Size() int

func (*RVData) XXX_Unmarshal 

func (m *RVData) XXX_Unmarshal(b []byte) error

type RealClientToRealServer 

type RealClientToRealServer struct {
	EpcId_0              *uint32  `protobuf:"varint,1,opt,name=epc_id_0,json=epcId0,def=0" json:"epc_id_0,omitempty"`
	Ipv4_0               *uint32  `protobuf:"varint,2,opt,name=ipv4_0,json=ipv40,def=0" json:"ipv4_0,omitempty"`
	Port_0               *uint32  `protobuf:"varint,3,opt,name=port_0,json=port0,def=0" json:"port_0,omitempty"`
	EpcId_1              *uint32  `protobuf:"varint,4,opt,name=epc_id_1,json=epcId1,def=0" json:"epc_id_1,omitempty"`
	Ipv4_1               *uint32  `protobuf:"varint,5,opt,name=ipv4_1,json=ipv41,def=0" json:"ipv4_1,omitempty"`
	Port_1               *uint32  `protobuf:"varint,6,opt,name=port_1,json=port1,def=0" json:"port_1,omitempty"`
	EpcIdReal            *uint32  `protobuf:"varint,7,opt,name=epc_id_real,json=epcIdReal,def=0" json:"epc_id_real,omitempty"`
	Ipv4Real             *uint32  `protobuf:"varint,8,opt,name=ipv4_real,json=ipv4Real,def=0" json:"ipv4_real,omitempty"`
	PortReal             *uint32  `protobuf:"varint,9,opt,name=port_real,json=portReal,def=0" json:"port_real,omitempty"`
	PidReal              *uint32  `protobuf:"varint,10,opt,name=pid_real,json=pidReal,def=0" json:"pid_real,omitempty"`
	AgentIdReal          *uint32  `protobuf:"varint,11,opt,name=agent_id_real,json=agentIdReal,def=0" json:"agent_id_real,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RealClientToRealServer) Descriptor 

func (*RealClientToRealServer) Descriptor() ([]byte, []int)

func (*RealClientToRealServer) GetAgentIdReal 

func (m *RealClientToRealServer) GetAgentIdReal() uint32

func (*RealClientToRealServer) GetEpcIdReal 

func (m *RealClientToRealServer) GetEpcIdReal() uint32

func (*RealClientToRealServer) GetEpcId_0 

func (m *RealClientToRealServer) GetEpcId_0() uint32

func (*RealClientToRealServer) GetEpcId_1 

func (m *RealClientToRealServer) GetEpcId_1() uint32

func (*RealClientToRealServer) GetIpv4Real 

func (m *RealClientToRealServer) GetIpv4Real() uint32

func (*RealClientToRealServer) GetIpv4_0 

func (m *RealClientToRealServer) GetIpv4_0() uint32

func (*RealClientToRealServer) GetIpv4_1 

func (m *RealClientToRealServer) GetIpv4_1() uint32

func (*RealClientToRealServer) GetPidReal 

func (m *RealClientToRealServer) GetPidReal() uint32

func (*RealClientToRealServer) GetPortReal 

func (m *RealClientToRealServer) GetPortReal() uint32

func (*RealClientToRealServer) GetPort_0 

func (m *RealClientToRealServer) GetPort_0() uint32

func (*RealClientToRealServer) GetPort_1 

func (m *RealClientToRealServer) GetPort_1() uint32

func (*RealClientToRealServer) Marshal 

func (m *RealClientToRealServer) Marshal() (dAtA []byte, err error)

func (*RealClientToRealServer) MarshalTo 

func (m *RealClientToRealServer) MarshalTo(dAtA []byte) (int, error)

func (*RealClientToRealServer) MarshalToSizedBuffer 

func (m *RealClientToRealServer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RealClientToRealServer) ProtoMessage 

func (*RealClientToRealServer) ProtoMessage()

func (*RealClientToRealServer) Reset 

func (m *RealClientToRealServer) Reset()

func (*RealClientToRealServer) Size 

func (m *RealClientToRealServer) Size() (n int)

func (*RealClientToRealServer) String 

func (m *RealClientToRealServer) String() string

func (*RealClientToRealServer) Unmarshal 

func (m *RealClientToRealServer) Unmarshal(dAtA []byte) error

func (*RealClientToRealServer) XXX_DiscardUnknown 

func (m *RealClientToRealServer) XXX_DiscardUnknown()

func (*RealClientToRealServer) XXX_Marshal 

func (m *RealClientToRealServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RealClientToRealServer) XXX_Merge 

func (m *RealClientToRealServer) XXX_Merge(src proto.Message)

func (*RealClientToRealServer) XXX_Size 

func (m *RealClientToRealServer) XXX_Size() int

func (*RealClientToRealServer) XXX_Unmarshal 

func (m *RealClientToRealServer) XXX_Unmarshal(b []byte) error

type RealGlobalData 

type RealGlobalData struct {
	Entries              []*RealClientToRealServer `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*RealGlobalData) Descriptor 

func (*RealGlobalData) Descriptor() ([]byte, []int)

func (*RealGlobalData) GetEntries 

func (m *RealGlobalData) GetEntries() []*RealClientToRealServer

func (*RealGlobalData) Marshal 

func (m *RealGlobalData) Marshal() (dAtA []byte, err error)

func (*RealGlobalData) MarshalTo 

func (m *RealGlobalData) MarshalTo(dAtA []byte) (int, error)

func (*RealGlobalData) MarshalToSizedBuffer 

func (m *RealGlobalData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RealGlobalData) ProtoMessage 

func (*RealGlobalData) ProtoMessage()

func (*RealGlobalData) Reset 

func (m *RealGlobalData) Reset()

func (*RealGlobalData) Size 

func (m *RealGlobalData) Size() (n int)

func (*RealGlobalData) String 

func (m *RealGlobalData) String() string

func (*RealGlobalData) Unmarshal 

func (m *RealGlobalData) Unmarshal(dAtA []byte) error

func (*RealGlobalData) XXX_DiscardUnknown 

func (m *RealGlobalData) XXX_DiscardUnknown()

func (*RealGlobalData) XXX_Marshal 

func (m *RealGlobalData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RealGlobalData) XXX_Merge 

func (m *RealGlobalData) XXX_Merge(src proto.Message)

func (*RealGlobalData) XXX_Size 

func (m *RealGlobalData) XXX_Size() int

func (*RealGlobalData) XXX_Unmarshal 

func (m *RealGlobalData) XXX_Unmarshal(b []byte) error

type RemoteCommand 

type RemoteCommand struct {
	Cmd                  *string         `protobuf:"bytes,2,opt,name=cmd" json:"cmd,omitempty"`
	OutputFormat         *OutputFormat   `protobuf:"varint,4,opt,name=output_format,json=outputFormat,enum=agent.OutputFormat" json:"output_format,omitempty"`
	Ident                *string         `protobuf:"bytes,6,opt,name=ident" json:"ident,omitempty"`
	Params               []*CommandParam `protobuf:"bytes,7,rep,name=params" json:"params,omitempty"`
	TypeName             *string         `protobuf:"bytes,8,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	Id                   *uint32         `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	ParamNames           []string        `protobuf:"bytes,3,rep,name=param_names,json=paramNames" json:"param_names,omitempty"`
	CmdType              *CommandType    `protobuf:"varint,5,opt,name=cmd_type,json=cmdType,enum=agent.CommandType" json:"cmd_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RemoteCommand) Descriptor 

func (*RemoteCommand) Descriptor() ([]byte, []int)

func (*RemoteCommand) GetCmd 

func (m *RemoteCommand) GetCmd() string

func (*RemoteCommand) GetCmdType 

func (m *RemoteCommand) GetCmdType() CommandType

func (*RemoteCommand) GetId 

func (m *RemoteCommand) GetId() uint32

func (*RemoteCommand) GetIdent 

func (m *RemoteCommand) GetIdent() string

func (*RemoteCommand) GetOutputFormat 

func (m *RemoteCommand) GetOutputFormat() OutputFormat

func (*RemoteCommand) GetParamNames 

func (m *RemoteCommand) GetParamNames() []string

func (*RemoteCommand) GetParams 

func (m *RemoteCommand) GetParams() []*CommandParam

func (*RemoteCommand) GetTypeName 

func (m *RemoteCommand) GetTypeName() string

func (*RemoteCommand) Marshal 

func (m *RemoteCommand) Marshal() (dAtA []byte, err error)

func (*RemoteCommand) MarshalTo 

func (m *RemoteCommand) MarshalTo(dAtA []byte) (int, error)

func (*RemoteCommand) MarshalToSizedBuffer 

func (m *RemoteCommand) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteCommand) ProtoMessage 

func (*RemoteCommand) ProtoMessage()

func (*RemoteCommand) Reset 

func (m *RemoteCommand) Reset()

func (*RemoteCommand) Size 

func (m *RemoteCommand) Size() (n int)

func (*RemoteCommand) String 

func (m *RemoteCommand) String() string

func (*RemoteCommand) Unmarshal 

func (m *RemoteCommand) Unmarshal(dAtA []byte) error

func (*RemoteCommand) XXX_DiscardUnknown 

func (m *RemoteCommand) XXX_DiscardUnknown()

func (*RemoteCommand) XXX_Marshal 

func (m *RemoteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteCommand) XXX_Merge 

func (m *RemoteCommand) XXX_Merge(src proto.Message)

func (*RemoteCommand) XXX_Size 

func (m *RemoteCommand) XXX_Size() int

func (*RemoteCommand) XXX_Unmarshal 

func (m *RemoteCommand) XXX_Unmarshal(b []byte) error

type RemoteExecRequest 

type RemoteExecRequest struct {
	RequestId            *uint64        `protobuf:"varint,1,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	ExecType             *ExecutionType `protobuf:"varint,2,opt,name=exec_type,json=execType,enum=agent.ExecutionType" json:"exec_type,omitempty"`
	Params               []*Parameter   `protobuf:"bytes,4,rep,name=params" json:"params,omitempty"`
	LinuxNsPid           *uint32        `protobuf:"varint,5,opt,name=linux_ns_pid,json=linuxNsPid" json:"linux_ns_pid,omitempty"`
	BatchLen             *uint32        `protobuf:"varint,6,opt,name=batch_len,json=batchLen,def=1048576" json:"batch_len,omitempty"`
	CommandIdent         *string        `protobuf:"bytes,7,opt,name=command_ident,json=commandIdent" json:"command_ident,omitempty"`
	CommandData          *DataChunk     `protobuf:"bytes,10,opt,name=command_data,json=commandData" json:"command_data,omitempty"`
	CommandId            *uint32        `protobuf:"varint,3,opt,name=command_id,json=commandId" json:"command_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

message from server to agent

func (*RemoteExecRequest) Descriptor 

func (*RemoteExecRequest) Descriptor() ([]byte, []int)

func (*RemoteExecRequest) GetBatchLen 

func (m *RemoteExecRequest) GetBatchLen() uint32

func (*RemoteExecRequest) GetCommandData 

func (m *RemoteExecRequest) GetCommandData() *DataChunk

func (*RemoteExecRequest) GetCommandId 

func (m *RemoteExecRequest) GetCommandId() uint32

func (*RemoteExecRequest) GetCommandIdent 

func (m *RemoteExecRequest) GetCommandIdent() string

func (*RemoteExecRequest) GetExecType 

func (m *RemoteExecRequest) GetExecType() ExecutionType

func (*RemoteExecRequest) GetLinuxNsPid 

func (m *RemoteExecRequest) GetLinuxNsPid() uint32

func (*RemoteExecRequest) GetParams 

func (m *RemoteExecRequest) GetParams() []*Parameter

func (*RemoteExecRequest) GetRequestId 

func (m *RemoteExecRequest) GetRequestId() uint64

func (*RemoteExecRequest) Marshal 

func (m *RemoteExecRequest) Marshal() (dAtA []byte, err error)

func (*RemoteExecRequest) MarshalTo 

func (m *RemoteExecRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoteExecRequest) MarshalToSizedBuffer 

func (m *RemoteExecRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteExecRequest) ProtoMessage 

func (*RemoteExecRequest) ProtoMessage()

func (*RemoteExecRequest) Reset 

func (m *RemoteExecRequest) Reset()

func (*RemoteExecRequest) Size 

func (m *RemoteExecRequest) Size() (n int)

func (*RemoteExecRequest) String 

func (m *RemoteExecRequest) String() string

func (*RemoteExecRequest) Unmarshal 

func (m *RemoteExecRequest) Unmarshal(dAtA []byte) error

func (*RemoteExecRequest) XXX_DiscardUnknown 

func (m *RemoteExecRequest) XXX_DiscardUnknown()

func (*RemoteExecRequest) XXX_Marshal 

func (m *RemoteExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteExecRequest) XXX_Merge 

func (m *RemoteExecRequest) XXX_Merge(src proto.Message)

func (*RemoteExecRequest) XXX_Size 

func (m *RemoteExecRequest) XXX_Size() int

func (*RemoteExecRequest) XXX_Unmarshal 

func (m *RemoteExecRequest) XXX_Unmarshal(b []byte) error

type RemoteExecResponse 

type RemoteExecResponse struct {
	AgentId              *AgentId          `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	RequestId            *uint64           `protobuf:"varint,2,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	Errmsg               *string           `protobuf:"bytes,3,opt,name=errmsg" json:"errmsg,omitempty"`
	Commands             []*RemoteCommand  `protobuf:"bytes,4,rep,name=commands" json:"commands,omitempty"`
	LinuxNamespaces      []*LinuxNamespace `protobuf:"bytes,5,rep,name=linux_namespaces,json=linuxNamespaces" json:"linux_namespaces,omitempty"`
	CommandResult        *DataChunk        `protobuf:"bytes,6,opt,name=command_result,json=commandResult" json:"command_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

message from agent to server

func (*RemoteExecResponse) Descriptor 

func (*RemoteExecResponse) Descriptor() ([]byte, []int)

func (*RemoteExecResponse) GetAgentId 

func (m *RemoteExecResponse) GetAgentId() *AgentId

func (*RemoteExecResponse) GetCommandResult 

func (m *RemoteExecResponse) GetCommandResult() *DataChunk

func (*RemoteExecResponse) GetCommands 

func (m *RemoteExecResponse) GetCommands() []*RemoteCommand

func (*RemoteExecResponse) GetErrmsg 

func (m *RemoteExecResponse) GetErrmsg() string

func (*RemoteExecResponse) GetLinuxNamespaces 

func (m *RemoteExecResponse) GetLinuxNamespaces() []*LinuxNamespace

func (*RemoteExecResponse) GetRequestId 

func (m *RemoteExecResponse) GetRequestId() uint64

func (*RemoteExecResponse) Marshal 

func (m *RemoteExecResponse) Marshal() (dAtA []byte, err error)

func (*RemoteExecResponse) MarshalTo 

func (m *RemoteExecResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoteExecResponse) MarshalToSizedBuffer 

func (m *RemoteExecResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteExecResponse) ProtoMessage 

func (*RemoteExecResponse) ProtoMessage()

func (*RemoteExecResponse) Reset 

func (m *RemoteExecResponse) Reset()

func (*RemoteExecResponse) Size 

func (m *RemoteExecResponse) Size() (n int)

func (*RemoteExecResponse) String 

func (m *RemoteExecResponse) String() string

func (*RemoteExecResponse) Unmarshal 

func (m *RemoteExecResponse) Unmarshal(dAtA []byte) error

func (*RemoteExecResponse) XXX_DiscardUnknown 

func (m *RemoteExecResponse) XXX_DiscardUnknown()

func (*RemoteExecResponse) XXX_Marshal 

func (m *RemoteExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteExecResponse) XXX_Merge 

func (m *RemoteExecResponse) XXX_Merge(src proto.Message)

func (*RemoteExecResponse) XXX_Size 

func (m *RemoteExecResponse) XXX_Size() int

func (*RemoteExecResponse) XXX_Unmarshal 

func (m *RemoteExecResponse) XXX_Unmarshal(b []byte) error

type RipToVip 

type RipToVip struct {
	Protocol             *ServiceProtocol `protobuf:"varint,1,opt,name=protocol,enum=agent.ServiceProtocol,def=0" json:"protocol,omitempty"`
	EpcId                *uint32          `protobuf:"varint,2,opt,name=epc_id,json=epcId,def=0" json:"epc_id,omitempty"`
	RIpv4                *uint32          `protobuf:"varint,3,opt,name=r_ipv4,json=rIpv4,def=0" json:"r_ipv4,omitempty"`
	RPort                *uint32          `protobuf:"varint,4,opt,name=r_port,json=rPort,def=0" json:"r_port,omitempty"`
	VIpv4                *uint32          `protobuf:"varint,5,opt,name=v_ipv4,json=vIpv4,def=0" json:"v_ipv4,omitempty"`
	VPort                *uint32          `protobuf:"varint,6,opt,name=v_port,json=vPort,def=0" json:"v_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RipToVip) Descriptor 

func (*RipToVip) Descriptor() ([]byte, []int)

func (*RipToVip) GetEpcId 

func (m *RipToVip) GetEpcId() uint32

func (*RipToVip) GetProtocol 

func (m *RipToVip) GetProtocol() ServiceProtocol

func (*RipToVip) GetRIpv4 

func (m *RipToVip) GetRIpv4() uint32

func (*RipToVip) GetRPort 

func (m *RipToVip) GetRPort() uint32

func (*RipToVip) GetVIpv4 

func (m *RipToVip) GetVIpv4() uint32

func (*RipToVip) GetVPort 

func (m *RipToVip) GetVPort() uint32

func (*RipToVip) Marshal 

func (m *RipToVip) Marshal() (dAtA []byte, err error)

func (*RipToVip) MarshalTo 

func (m *RipToVip) MarshalTo(dAtA []byte) (int, error)

func (*RipToVip) MarshalToSizedBuffer 

func (m *RipToVip) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RipToVip) ProtoMessage 

func (*RipToVip) ProtoMessage()

func (*RipToVip) Reset 

func (m *RipToVip) Reset()

func (*RipToVip) Size 

func (m *RipToVip) Size() (n int)

func (*RipToVip) String 

func (m *RipToVip) String() string

func (*RipToVip) Unmarshal 

func (m *RipToVip) Unmarshal(dAtA []byte) error

func (*RipToVip) XXX_DiscardUnknown 

func (m *RipToVip) XXX_DiscardUnknown()

func (*RipToVip) XXX_Marshal 

func (m *RipToVip) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RipToVip) XXX_Merge 

func (m *RipToVip) XXX_Merge(src proto.Message)

func (*RipToVip) XXX_Size 

func (m *RipToVip) XXX_Size() int

func (*RipToVip) XXX_Unmarshal 

func (m *RipToVip) XXX_Unmarshal(b []byte) error

type RoleType 

type RoleType int32
const (
	RoleType_ROLE_NONE   RoleType = 0
	RoleType_ROLE_CLIENT RoleType = 1
	RoleType_ROLE_SERVER RoleType = 2
)
const Default_GPIDSyncEntry_RoleReal RoleType = RoleType_ROLE_NONE

func (RoleType) Enum 

func (x RoleType) Enum() *RoleType

func (RoleType) EnumDescriptor 

func (RoleType) EnumDescriptor() ([]byte, []int)

func (RoleType) String 

func (x RoleType) String() string

func (*RoleType) UnmarshalJSON 

func (x *RoleType) UnmarshalJSON(data []byte) error

type Segment 

type Segment struct {
	Id                   *uint32  `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Mac                  []string `protobuf:"bytes,2,rep,name=mac" json:"mac,omitempty"`
	InterfaceId          []uint32 `protobuf:"varint,3,rep,name=interface_id,json=interfaceId" json:"interface_id,omitempty"`
	Vmac                 []string `protobuf:"bytes,4,rep,name=vmac" json:"vmac,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Segment) Descriptor 

func (*Segment) Descriptor() ([]byte, []int)

func (*Segment) GetId 

func (m *Segment) GetId() uint32

func (*Segment) GetInterfaceId 

func (m *Segment) GetInterfaceId() []uint32

func (*Segment) GetMac 

func (m *Segment) GetMac() []string

func (*Segment) GetVmac 

func (m *Segment) GetVmac() []string

func (*Segment) Marshal 

func (m *Segment) Marshal() (dAtA []byte, err error)

func (*Segment) MarshalTo 

func (m *Segment) MarshalTo(dAtA []byte) (int, error)

func (*Segment) MarshalToSizedBuffer 

func (m *Segment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Segment) ProtoMessage 

func (*Segment) ProtoMessage()

func (*Segment) Reset 

func (m *Segment) Reset()

func (*Segment) Size 

func (m *Segment) Size() (n int)

func (*Segment) String 

func (m *Segment) String() string

func (*Segment) Unmarshal 

func (m *Segment) Unmarshal(dAtA []byte) error

func (*Segment) XXX_DiscardUnknown 

func (m *Segment) XXX_DiscardUnknown()

func (*Segment) XXX_Marshal 

func (m *Segment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Segment) XXX_Merge 

func (m *Segment) XXX_Merge(src proto.Message)

func (*Segment) XXX_Size 

func (m *Segment) XXX_Size() int

func (*Segment) XXX_Unmarshal 

func (m *Segment) XXX_Unmarshal(b []byte) error

type ServiceProtocol 

type ServiceProtocol int32
const (
	ServiceProtocol_ANY         ServiceProtocol = 0
	ServiceProtocol_TCP_SERVICE ServiceProtocol = 1
	ServiceProtocol_UDP_SERVICE ServiceProtocol = 2
)
const Default_GPIDSyncEntry_Protocol ServiceProtocol = ServiceProtocol_ANY
const Default_GlobalGPIDEntry_Protocol ServiceProtocol = ServiceProtocol_ANY
const Default_RipToVip_Protocol ServiceProtocol = ServiceProtocol_ANY

func (ServiceProtocol) Enum 

func (x ServiceProtocol) Enum() *ServiceProtocol

func (ServiceProtocol) EnumDescriptor 

func (ServiceProtocol) EnumDescriptor() ([]byte, []int)

func (ServiceProtocol) String 

func (x ServiceProtocol) String() string

func (*ServiceProtocol) UnmarshalJSON 

func (x *ServiceProtocol) UnmarshalJSON(data []byte) error

type ShareGPIDSyncRequests 

type ShareGPIDSyncRequests struct {
	ServerIp             *string            `protobuf:"bytes,1,opt,name=server_ip,json=serverIp" json:"server_ip,omitempty"`
	SyncRequests         []*GPIDSyncRequest `protobuf:"bytes,2,rep,name=sync_requests,json=syncRequests" json:"sync_requests,omitempty"`
	OrgId                *uint32            `protobuf:"varint,3,opt,name=org_id,json=orgId" json:"org_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ShareGPIDSyncRequests) Descriptor 

func (*ShareGPIDSyncRequests) Descriptor() ([]byte, []int)

func (*ShareGPIDSyncRequests) GetOrgId 

func (m *ShareGPIDSyncRequests) GetOrgId() uint32

func (*ShareGPIDSyncRequests) GetServerIp 

func (m *ShareGPIDSyncRequests) GetServerIp() string

func (*ShareGPIDSyncRequests) GetSyncRequests 

func (m *ShareGPIDSyncRequests) GetSyncRequests() []*GPIDSyncRequest

func (*ShareGPIDSyncRequests) Marshal 

func (m *ShareGPIDSyncRequests) Marshal() (dAtA []byte, err error)

func (*ShareGPIDSyncRequests) MarshalTo 

func (m *ShareGPIDSyncRequests) MarshalTo(dAtA []byte) (int, error)

func (*ShareGPIDSyncRequests) MarshalToSizedBuffer 

func (m *ShareGPIDSyncRequests) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShareGPIDSyncRequests) ProtoMessage 

func (*ShareGPIDSyncRequests) ProtoMessage()

func (*ShareGPIDSyncRequests) Reset 

func (m *ShareGPIDSyncRequests) Reset()

func (*ShareGPIDSyncRequests) Size 

func (m *ShareGPIDSyncRequests) Size() (n int)

func (*ShareGPIDSyncRequests) String 

func (m *ShareGPIDSyncRequests) String() string

func (*ShareGPIDSyncRequests) Unmarshal 

func (m *ShareGPIDSyncRequests) Unmarshal(dAtA []byte) error

func (*ShareGPIDSyncRequests) XXX_DiscardUnknown 

func (m *ShareGPIDSyncRequests) XXX_DiscardUnknown()

func (*ShareGPIDSyncRequests) XXX_Marshal 

func (m *ShareGPIDSyncRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShareGPIDSyncRequests) XXX_Merge 

func (m *ShareGPIDSyncRequests) XXX_Merge(src proto.Message)

func (*ShareGPIDSyncRequests) XXX_Size 

func (m *ShareGPIDSyncRequests) XXX_Size() int

func (*ShareGPIDSyncRequests) XXX_Unmarshal 

func (m *ShareGPIDSyncRequests) XXX_Unmarshal(b []byte) error

type SkipInterface 

type SkipInterface struct {
	// 若该接口对应的虚拟机内已经部署 agent,
	// 发送此接口给虚拟机所在宿主机 agent
	Mac                  *uint64  `protobuf:"varint,1,opt,name=mac" json:"mac,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SkipInterface) Descriptor 

func (*SkipInterface) Descriptor() ([]byte, []int)

func (*SkipInterface) GetMac 

func (m *SkipInterface) GetMac() uint64

func (*SkipInterface) Marshal 

func (m *SkipInterface) Marshal() (dAtA []byte, err error)

func (*SkipInterface) MarshalTo 

func (m *SkipInterface) MarshalTo(dAtA []byte) (int, error)

func (*SkipInterface) MarshalToSizedBuffer 

func (m *SkipInterface) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SkipInterface) ProtoMessage 

func (*SkipInterface) ProtoMessage()

func (*SkipInterface) Reset 

func (m *SkipInterface) Reset()

func (*SkipInterface) Size 

func (m *SkipInterface) Size() (n int)

func (*SkipInterface) String 

func (m *SkipInterface) String() string

func (*SkipInterface) Unmarshal 

func (m *SkipInterface) Unmarshal(dAtA []byte) error

func (*SkipInterface) XXX_DiscardUnknown 

func (m *SkipInterface) XXX_DiscardUnknown()

func (*SkipInterface) XXX_Marshal 

func (m *SkipInterface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SkipInterface) XXX_Merge 

func (m *SkipInterface) XXX_Merge(src proto.Message)

func (*SkipInterface) XXX_Size 

func (m *SkipInterface) XXX_Size() int

func (*SkipInterface) XXX_Unmarshal 

func (m *SkipInterface) XXX_Unmarshal(b []byte) error

type SocketType 

type SocketType int32
const (
	SocketType_RAW_UDP SocketType = 0
	SocketType_TCP     SocketType = 1
	SocketType_UDP     SocketType = 2
	SocketType_FILE    SocketType = 3
	SocketType_ZMQ     SocketType = 4
)

func (SocketType) Enum 

func (x SocketType) Enum() *SocketType

func (SocketType) EnumDescriptor 

func (SocketType) EnumDescriptor() ([]byte, []int)

func (SocketType) String 

func (x SocketType) String() string

func (*SocketType) UnmarshalJSON 

func (x *SocketType) UnmarshalJSON(data []byte) error

type State 

type State int32
const (
	State_ENVIRONMENT_CHECK State = 0
	State_DISABLED          State = 1
	State_RUNNING           State = 2
	State_REBOOTING         State = 3
	State_STRESSED          State = 4
	State_RESTRICTED        State = 5
)

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor 

func (State) EnumDescriptor() ([]byte, []int)

func (State) String 

func (x State) String() string

func (*State) UnmarshalJSON 

func (x *State) UnmarshalJSON(data []byte) error

type Status 

type Status int32
const (
	Status_SUCCESS              Status = 0
	Status_FAILED               Status = 1
	Status_HEARTBEAT            Status = 2
	Status_CLUSTER_ID_NOT_FOUND Status = 10
)

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor 

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String 

func (x Status) String() string

func (*Status) UnmarshalJSON 

func (x *Status) UnmarshalJSON(data []byte) error

type SyncRequest 

type SyncRequest struct {
	BootTime              *uint32            `protobuf:"varint,1,opt,name=boot_time,json=bootTime" json:"boot_time,omitempty"`
	ConfigAccepted        *bool              `protobuf:"varint,2,opt,name=config_accepted,json=configAccepted,def=1" json:"config_accepted,omitempty"`
	State                 *State             `protobuf:"varint,4,opt,name=state,enum=agent.State" json:"state,omitempty"`
	Revision              *string            `protobuf:"bytes,5,opt,name=revision" json:"revision,omitempty"`
	Exception             *uint64            `protobuf:"varint,6,opt,name=exception,def=0" json:"exception,omitempty"`
	ProcessName           *string            `protobuf:"bytes,7,opt,name=process_name,json=processName" json:"process_name,omitempty"`
	PacketCaptureType     *PacketCaptureType `` /* 143-byte string literal not displayed */
	VersionPlatformData   *uint64            `protobuf:"varint,9,opt,name=version_platform_data,json=versionPlatformData,def=0" json:"version_platform_data,omitempty"`
	VersionAcls           *uint64            `protobuf:"varint,10,opt,name=version_acls,json=versionAcls,def=0" json:"version_acls,omitempty"`
	VersionGroups         *uint64            `protobuf:"varint,11,opt,name=version_groups,json=versionGroups,def=0" json:"version_groups,omitempty"`
	CurrentK8SImage       *string            `protobuf:"bytes,12,opt,name=current_k8s_image,json=currentK8sImage" json:"current_k8s_image,omitempty"`
	CustomAppConfig       *CustomAppConfig   `protobuf:"bytes,13,opt,name=custom_app_config,json=customAppConfig" json:"custom_app_config,omitempty"`
	CtrlIp                *string            `protobuf:"bytes,21,opt,name=ctrl_ip,json=ctrlIp" json:"ctrl_ip,omitempty"`
	Host                  *string            `protobuf:"bytes,22,opt,name=host" json:"host,omitempty"`
	HostIps               []string           `protobuf:"bytes,23,rep,name=host_ips,json=hostIps" json:"host_ips,omitempty"`
	CtrlMac               *string            `protobuf:"bytes,25,opt,name=ctrl_mac,json=ctrlMac" json:"ctrl_mac,omitempty"`
	AgentGroupIdRequest   *string            `protobuf:"bytes,26,opt,name=agent_group_id_request,json=agentGroupIdRequest" json:"agent_group_id_request,omitempty"`
	KubernetesForceWatch  *bool              `protobuf:"varint,27,opt,name=kubernetes_force_watch,json=kubernetesForceWatch,def=0" json:"kubernetes_force_watch,omitempty"`
	AgentUniqueIdentifier *AgentIdentifier   `` /* 154-byte string literal not displayed */
	TeamId                *string            `protobuf:"bytes,29,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	// 运行环境基本信息
	CpuNum                *uint32                `protobuf:"varint,32,opt,name=cpu_num,json=cpuNum" json:"cpu_num,omitempty"`
	MemorySize            *uint64                `protobuf:"varint,33,opt,name=memory_size,json=memorySize" json:"memory_size,omitempty"`
	Arch                  *string                `protobuf:"bytes,34,opt,name=arch" json:"arch,omitempty"`
	Os                    *string                `protobuf:"bytes,35,opt,name=os" json:"os,omitempty"`
	KernelVersion         *string                `protobuf:"bytes,36,opt,name=kernel_version,json=kernelVersion" json:"kernel_version,omitempty"`
	KubernetesWatchPolicy *KubernetesWatchPolicy `` /* 154-byte string literal not displayed */
	KubernetesClusterId   *string                `protobuf:"bytes,45,opt,name=kubernetes_cluster_id,json=kubernetesClusterId" json:"kubernetes_cluster_id,omitempty"`
	KubernetesClusterName *string                `protobuf:"bytes,46,opt,name=kubernetes_cluster_name,json=kubernetesClusterName" json:"kubernetes_cluster_name,omitempty"`
	KubernetesClusterMd5  *string                `protobuf:"bytes,47,opt,name=kubernetes_cluster_md5,json=kubernetesClusterMd5" json:"kubernetes_cluster_md5,omitempty"`
	CurrentGrpcBufferSize *uint64                `protobuf:"varint,50,opt,name=current_grpc_buffer_size,json=currentGrpcBufferSize" json:"current_grpc_buffer_size,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}               `json:"-"`
	XXX_unrecognized      []byte                 `json:"-"`
	XXX_sizecache         int32                  `json:"-"`
}

func (*SyncRequest) Descriptor 

func (*SyncRequest) Descriptor() ([]byte, []int)

func (*SyncRequest) GetAgentGroupIdRequest 

func (m *SyncRequest) GetAgentGroupIdRequest() string

func (*SyncRequest) GetAgentUniqueIdentifier 

func (m *SyncRequest) GetAgentUniqueIdentifier() AgentIdentifier

func (*SyncRequest) GetArch 

func (m *SyncRequest) GetArch() string

func (*SyncRequest) GetBootTime 

func (m *SyncRequest) GetBootTime() uint32

func (*SyncRequest) GetConfigAccepted 

func (m *SyncRequest) GetConfigAccepted() bool

func (*SyncRequest) GetCpuNum 

func (m *SyncRequest) GetCpuNum() uint32

func (*SyncRequest) GetCtrlIp 

func (m *SyncRequest) GetCtrlIp() string

func (*SyncRequest) GetCtrlMac 

func (m *SyncRequest) GetCtrlMac() string

func (*SyncRequest) GetCurrentGrpcBufferSize 

func (m *SyncRequest) GetCurrentGrpcBufferSize() uint64

func (*SyncRequest) GetCurrentK8SImage 

func (m *SyncRequest) GetCurrentK8SImage() string

func (*SyncRequest) GetCustomAppConfig 

func (m *SyncRequest) GetCustomAppConfig() *CustomAppConfig

func (*SyncRequest) GetException 

func (m *SyncRequest) GetException() uint64

func (*SyncRequest) GetHost 

func (m *SyncRequest) GetHost() string

func (*SyncRequest) GetHostIps 

func (m *SyncRequest) GetHostIps() []string

func (*SyncRequest) GetKernelVersion 

func (m *SyncRequest) GetKernelVersion() string

func (*SyncRequest) GetKubernetesClusterId 

func (m *SyncRequest) GetKubernetesClusterId() string

func (*SyncRequest) GetKubernetesClusterMd5 

func (m *SyncRequest) GetKubernetesClusterMd5() string

func (*SyncRequest) GetKubernetesClusterName 

func (m *SyncRequest) GetKubernetesClusterName() string

func (*SyncRequest) GetKubernetesForceWatch 

func (m *SyncRequest) GetKubernetesForceWatch() bool

func (*SyncRequest) GetKubernetesWatchPolicy 

func (m *SyncRequest) GetKubernetesWatchPolicy() KubernetesWatchPolicy

func (*SyncRequest) GetMemorySize 

func (m *SyncRequest) GetMemorySize() uint64

func (*SyncRequest) GetOs 

func (m *SyncRequest) GetOs() string

func (*SyncRequest) GetPacketCaptureType 

func (m *SyncRequest) GetPacketCaptureType() PacketCaptureType

func (*SyncRequest) GetProcessName 

func (m *SyncRequest) GetProcessName() string

func (*SyncRequest) GetRevision 

func (m *SyncRequest) GetRevision() string

func (*SyncRequest) GetState 

func (m *SyncRequest) GetState() State

func (*SyncRequest) GetTeamId 

func (m *SyncRequest) GetTeamId() string

func (*SyncRequest) GetVersionAcls 

func (m *SyncRequest) GetVersionAcls() uint64

func (*SyncRequest) GetVersionGroups 

func (m *SyncRequest) GetVersionGroups() uint64

func (*SyncRequest) GetVersionPlatformData 

func (m *SyncRequest) GetVersionPlatformData() uint64

func (*SyncRequest) Marshal 

func (m *SyncRequest) Marshal() (dAtA []byte, err error)

func (*SyncRequest) MarshalTo 

func (m *SyncRequest) MarshalTo(dAtA []byte) (int, error)

func (*SyncRequest) MarshalToSizedBuffer 

func (m *SyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) Reset 

func (m *SyncRequest) Reset()

func (*SyncRequest) Size 

func (m *SyncRequest) Size() (n int)

func (*SyncRequest) String 

func (m *SyncRequest) String() string

func (*SyncRequest) Unmarshal 

func (m *SyncRequest) Unmarshal(dAtA []byte) error

func (*SyncRequest) XXX_DiscardUnknown 

func (m *SyncRequest) XXX_DiscardUnknown()

func (*SyncRequest) XXX_Marshal 

func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncRequest) XXX_Merge 

func (m *SyncRequest) XXX_Merge(src proto.Message)

func (*SyncRequest) XXX_Size 

func (m *SyncRequest) XXX_Size() int

func (*SyncRequest) XXX_Unmarshal 

func (m *SyncRequest) XXX_Unmarshal(b []byte) error

type SyncResponse 

type SyncResponse struct {
	Status              *Status `protobuf:"varint,1,opt,name=status,enum=agent.Status" json:"status,omitempty"`
	UserConfig          *string `protobuf:"bytes,2,opt,name=user_config,json=userConfig" json:"user_config,omitempty"`
	Revision            *string `protobuf:"bytes,3,opt,name=revision" json:"revision,omitempty"`
	SelfUpdateUrl       *string `protobuf:"bytes,4,opt,name=self_update_url,json=selfUpdateUrl" json:"self_update_url,omitempty"`
	VersionPlatformData *uint64 `protobuf:"varint,5,opt,name=version_platform_data,json=versionPlatformData,def=0" json:"version_platform_data,omitempty"`
	VersionAcls         *uint64 `protobuf:"varint,6,opt,name=version_acls,json=versionAcls,def=0" json:"version_acls,omitempty"`
	VersionGroups       *uint64 `protobuf:"varint,7,opt,name=version_groups,json=versionGroups,def=0" json:"version_groups,omitempty"`
	// The controller sends a container list to each agent, which contains a list of
	// containers in the operating system that the agent is running on (Note that only
	// the local container will be issued, not other machines)
	// =================================================================================
	// 控制器向每个 Agent 下发一个 container list，其内容为该 Agent 运行操作
	// 系统中的 container 列表（注意仅会下发本机的 container，不会包含其他机器的）
	Containers          []*Container          `protobuf:"bytes,8,rep,name=containers" json:"containers,omitempty"`
	LocalSegments       []*Segment            `protobuf:"bytes,9,rep,name=local_segments,json=localSegments" json:"local_segments,omitempty"`
	RemoteSegments      []*Segment            `protobuf:"bytes,10,rep,name=remote_segments,json=remoteSegments" json:"remote_segments,omitempty"`
	PlatformData        []byte                `protobuf:"bytes,11,opt,name=platform_data,json=platformData" json:"platform_data,omitempty"`
	FlowAcls            []byte                `protobuf:"bytes,12,opt,name=flow_acls,json=flowAcls" json:"flow_acls,omitempty"`
	Groups              []byte                `protobuf:"bytes,13,opt,name=groups" json:"groups,omitempty"`
	CaptureNetworkTypes []*CaptureNetworkType `protobuf:"bytes,14,rep,name=capture_network_types,json=captureNetworkTypes" json:"capture_network_types,omitempty"`
	SkipInterface       []*SkipInterface      `protobuf:"bytes,15,rep,name=skip_interface,json=skipInterface" json:"skip_interface,omitempty"`
	DynamicConfig       *DynamicConfig        `protobuf:"bytes,20,opt,name=dynamic_config,json=dynamicConfig" json:"dynamic_config,omitempty"`
	CustomAppConfig     *CustomAppConfig      `protobuf:"bytes,21,opt,name=custom_app_config,json=customAppConfig" json:"custom_app_config,omitempty"`
	// When the controller determines that the agent needs to adjust `current_grpc_buffer_size`,
	// this value is set to true. At this time, only the following fields in the message are valid:
	// - status
	// - user_config
	// - revision
	// - self_update_url
	// - containers
	// - dynamic_config
	// - only_partial_fields
	// - new_grpc_buffer_size
	OnlyPartialFields    *bool    `protobuf:"varint,30,opt,name=only_partial_fields,json=onlyPartialFields,def=0" json:"only_partial_fields,omitempty"`
	NewGrpcBufferSize    *uint64  `protobuf:"varint,31,opt,name=new_grpc_buffer_size,json=newGrpcBufferSize" json:"new_grpc_buffer_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncResponse) Descriptor 

func (*SyncResponse) Descriptor() ([]byte, []int)

func (*SyncResponse) GetCaptureNetworkTypes 

func (m *SyncResponse) GetCaptureNetworkTypes() []*CaptureNetworkType

func (*SyncResponse) GetContainers 

func (m *SyncResponse) GetContainers() []*Container

func (*SyncResponse) GetCustomAppConfig 

func (m *SyncResponse) GetCustomAppConfig() *CustomAppConfig

func (*SyncResponse) GetDynamicConfig 

func (m *SyncResponse) GetDynamicConfig() *DynamicConfig

func (*SyncResponse) GetFlowAcls 

func (m *SyncResponse) GetFlowAcls() []byte

func (*SyncResponse) GetGroups 

func (m *SyncResponse) GetGroups() []byte

func (*SyncResponse) GetLocalSegments 

func (m *SyncResponse) GetLocalSegments() []*Segment

func (*SyncResponse) GetNewGrpcBufferSize 

func (m *SyncResponse) GetNewGrpcBufferSize() uint64

func (*SyncResponse) GetOnlyPartialFields 

func (m *SyncResponse) GetOnlyPartialFields() bool

func (*SyncResponse) GetPlatformData 

func (m *SyncResponse) GetPlatformData() []byte

func (*SyncResponse) GetRemoteSegments 

func (m *SyncResponse) GetRemoteSegments() []*Segment

func (*SyncResponse) GetRevision 

func (m *SyncResponse) GetRevision() string

func (*SyncResponse) GetSelfUpdateUrl 

func (m *SyncResponse) GetSelfUpdateUrl() string

func (*SyncResponse) GetSkipInterface 

func (m *SyncResponse) GetSkipInterface() []*SkipInterface

func (*SyncResponse) GetStatus 

func (m *SyncResponse) GetStatus() Status

func (*SyncResponse) GetUserConfig 

func (m *SyncResponse) GetUserConfig() string

func (*SyncResponse) GetVersionAcls 

func (m *SyncResponse) GetVersionAcls() uint64

func (*SyncResponse) GetVersionGroups 

func (m *SyncResponse) GetVersionGroups() uint64

func (*SyncResponse) GetVersionPlatformData 

func (m *SyncResponse) GetVersionPlatformData() uint64

func (*SyncResponse) Marshal 

func (m *SyncResponse) Marshal() (dAtA []byte, err error)

func (*SyncResponse) MarshalTo 

func (m *SyncResponse) MarshalTo(dAtA []byte) (int, error)

func (*SyncResponse) MarshalToSizedBuffer 

func (m *SyncResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) Reset 

func (m *SyncResponse) Reset()

func (*SyncResponse) Size 

func (m *SyncResponse) Size() (n int)

func (*SyncResponse) String 

func (m *SyncResponse) String() string

func (*SyncResponse) Unmarshal 

func (m *SyncResponse) Unmarshal(dAtA []byte) error

func (*SyncResponse) XXX_DiscardUnknown 

func (m *SyncResponse) XXX_DiscardUnknown()

func (*SyncResponse) XXX_Marshal 

func (m *SyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncResponse) XXX_Merge 

func (m *SyncResponse) XXX_Merge(src proto.Message)

func (*SyncResponse) XXX_Size 

func (m *SyncResponse) XXX_Size() int

func (*SyncResponse) XXX_Unmarshal 

func (m *SyncResponse) XXX_Unmarshal(b []byte) error

type SynchronizerClient 

type SynchronizerClient interface {
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	Push(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Synchronizer_PushClient, error)
	Upgrade(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (Synchronizer_UpgradeClient, error)
	Query(ctx context.Context, in *NtpRequest, opts ...grpc.CallOption) (*NtpResponse, error)
	GenesisSync(ctx context.Context, in *GenesisSyncRequest, opts ...grpc.CallOption) (*GenesisSyncResponse, error)
	KubernetesAPISync(ctx context.Context, in *KubernetesAPISyncRequest, opts ...grpc.CallOption) (*KubernetesAPISyncResponse, error)
	GetKubernetesClusterID(ctx context.Context, in *KubernetesClusterIDRequest, opts ...grpc.CallOption) (*KubernetesClusterIDResponse, error)
	GPIDSync(ctx context.Context, in *GPIDSyncRequest, opts ...grpc.CallOption) (*GPIDSyncResponse, error)
	ShareGPIDLocalData(ctx context.Context, in *ShareGPIDSyncRequests, opts ...grpc.CallOption) (*ShareGPIDSyncRequests, error)
	Plugin(ctx context.Context, in *PluginRequest, opts ...grpc.CallOption) (Synchronizer_PluginClient, error)
	// because gRPC cannot be initiated by server, the req/resp of this rpc is reversed
	RemoteExecute(ctx context.Context, opts ...grpc.CallOption) (Synchronizer_RemoteExecuteClient, error)
}

SynchronizerClient is the client API for Synchronizer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSynchronizerClient 

func NewSynchronizerClient(cc *grpc.ClientConn) SynchronizerClient

type SynchronizerServer 

type SynchronizerServer interface {
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	Push(*SyncRequest, Synchronizer_PushServer) error
	Upgrade(*UpgradeRequest, Synchronizer_UpgradeServer) error
	Query(context.Context, *NtpRequest) (*NtpResponse, error)
	GenesisSync(context.Context, *GenesisSyncRequest) (*GenesisSyncResponse, error)
	KubernetesAPISync(context.Context, *KubernetesAPISyncRequest) (*KubernetesAPISyncResponse, error)
	GetKubernetesClusterID(context.Context, *KubernetesClusterIDRequest) (*KubernetesClusterIDResponse, error)
	GPIDSync(context.Context, *GPIDSyncRequest) (*GPIDSyncResponse, error)
	ShareGPIDLocalData(context.Context, *ShareGPIDSyncRequests) (*ShareGPIDSyncRequests, error)
	Plugin(*PluginRequest, Synchronizer_PluginServer) error
	// because gRPC cannot be initiated by server, the req/resp of this rpc is reversed
	RemoteExecute(Synchronizer_RemoteExecuteServer) error
}

SynchronizerServer is the server API for Synchronizer service.

type Synchronizer_PluginClient 

type Synchronizer_PluginClient interface {
	Recv() (*PluginResponse, error)
	grpc.ClientStream
}

type Synchronizer_PluginServer 

type Synchronizer_PluginServer interface {
	Send(*PluginResponse) error
	grpc.ServerStream
}

type Synchronizer_PushClient 

type Synchronizer_PushClient interface {
	Recv() (*SyncResponse, error)
	grpc.ClientStream
}

type Synchronizer_PushServer 

type Synchronizer_PushServer interface {
	Send(*SyncResponse) error
	grpc.ServerStream
}

type Synchronizer_RemoteExecuteClient 

type Synchronizer_RemoteExecuteClient interface {
	Send(*RemoteExecResponse) error
	Recv() (*RemoteExecRequest, error)
	grpc.ClientStream
}

type Synchronizer_RemoteExecuteServer 

type Synchronizer_RemoteExecuteServer interface {
	Send(*RemoteExecRequest) error
	Recv() (*RemoteExecResponse, error)
	grpc.ServerStream
}

type Synchronizer_UpgradeClient 

type Synchronizer_UpgradeClient interface {
	Recv() (*UpgradeResponse, error)
	grpc.ClientStream
}

type Synchronizer_UpgradeServer 

type Synchronizer_UpgradeServer interface {
	Send(*UpgradeResponse) error
	grpc.ServerStream
}

type SysMemoryMetric 

type SysMemoryMetric int32
const (
	SysMemoryMetric_Free      SysMemoryMetric = 0
	SysMemoryMetric_Available SysMemoryMetric = 1
)

func (SysMemoryMetric) Enum 

func (x SysMemoryMetric) Enum() *SysMemoryMetric

func (SysMemoryMetric) EnumDescriptor 

func (SysMemoryMetric) EnumDescriptor() ([]byte, []int)

func (SysMemoryMetric) String 

func (x SysMemoryMetric) String() string

func (*SysMemoryMetric) UnmarshalJSON 

func (x *SysMemoryMetric) UnmarshalJSON(data []byte) error

type SystemLoadMetric 

type SystemLoadMetric int32
const (
	SystemLoadMetric_Load1  SystemLoadMetric = 0
	SystemLoadMetric_Load5  SystemLoadMetric = 1
	SystemLoadMetric_Load15 SystemLoadMetric = 2
)

func (SystemLoadMetric) Enum 

func (x SystemLoadMetric) Enum() *SystemLoadMetric

func (SystemLoadMetric) EnumDescriptor 

func (SystemLoadMetric) EnumDescriptor() ([]byte, []int)

func (SystemLoadMetric) String 

func (x SystemLoadMetric) String() string

func (*SystemLoadMetric) UnmarshalJSON 

func (x *SystemLoadMetric) UnmarshalJSON(data []byte) error

type Tag 

type Tag struct {
	Key                  *string  `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value                *string  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Tag) Descriptor 

func (*Tag) Descriptor() ([]byte, []int)

func (*Tag) GetKey 

func (m *Tag) GetKey() string

func (*Tag) GetValue 

func (m *Tag) GetValue() string

func (*Tag) Marshal 

func (m *Tag) Marshal() (dAtA []byte, err error)

func (*Tag) MarshalTo 

func (m *Tag) MarshalTo(dAtA []byte) (int, error)

func (*Tag) MarshalToSizedBuffer 

func (m *Tag) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) Size 

func (m *Tag) Size() (n int)

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) Unmarshal 

func (m *Tag) Unmarshal(dAtA []byte) error

func (*Tag) XXX_DiscardUnknown 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal 

func (m *Tag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tag) XXX_Merge 

func (m *Tag) XXX_Merge(src proto.Message)

func (*Tag) XXX_Size 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal 

func (m *Tag) XXX_Unmarshal(b []byte) error

type TunnelType 

type TunnelType int32
const (
	TunnelType_VXLAN      TunnelType = 0
	TunnelType_GRE_ERSPAN TunnelType = 1
	TunnelType_PCAP       TunnelType = 2
	TunnelType_NPB_DROP   TunnelType = 3
)
const Default_NpbAction_TunnelType TunnelType = TunnelType_VXLAN

func (TunnelType) Enum 

func (x TunnelType) Enum() *TunnelType

func (TunnelType) EnumDescriptor 

func (TunnelType) EnumDescriptor() ([]byte, []int)

func (TunnelType) String 

func (x TunnelType) String() string

func (*TunnelType) UnmarshalJSON 

func (x *TunnelType) UnmarshalJSON(data []byte) error

type UnimplementedDebugServer 

type UnimplementedDebugServer struct {
}

UnimplementedDebugServer can be embedded to have forward compatible implementations.

func (*UnimplementedDebugServer) DebugAgentCache 

func (*UnimplementedDebugServer) DebugAgentCache(ctx context.Context, req *AgentCacheRequest) (*AgentCacheResponse, error)

func (*UnimplementedDebugServer) DebugGPIDAgentData 

func (*UnimplementedDebugServer) DebugGPIDAgentData(ctx context.Context, req *GPIDSyncRequest) (*GPIDAgentData, error)

func (*UnimplementedDebugServer) DebugGPIDGlobalData 

func (*UnimplementedDebugServer) DebugGPIDGlobalData(ctx context.Context, req *GPIDSyncRequest) (*GPIDGlobalData, error)

func (*UnimplementedDebugServer) DebugRIPToVIP 

func (*UnimplementedDebugServer) DebugRIPToVIP(ctx context.Context, req *GPIDSyncRequest) (*RVData, error)

func (*UnimplementedDebugServer) DebugRealGlobalData 

func (*UnimplementedDebugServer) DebugRealGlobalData(ctx context.Context, req *GPIDSyncRequest) (*RealGlobalData, error)

type UnimplementedSynchronizerServer 

type UnimplementedSynchronizerServer struct {
}

UnimplementedSynchronizerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSynchronizerServer) GPIDSync 

func (*UnimplementedSynchronizerServer) GPIDSync(ctx context.Context, req *GPIDSyncRequest) (*GPIDSyncResponse, error)

func (*UnimplementedSynchronizerServer) GenesisSync 

func (*UnimplementedSynchronizerServer) GenesisSync(ctx context.Context, req *GenesisSyncRequest) (*GenesisSyncResponse, error)

func (*UnimplementedSynchronizerServer) GetKubernetesClusterID 

func (*UnimplementedSynchronizerServer) GetKubernetesClusterID(ctx context.Context, req *KubernetesClusterIDRequest) (*KubernetesClusterIDResponse, error)

func (*UnimplementedSynchronizerServer) KubernetesAPISync 

func (*UnimplementedSynchronizerServer) KubernetesAPISync(ctx context.Context, req *KubernetesAPISyncRequest) (*KubernetesAPISyncResponse, error)

func (*UnimplementedSynchronizerServer) Plugin 

func (*UnimplementedSynchronizerServer) Plugin(req *PluginRequest, srv Synchronizer_PluginServer) error

func (*UnimplementedSynchronizerServer) Push 

func (*UnimplementedSynchronizerServer) Push(req *SyncRequest, srv Synchronizer_PushServer) error

func (*UnimplementedSynchronizerServer) Query 

func (*UnimplementedSynchronizerServer) Query(ctx context.Context, req *NtpRequest) (*NtpResponse, error)

func (*UnimplementedSynchronizerServer) RemoteExecute 

func (*UnimplementedSynchronizerServer) RemoteExecute(srv Synchronizer_RemoteExecuteServer) error

func (*UnimplementedSynchronizerServer) ShareGPIDLocalData 

func (*UnimplementedSynchronizerServer) ShareGPIDLocalData(ctx context.Context, req *ShareGPIDSyncRequests) (*ShareGPIDSyncRequests, error)

func (*UnimplementedSynchronizerServer) Sync 

func (*UnimplementedSynchronizerServer) Sync(ctx context.Context, req *SyncRequest) (*SyncResponse, error)

func (*UnimplementedSynchronizerServer) Upgrade 

func (*UnimplementedSynchronizerServer) Upgrade(req *UpgradeRequest, srv Synchronizer_UpgradeServer) error

type UpgradeRequest 

type UpgradeRequest struct {
	CtrlIp               *string  `protobuf:"bytes,1,opt,name=ctrl_ip,json=ctrlIp" json:"ctrl_ip,omitempty"`
	CtrlMac              *string  `protobuf:"bytes,2,opt,name=ctrl_mac,json=ctrlMac" json:"ctrl_mac,omitempty"`
	TeamId               *string  `protobuf:"bytes,3,opt,name=team_id,json=teamId" json:"team_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpgradeRequest) Descriptor 

func (*UpgradeRequest) Descriptor() ([]byte, []int)

func (*UpgradeRequest) GetCtrlIp 

func (m *UpgradeRequest) GetCtrlIp() string

func (*UpgradeRequest) GetCtrlMac 

func (m *UpgradeRequest) GetCtrlMac() string

func (*UpgradeRequest) GetTeamId 

func (m *UpgradeRequest) GetTeamId() string

func (*UpgradeRequest) Marshal 

func (m *UpgradeRequest) Marshal() (dAtA []byte, err error)

func (*UpgradeRequest) MarshalTo 

func (m *UpgradeRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpgradeRequest) MarshalToSizedBuffer 

func (m *UpgradeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpgradeRequest) ProtoMessage 

func (*UpgradeRequest) ProtoMessage()

func (*UpgradeRequest) Reset 

func (m *UpgradeRequest) Reset()

func (*UpgradeRequest) Size 

func (m *UpgradeRequest) Size() (n int)

func (*UpgradeRequest) String 

func (m *UpgradeRequest) String() string

func (*UpgradeRequest) Unmarshal 

func (m *UpgradeRequest) Unmarshal(dAtA []byte) error

func (*UpgradeRequest) XXX_DiscardUnknown 

func (m *UpgradeRequest) XXX_DiscardUnknown()

func (*UpgradeRequest) XXX_Marshal 

func (m *UpgradeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpgradeRequest) XXX_Merge 

func (m *UpgradeRequest) XXX_Merge(src proto.Message)

func (*UpgradeRequest) XXX_Size 

func (m *UpgradeRequest) XXX_Size() int

func (*UpgradeRequest) XXX_Unmarshal 

func (m *UpgradeRequest) XXX_Unmarshal(b []byte) error

type UpgradeResponse 

type UpgradeResponse struct {
	Status               *Status  `protobuf:"varint,1,opt,name=status,enum=agent.Status" json:"status,omitempty"`
	Content              []byte   `protobuf:"bytes,2,opt,name=content" json:"content,omitempty"`
	Md5                  *string  `protobuf:"bytes,3,opt,name=md5" json:"md5,omitempty"`
	TotalLen             *uint64  `protobuf:"varint,4,opt,name=total_len,json=totalLen" json:"total_len,omitempty"`
	PktCount             *uint32  `protobuf:"varint,5,opt,name=pkt_count,json=pktCount" json:"pkt_count,omitempty"`
	K8SImage             *string  `protobuf:"bytes,6,opt,name=k8s_image,json=k8sImage" json:"k8s_image,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpgradeResponse) Descriptor 

func (*UpgradeResponse) Descriptor() ([]byte, []int)

func (*UpgradeResponse) GetContent 

func (m *UpgradeResponse) GetContent() []byte

func (*UpgradeResponse) GetK8SImage 

func (m *UpgradeResponse) GetK8SImage() string

func (*UpgradeResponse) GetMd5 

func (m *UpgradeResponse) GetMd5() string

func (*UpgradeResponse) GetPktCount 

func (m *UpgradeResponse) GetPktCount() uint32

func (*UpgradeResponse) GetStatus 

func (m *UpgradeResponse) GetStatus() Status

func (*UpgradeResponse) GetTotalLen 

func (m *UpgradeResponse) GetTotalLen() uint64

func (*UpgradeResponse) Marshal 

func (m *UpgradeResponse) Marshal() (dAtA []byte, err error)

func (*UpgradeResponse) MarshalTo 

func (m *UpgradeResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpgradeResponse) MarshalToSizedBuffer 

func (m *UpgradeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpgradeResponse) ProtoMessage 

func (*UpgradeResponse) ProtoMessage()

func (*UpgradeResponse) Reset 

func (m *UpgradeResponse) Reset()

func (*UpgradeResponse) Size 

func (m *UpgradeResponse) Size() (n int)

func (*UpgradeResponse) String 

func (m *UpgradeResponse) String() string

func (*UpgradeResponse) Unmarshal 

func (m *UpgradeResponse) Unmarshal(dAtA []byte) error

func (*UpgradeResponse) XXX_DiscardUnknown 

func (m *UpgradeResponse) XXX_DiscardUnknown()

func (*UpgradeResponse) XXX_Marshal 

func (m *UpgradeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpgradeResponse) XXX_Merge 

func (m *UpgradeResponse) XXX_Merge(src proto.Message)

func (*UpgradeResponse) XXX_Size 

func (m *UpgradeResponse) XXX_Size() int

func (*UpgradeResponse) XXX_Unmarshal 

func (m *UpgradeResponse) XXX_Unmarshal(b []byte) error

type VlanMode 

type VlanMode int32
const (
	VlanMode_NONE VlanMode = 0
	VlanMode_VLAN VlanMode = 1
	VlanMode_QINQ VlanMode = 2
)

func (VlanMode) Enum 

func (x VlanMode) Enum() *VlanMode

func (VlanMode) EnumDescriptor 

func (VlanMode) EnumDescriptor() ([]byte, []int)

func (VlanMode) String 

func (x VlanMode) String() string

func (*VlanMode) UnmarshalJSON 

func (x *VlanMode) UnmarshalJSON(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.