Documentation
¶
Overview ¶
Package kp_proto is a generated protocol buffer package.
It is generated from these files:
kp_proto.proto
It has these top-level messages:
A2SRegisterReq S2ARegisterRes RealServerInfo S2AAddListenerReq A2SAddListenerRes S2ADelListenerReq A2SDelListenerRes S2AModListenerReq A2SModListenerRes S2ABindListenerWithRSReq A2SBindListenerWithRSRes S2AUnBindListenerWithRsReq A2SUnBindListenerWithRSRes RSStatus A2SRSStatusNotify HeartBeat S2AReloadReq A2SReloadRes A2SNetSpeedMeasureNtf NetStatisticsInfo A2SNetStatisticsNtf KPMessage
Index ¶
- Variables
- type A2SAddListenerRes
- func (*A2SAddListenerRes) Descriptor() ([]byte, []int)
- func (m *A2SAddListenerRes) GetListenerId() string
- func (m *A2SAddListenerRes) GetListenerPort() int32
- func (m *A2SAddListenerRes) GetNetProtocolName() string
- func (m *A2SAddListenerRes) GetProxyId() string
- func (m *A2SAddListenerRes) GetResult() KPErrorCode
- func (m *A2SAddListenerRes) GetTaskId() string
- func (m *A2SAddListenerRes) GetVrrpRouterid() int32
- func (*A2SAddListenerRes) ProtoMessage()
- func (m *A2SAddListenerRes) Reset()
- func (m *A2SAddListenerRes) String() string
- type A2SBindListenerWithRSRes
- func (*A2SBindListenerWithRSRes) Descriptor() ([]byte, []int)
- func (m *A2SBindListenerWithRSRes) GetListenerId() string
- func (m *A2SBindListenerWithRSRes) GetListenerPort() int32
- func (m *A2SBindListenerWithRSRes) GetNetProtocolName() string
- func (m *A2SBindListenerWithRSRes) GetProxyId() string
- func (m *A2SBindListenerWithRSRes) GetResult() KPErrorCode
- func (m *A2SBindListenerWithRSRes) GetTaskId() string
- func (m *A2SBindListenerWithRSRes) GetVrrpRouterid() int32
- func (*A2SBindListenerWithRSRes) ProtoMessage()
- func (m *A2SBindListenerWithRSRes) Reset()
- func (m *A2SBindListenerWithRSRes) String() string
- type A2SDelListenerRes
- func (*A2SDelListenerRes) Descriptor() ([]byte, []int)
- func (m *A2SDelListenerRes) GetListenerId() string
- func (m *A2SDelListenerRes) GetListenerPort() int32
- func (m *A2SDelListenerRes) GetNetProtocolName() string
- func (m *A2SDelListenerRes) GetProxyId() string
- func (m *A2SDelListenerRes) GetResult() KPErrorCode
- func (m *A2SDelListenerRes) GetTaskId() string
- func (m *A2SDelListenerRes) GetVrrpRouterid() int32
- func (*A2SDelListenerRes) ProtoMessage()
- func (m *A2SDelListenerRes) Reset()
- func (m *A2SDelListenerRes) String() string
- type A2SModListenerRes
- func (*A2SModListenerRes) Descriptor() ([]byte, []int)
- func (m *A2SModListenerRes) GetListenerId() string
- func (m *A2SModListenerRes) GetListenerPort() int32
- func (m *A2SModListenerRes) GetNetProtocolName() string
- func (m *A2SModListenerRes) GetProxyId() string
- func (m *A2SModListenerRes) GetResult() KPErrorCode
- func (m *A2SModListenerRes) GetTaskId() string
- func (m *A2SModListenerRes) GetVrrpRouterid() int32
- func (*A2SModListenerRes) ProtoMessage()
- func (m *A2SModListenerRes) Reset()
- func (m *A2SModListenerRes) String() string
- type A2SNetSpeedMeasureNtf
- func (*A2SNetSpeedMeasureNtf) Descriptor() ([]byte, []int)
- func (m *A2SNetSpeedMeasureNtf) GetLinkNodeId() string
- func (m *A2SNetSpeedMeasureNtf) GetProxyId() string
- func (m *A2SNetSpeedMeasureNtf) GetSpeed() int32
- func (m *A2SNetSpeedMeasureNtf) GetTimeStamp() int64
- func (m *A2SNetSpeedMeasureNtf) GetVrrpRouterid() int32
- func (*A2SNetSpeedMeasureNtf) ProtoMessage()
- func (m *A2SNetSpeedMeasureNtf) Reset()
- func (m *A2SNetSpeedMeasureNtf) String() string
- type A2SNetStatisticsNtf
- func (*A2SNetStatisticsNtf) Descriptor() ([]byte, []int)
- func (m *A2SNetStatisticsNtf) GetLinkNodeId() string
- func (m *A2SNetStatisticsNtf) GetNetstatis() *NetStatisticsInfo
- func (m *A2SNetStatisticsNtf) GetProxyId() string
- func (m *A2SNetStatisticsNtf) GetTimeStamp() int64
- func (m *A2SNetStatisticsNtf) GetVrrpRouterid() int32
- func (*A2SNetStatisticsNtf) ProtoMessage()
- func (m *A2SNetStatisticsNtf) Reset()
- func (m *A2SNetStatisticsNtf) String() string
- type A2SRSStatusNotify
- func (*A2SRSStatusNotify) Descriptor() ([]byte, []int)
- func (m *A2SRSStatusNotify) GetProxyId() string
- func (m *A2SRSStatusNotify) GetStatusInfo() *RSStatus
- func (m *A2SRSStatusNotify) GetVrrpRouterid() int32
- func (*A2SRSStatusNotify) ProtoMessage()
- func (m *A2SRSStatusNotify) Reset()
- func (m *A2SRSStatusNotify) String() string
- type A2SRegisterReq
- func (*A2SRegisterReq) Descriptor() ([]byte, []int)
- func (m *A2SRegisterReq) GetAgentLocalip() string
- func (m *A2SRegisterReq) GetDhKeyAgent() string
- func (m *A2SRegisterReq) GetIsMaster() bool
- func (*A2SRegisterReq) ProtoMessage()
- func (m *A2SRegisterReq) Reset()
- func (m *A2SRegisterReq) String() string
- type A2SReloadRes
- func (*A2SReloadRes) Descriptor() ([]byte, []int)
- func (m *A2SReloadRes) GetFailedReason() string
- func (m *A2SReloadRes) GetProxyId() string
- func (m *A2SReloadRes) GetResult() KPErrorCode
- func (m *A2SReloadRes) GetTaskId() string
- func (m *A2SReloadRes) GetVrrpRouterid() int32
- func (*A2SReloadRes) ProtoMessage()
- func (m *A2SReloadRes) Reset()
- func (m *A2SReloadRes) String() string
- type A2SUnBindListenerWithRSRes
- func (*A2SUnBindListenerWithRSRes) Descriptor() ([]byte, []int)
- func (m *A2SUnBindListenerWithRSRes) GetListenerId() string
- func (m *A2SUnBindListenerWithRSRes) GetListenerPort() int32
- func (m *A2SUnBindListenerWithRSRes) GetNetProtocolName() string
- func (m *A2SUnBindListenerWithRSRes) GetProxyId() string
- func (m *A2SUnBindListenerWithRSRes) GetResult() KPErrorCode
- func (m *A2SUnBindListenerWithRSRes) GetTaskId() string
- func (m *A2SUnBindListenerWithRSRes) GetVrrpRouterid() int32
- func (*A2SUnBindListenerWithRSRes) ProtoMessage()
- func (m *A2SUnBindListenerWithRSRes) Reset()
- func (m *A2SUnBindListenerWithRSRes) String() string
- type HeartBeat
- type KPErrorCode
- type KPMessage
- type KPProtoCmd
- type LinkNodeType
- type NetStatisticsInfo
- func (*NetStatisticsInfo) Descriptor() ([]byte, []int)
- func (m *NetStatisticsInfo) GetDroppcks() uint64
- func (m *NetStatisticsInfo) GetRxbytes() uint64
- func (m *NetStatisticsInfo) GetRxbytesS() uint32
- func (m *NetStatisticsInfo) GetRxpcks() uint64
- func (m *NetStatisticsInfo) GetTcpCurrestab() uint64
- func (m *NetStatisticsInfo) GetTcpInsegs() uint64
- func (m *NetStatisticsInfo) GetTcpOutsegs() uint64
- func (m *NetStatisticsInfo) GetTcpPassiveopens() uint64
- func (m *NetStatisticsInfo) GetTxbytes() uint64
- func (m *NetStatisticsInfo) GetTxbytesS() uint32
- func (m *NetStatisticsInfo) GetTxpcks() uint64
- func (m *NetStatisticsInfo) GetUdpIndatarams() uint64
- func (m *NetStatisticsInfo) GetUdpOutdatarams() uint64
- func (*NetStatisticsInfo) ProtoMessage()
- func (m *NetStatisticsInfo) Reset()
- func (m *NetStatisticsInfo) String() string
- type RSStatus
- func (*RSStatus) Descriptor() ([]byte, []int)
- func (m *RSStatus) GetListenerId() string
- func (m *RSStatus) GetNetProtocolName() string
- func (m *RSStatus) GetRsIp() string
- func (m *RSStatus) GetRsPort() int32
- func (m *RSStatus) GetStatus() int32
- func (m *RSStatus) GetTimeStamp() int64
- func (*RSStatus) ProtoMessage()
- func (m *RSStatus) Reset()
- func (m *RSStatus) String() string
- type RealServerInfo
- type S2AAddListenerReq
- func (*S2AAddListenerReq) Descriptor() ([]byte, []int)
- func (m *S2AAddListenerReq) GetDelayLoop() int32
- func (m *S2AAddListenerReq) GetListenerId() string
- func (m *S2AAddListenerReq) GetListenerPort() int32
- func (m *S2AAddListenerReq) GetNetProtocolName() string
- func (m *S2AAddListenerReq) GetProxyId() string
- func (m *S2AAddListenerReq) GetProxyRealsvrLst() []*RealServerInfo
- func (m *S2AAddListenerReq) GetScheduler() string
- func (m *S2AAddListenerReq) GetTaskId() string
- func (m *S2AAddListenerReq) GetVrrpRouterid() int32
- func (*S2AAddListenerReq) ProtoMessage()
- func (m *S2AAddListenerReq) Reset()
- func (m *S2AAddListenerReq) String() string
- type S2ABindListenerWithRSReq
- func (*S2ABindListenerWithRSReq) Descriptor() ([]byte, []int)
- func (m *S2ABindListenerWithRSReq) GetListenerId() string
- func (m *S2ABindListenerWithRSReq) GetListenerPort() int32
- func (m *S2ABindListenerWithRSReq) GetNetProtocolName() string
- func (m *S2ABindListenerWithRSReq) GetProxyId() string
- func (m *S2ABindListenerWithRSReq) GetRealserverLst() []*RealServerInfo
- func (m *S2ABindListenerWithRSReq) GetTaskId() string
- func (m *S2ABindListenerWithRSReq) GetVrrpRouterid() int32
- func (*S2ABindListenerWithRSReq) ProtoMessage()
- func (m *S2ABindListenerWithRSReq) Reset()
- func (m *S2ABindListenerWithRSReq) String() string
- type S2ADelListenerReq
- func (*S2ADelListenerReq) Descriptor() ([]byte, []int)
- func (m *S2ADelListenerReq) GetListenerId() string
- func (m *S2ADelListenerReq) GetListenerPort() int32
- func (m *S2ADelListenerReq) GetNetProtocolName() string
- func (m *S2ADelListenerReq) GetProxyId() string
- func (m *S2ADelListenerReq) GetTaskId() string
- func (m *S2ADelListenerReq) GetVrrpRouterid() int32
- func (*S2ADelListenerReq) ProtoMessage()
- func (m *S2ADelListenerReq) Reset()
- func (m *S2ADelListenerReq) String() string
- type S2AModListenerReq
- func (*S2AModListenerReq) Descriptor() ([]byte, []int)
- func (m *S2AModListenerReq) GetDelayLoop() int32
- func (m *S2AModListenerReq) GetListenerId() string
- func (m *S2AModListenerReq) GetListenerPort() int32
- func (m *S2AModListenerReq) GetNetProtocolName() string
- func (m *S2AModListenerReq) GetProxyId() string
- func (m *S2AModListenerReq) GetScheduler() string
- func (m *S2AModListenerReq) GetTaskId() string
- func (m *S2AModListenerReq) GetVrrpRouterid() int32
- func (*S2AModListenerReq) ProtoMessage()
- func (m *S2AModListenerReq) Reset()
- func (m *S2AModListenerReq) String() string
- type S2ARegisterRes
- func (*S2ARegisterRes) Descriptor() ([]byte, []int)
- func (m *S2ARegisterRes) GetDhKeyServer() string
- func (m *S2ARegisterRes) GetKpLocalip() string
- func (m *S2ARegisterRes) GetKpVirtualIp() string
- func (m *S2ARegisterRes) GetLinkNodeId() string
- func (m *S2ARegisterRes) GetLinkNodeType() LinkNodeType
- func (m *S2ARegisterRes) GetProxyId() string
- func (m *S2ARegisterRes) GetResult() KPErrorCode
- func (m *S2ARegisterRes) GetVrrpItfname() string
- func (m *S2ARegisterRes) GetVrrpRouterid() int32
- func (*S2ARegisterRes) ProtoMessage()
- func (m *S2ARegisterRes) Reset()
- func (m *S2ARegisterRes) String() string
- type S2AReloadReq
- type S2AUnBindListenerWithRsReq
- func (*S2AUnBindListenerWithRsReq) Descriptor() ([]byte, []int)
- func (m *S2AUnBindListenerWithRsReq) GetListenerId() string
- func (m *S2AUnBindListenerWithRsReq) GetListenerPort() int32
- func (m *S2AUnBindListenerWithRsReq) GetNetProtocolName() string
- func (m *S2AUnBindListenerWithRsReq) GetProxyId() string
- func (m *S2AUnBindListenerWithRsReq) GetRealserverLst() []string
- func (m *S2AUnBindListenerWithRsReq) GetTaskId() string
- func (m *S2AUnBindListenerWithRsReq) GetVrrpRouterid() int32
- func (*S2AUnBindListenerWithRsReq) ProtoMessage()
- func (m *S2AUnBindListenerWithRsReq) Reset()
- func (m *S2AUnBindListenerWithRsReq) String() string
Constants ¶
This section is empty.
Variables ¶
var KPErrorCode_name = map[int32]string{
0: "E_KPERR_OK",
1: "E_KPERR_FAILED_PROXYID_INVALID",
2: "E_KPERR_FAILED_VRRPROUTERID_INVALID",
3: "E_KPERR_FAILED_ADDVIRTUALSVR_ALREADYEXISTS",
4: "E_KPERR_FAILED_DELVIRTUALSVR_NOTEXISTS",
5: "E_KPERR_FAILED_BINDRS_VIRTUALSVRNOTEXISTS",
6: "E_KPERR_FAILED_UNBINDRS_VIRTUALSVRNOTEXISTS",
7: "E_KPERR_FAILED_RELOAD",
8: "E_KPERR_FAILED_INSIDERROR",
9: "E_KPERR_FAILED_REGISTER_LOCALIPNOTEXISTS",
10: "E_KPERR_FAILED_REGISTER_DATABASEERROR",
11: "E_KPERR_FAILED_UNMARSHALEFAILED",
12: "E_KPERR_FAILED_MODLISTENER_VIRTUALSVRNOTEXISTS",
}
var KPErrorCode_value = map[string]int32{
"E_KPERR_OK": 0,
"E_KPERR_FAILED_PROXYID_INVALID": 1,
"E_KPERR_FAILED_VRRPROUTERID_INVALID": 2,
"E_KPERR_FAILED_ADDVIRTUALSVR_ALREADYEXISTS": 3,
"E_KPERR_FAILED_DELVIRTUALSVR_NOTEXISTS": 4,
"E_KPERR_FAILED_BINDRS_VIRTUALSVRNOTEXISTS": 5,
"E_KPERR_FAILED_UNBINDRS_VIRTUALSVRNOTEXISTS": 6,
"E_KPERR_FAILED_RELOAD": 7,
"E_KPERR_FAILED_INSIDERROR": 8,
"E_KPERR_FAILED_REGISTER_LOCALIPNOTEXISTS": 9,
"E_KPERR_FAILED_REGISTER_DATABASEERROR": 10,
"E_KPERR_FAILED_UNMARSHALEFAILED": 11,
"E_KPERR_FAILED_MODLISTENER_VIRTUALSVRNOTEXISTS": 12,
}
var KPProtoCmd_name = map[int32]string{
0: "E_A2S_REGISTER_REQ",
1: "E_S2A_REGISTER_RES",
2: "E_S2A_ADD_LISTENER_REQ",
3: "E_A2S_ADD_LISTENER_RES",
4: "E_S2A_DEL_LISTENER_REQ",
5: "E_A2S_DEL_LISTENER_RES",
6: "E_S2A_BIND_LISTENER_WITH_RS_REQ",
7: "E_A2S_BIND_LISTENER_WITH_RS_RES",
8: "E_S2A_UNBIND_LISTENER_WITH_RS_REQ",
9: "E_A2S_UNBIND_LISTENER_WITH_RS_RES",
10: "E_A2S_RS_STATUS_NOTIFY",
12: "E_A2S_HEARTBEAT_REQ",
13: "E_S2A_HEARTBEAT_RES",
14: "E_S2A_KPRELOAD_REQ",
15: "E_A2S_KPRELOAD_RES",
16: "E_A2S_NETSPEEDMEASURE_NTF",
17: "E_A2S_NETSTATISTICS_NTF",
18: "E_S2A_MOD_LISTENER_REQ",
19: "E_A2S_MOD_LISTENER_RES",
}
var KPProtoCmd_value = map[string]int32{
"E_A2S_REGISTER_REQ": 0,
"E_S2A_REGISTER_RES": 1,
"E_S2A_ADD_LISTENER_REQ": 2,
"E_A2S_ADD_LISTENER_RES": 3,
"E_S2A_DEL_LISTENER_REQ": 4,
"E_A2S_DEL_LISTENER_RES": 5,
"E_S2A_BIND_LISTENER_WITH_RS_REQ": 6,
"E_A2S_BIND_LISTENER_WITH_RS_RES": 7,
"E_S2A_UNBIND_LISTENER_WITH_RS_REQ": 8,
"E_A2S_UNBIND_LISTENER_WITH_RS_RES": 9,
"E_A2S_RS_STATUS_NOTIFY": 10,
"E_A2S_HEARTBEAT_REQ": 12,
"E_S2A_HEARTBEAT_RES": 13,
"E_S2A_KPRELOAD_REQ": 14,
"E_A2S_KPRELOAD_RES": 15,
"E_A2S_NETSPEEDMEASURE_NTF": 16,
"E_A2S_NETSTATISTICS_NTF": 17,
"E_S2A_MOD_LISTENER_REQ": 18,
"E_A2S_MOD_LISTENER_RES": 19,
}
var LinkNodeType_name = map[int32]string{
0: "E_LINKNODE_FRONTEND",
1: "E_LINKNODE_BACKEND",
2: "E_LINKNODE_INTERMEDIATE",
}
var LinkNodeType_value = map[string]int32{
"E_LINKNODE_FRONTEND": 0,
"E_LINKNODE_BACKEND": 1,
"E_LINKNODE_INTERMEDIATE": 2,
}
Functions ¶
This section is empty.
Types ¶
type A2SAddListenerRes ¶
type A2SAddListenerRes struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Result *KPErrorCode `protobuf:"varint,7,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SAddListenerRes) Descriptor ¶
func (*A2SAddListenerRes) Descriptor() ([]byte, []int)
func (*A2SAddListenerRes) GetListenerId ¶
func (m *A2SAddListenerRes) GetListenerId() string
func (*A2SAddListenerRes) GetListenerPort ¶
func (m *A2SAddListenerRes) GetListenerPort() int32
func (*A2SAddListenerRes) GetNetProtocolName ¶
func (m *A2SAddListenerRes) GetNetProtocolName() string
func (*A2SAddListenerRes) GetProxyId ¶
func (m *A2SAddListenerRes) GetProxyId() string
func (*A2SAddListenerRes) GetResult ¶
func (m *A2SAddListenerRes) GetResult() KPErrorCode
func (*A2SAddListenerRes) GetTaskId ¶
func (m *A2SAddListenerRes) GetTaskId() string
func (*A2SAddListenerRes) GetVrrpRouterid ¶
func (m *A2SAddListenerRes) GetVrrpRouterid() int32
func (*A2SAddListenerRes) ProtoMessage ¶
func (*A2SAddListenerRes) ProtoMessage()
func (*A2SAddListenerRes) Reset ¶
func (m *A2SAddListenerRes) Reset()
func (*A2SAddListenerRes) String ¶
func (m *A2SAddListenerRes) String() string
type A2SBindListenerWithRSRes ¶
type A2SBindListenerWithRSRes struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Result *KPErrorCode `protobuf:"varint,7,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SBindListenerWithRSRes) Descriptor ¶
func (*A2SBindListenerWithRSRes) Descriptor() ([]byte, []int)
func (*A2SBindListenerWithRSRes) GetListenerId ¶
func (m *A2SBindListenerWithRSRes) GetListenerId() string
func (*A2SBindListenerWithRSRes) GetListenerPort ¶
func (m *A2SBindListenerWithRSRes) GetListenerPort() int32
func (*A2SBindListenerWithRSRes) GetNetProtocolName ¶
func (m *A2SBindListenerWithRSRes) GetNetProtocolName() string
func (*A2SBindListenerWithRSRes) GetProxyId ¶
func (m *A2SBindListenerWithRSRes) GetProxyId() string
func (*A2SBindListenerWithRSRes) GetResult ¶
func (m *A2SBindListenerWithRSRes) GetResult() KPErrorCode
func (*A2SBindListenerWithRSRes) GetTaskId ¶
func (m *A2SBindListenerWithRSRes) GetTaskId() string
func (*A2SBindListenerWithRSRes) GetVrrpRouterid ¶
func (m *A2SBindListenerWithRSRes) GetVrrpRouterid() int32
func (*A2SBindListenerWithRSRes) ProtoMessage ¶
func (*A2SBindListenerWithRSRes) ProtoMessage()
func (*A2SBindListenerWithRSRes) Reset ¶
func (m *A2SBindListenerWithRSRes) Reset()
func (*A2SBindListenerWithRSRes) String ¶
func (m *A2SBindListenerWithRSRes) String() string
type A2SDelListenerRes ¶
type A2SDelListenerRes struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Result *KPErrorCode `protobuf:"varint,7,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SDelListenerRes) Descriptor ¶
func (*A2SDelListenerRes) Descriptor() ([]byte, []int)
func (*A2SDelListenerRes) GetListenerId ¶
func (m *A2SDelListenerRes) GetListenerId() string
func (*A2SDelListenerRes) GetListenerPort ¶
func (m *A2SDelListenerRes) GetListenerPort() int32
func (*A2SDelListenerRes) GetNetProtocolName ¶
func (m *A2SDelListenerRes) GetNetProtocolName() string
func (*A2SDelListenerRes) GetProxyId ¶
func (m *A2SDelListenerRes) GetProxyId() string
func (*A2SDelListenerRes) GetResult ¶
func (m *A2SDelListenerRes) GetResult() KPErrorCode
func (*A2SDelListenerRes) GetTaskId ¶
func (m *A2SDelListenerRes) GetTaskId() string
func (*A2SDelListenerRes) GetVrrpRouterid ¶
func (m *A2SDelListenerRes) GetVrrpRouterid() int32
func (*A2SDelListenerRes) ProtoMessage ¶
func (*A2SDelListenerRes) ProtoMessage()
func (*A2SDelListenerRes) Reset ¶
func (m *A2SDelListenerRes) Reset()
func (*A2SDelListenerRes) String ¶
func (m *A2SDelListenerRes) String() string
type A2SModListenerRes ¶
type A2SModListenerRes struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Result *KPErrorCode `protobuf:"varint,7,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SModListenerRes) Descriptor ¶
func (*A2SModListenerRes) Descriptor() ([]byte, []int)
func (*A2SModListenerRes) GetListenerId ¶
func (m *A2SModListenerRes) GetListenerId() string
func (*A2SModListenerRes) GetListenerPort ¶
func (m *A2SModListenerRes) GetListenerPort() int32
func (*A2SModListenerRes) GetNetProtocolName ¶
func (m *A2SModListenerRes) GetNetProtocolName() string
func (*A2SModListenerRes) GetProxyId ¶
func (m *A2SModListenerRes) GetProxyId() string
func (*A2SModListenerRes) GetResult ¶
func (m *A2SModListenerRes) GetResult() KPErrorCode
func (*A2SModListenerRes) GetTaskId ¶
func (m *A2SModListenerRes) GetTaskId() string
func (*A2SModListenerRes) GetVrrpRouterid ¶
func (m *A2SModListenerRes) GetVrrpRouterid() int32
func (*A2SModListenerRes) ProtoMessage ¶
func (*A2SModListenerRes) ProtoMessage()
func (*A2SModListenerRes) Reset ¶
func (m *A2SModListenerRes) Reset()
func (*A2SModListenerRes) String ¶
func (m *A2SModListenerRes) String() string
type A2SNetSpeedMeasureNtf ¶
type A2SNetSpeedMeasureNtf struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,2,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` LinkNodeId *string `protobuf:"bytes,3,req,name=link_node_id" json:"link_node_id,omitempty"` Speed *int32 `protobuf:"varint,4,req,name=speed" json:"speed,omitempty"` TimeStamp *int64 `protobuf:"varint,5,req,name=time_stamp" json:"time_stamp,omitempty"` XXX_unrecognized []byte `json:"-"` }
--------------------------------------------------------------------------
func (*A2SNetSpeedMeasureNtf) Descriptor ¶
func (*A2SNetSpeedMeasureNtf) Descriptor() ([]byte, []int)
func (*A2SNetSpeedMeasureNtf) GetLinkNodeId ¶
func (m *A2SNetSpeedMeasureNtf) GetLinkNodeId() string
func (*A2SNetSpeedMeasureNtf) GetProxyId ¶
func (m *A2SNetSpeedMeasureNtf) GetProxyId() string
func (*A2SNetSpeedMeasureNtf) GetSpeed ¶
func (m *A2SNetSpeedMeasureNtf) GetSpeed() int32
func (*A2SNetSpeedMeasureNtf) GetTimeStamp ¶
func (m *A2SNetSpeedMeasureNtf) GetTimeStamp() int64
func (*A2SNetSpeedMeasureNtf) GetVrrpRouterid ¶
func (m *A2SNetSpeedMeasureNtf) GetVrrpRouterid() int32
func (*A2SNetSpeedMeasureNtf) ProtoMessage ¶
func (*A2SNetSpeedMeasureNtf) ProtoMessage()
func (*A2SNetSpeedMeasureNtf) Reset ¶
func (m *A2SNetSpeedMeasureNtf) Reset()
func (*A2SNetSpeedMeasureNtf) String ¶
func (m *A2SNetSpeedMeasureNtf) String() string
type A2SNetStatisticsNtf ¶
type A2SNetStatisticsNtf struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,2,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` LinkNodeId *string `protobuf:"bytes,3,req,name=link_node_id" json:"link_node_id,omitempty"` Netstatis *NetStatisticsInfo `protobuf:"bytes,4,req,name=netstatis" json:"netstatis,omitempty"` TimeStamp *int64 `protobuf:"varint,5,req,name=time_stamp" json:"time_stamp,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SNetStatisticsNtf) Descriptor ¶
func (*A2SNetStatisticsNtf) Descriptor() ([]byte, []int)
func (*A2SNetStatisticsNtf) GetLinkNodeId ¶
func (m *A2SNetStatisticsNtf) GetLinkNodeId() string
func (*A2SNetStatisticsNtf) GetNetstatis ¶
func (m *A2SNetStatisticsNtf) GetNetstatis() *NetStatisticsInfo
func (*A2SNetStatisticsNtf) GetProxyId ¶
func (m *A2SNetStatisticsNtf) GetProxyId() string
func (*A2SNetStatisticsNtf) GetTimeStamp ¶
func (m *A2SNetStatisticsNtf) GetTimeStamp() int64
func (*A2SNetStatisticsNtf) GetVrrpRouterid ¶
func (m *A2SNetStatisticsNtf) GetVrrpRouterid() int32
func (*A2SNetStatisticsNtf) ProtoMessage ¶
func (*A2SNetStatisticsNtf) ProtoMessage()
func (*A2SNetStatisticsNtf) Reset ¶
func (m *A2SNetStatisticsNtf) Reset()
func (*A2SNetStatisticsNtf) String ¶
func (m *A2SNetStatisticsNtf) String() string
type A2SRSStatusNotify ¶
type A2SRSStatusNotify struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,2,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` StatusInfo *RSStatus `protobuf:"bytes,3,req,name=status_info" json:"status_info,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SRSStatusNotify) Descriptor ¶
func (*A2SRSStatusNotify) Descriptor() ([]byte, []int)
func (*A2SRSStatusNotify) GetProxyId ¶
func (m *A2SRSStatusNotify) GetProxyId() string
func (*A2SRSStatusNotify) GetStatusInfo ¶
func (m *A2SRSStatusNotify) GetStatusInfo() *RSStatus
func (*A2SRSStatusNotify) GetVrrpRouterid ¶
func (m *A2SRSStatusNotify) GetVrrpRouterid() int32
func (*A2SRSStatusNotify) ProtoMessage ¶
func (*A2SRSStatusNotify) ProtoMessage()
func (*A2SRSStatusNotify) Reset ¶
func (m *A2SRSStatusNotify) Reset()
func (*A2SRSStatusNotify) String ¶
func (m *A2SRSStatusNotify) String() string
type A2SRegisterReq ¶
type A2SRegisterReq struct { AgentLocalip *string `protobuf:"bytes,1,req,name=agent_localip" json:"agent_localip,omitempty"` DhKeyAgent *string `protobuf:"bytes,2,req,name=dh_key_agent" json:"dh_key_agent,omitempty"` IsMaster *bool `protobuf:"varint,3,req,name=is_master" json:"is_master,omitempty"` XXX_unrecognized []byte `json:"-"` }
---------------------------------------------------------------------------
func (*A2SRegisterReq) Descriptor ¶
func (*A2SRegisterReq) Descriptor() ([]byte, []int)
func (*A2SRegisterReq) GetAgentLocalip ¶
func (m *A2SRegisterReq) GetAgentLocalip() string
func (*A2SRegisterReq) GetDhKeyAgent ¶
func (m *A2SRegisterReq) GetDhKeyAgent() string
func (*A2SRegisterReq) GetIsMaster ¶
func (m *A2SRegisterReq) GetIsMaster() bool
func (*A2SRegisterReq) ProtoMessage ¶
func (*A2SRegisterReq) ProtoMessage()
func (*A2SRegisterReq) Reset ¶
func (m *A2SRegisterReq) Reset()
func (*A2SRegisterReq) String ¶
func (m *A2SRegisterReq) String() string
type A2SReloadRes ¶
type A2SReloadRes struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,2,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` Result *KPErrorCode `protobuf:"varint,3,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` FailedReason *string `protobuf:"bytes,4,opt,name=failed_reason" json:"failed_reason,omitempty"` TaskId *string `protobuf:"bytes,5,req,name=task_id" json:"task_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SReloadRes) Descriptor ¶
func (*A2SReloadRes) Descriptor() ([]byte, []int)
func (*A2SReloadRes) GetFailedReason ¶
func (m *A2SReloadRes) GetFailedReason() string
func (*A2SReloadRes) GetProxyId ¶
func (m *A2SReloadRes) GetProxyId() string
func (*A2SReloadRes) GetResult ¶
func (m *A2SReloadRes) GetResult() KPErrorCode
func (*A2SReloadRes) GetTaskId ¶
func (m *A2SReloadRes) GetTaskId() string
func (*A2SReloadRes) GetVrrpRouterid ¶
func (m *A2SReloadRes) GetVrrpRouterid() int32
func (*A2SReloadRes) ProtoMessage ¶
func (*A2SReloadRes) ProtoMessage()
func (*A2SReloadRes) Reset ¶
func (m *A2SReloadRes) Reset()
func (*A2SReloadRes) String ¶
func (m *A2SReloadRes) String() string
type A2SUnBindListenerWithRSRes ¶
type A2SUnBindListenerWithRSRes struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Result *KPErrorCode `protobuf:"varint,7,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*A2SUnBindListenerWithRSRes) Descriptor ¶
func (*A2SUnBindListenerWithRSRes) Descriptor() ([]byte, []int)
func (*A2SUnBindListenerWithRSRes) GetListenerId ¶
func (m *A2SUnBindListenerWithRSRes) GetListenerId() string
func (*A2SUnBindListenerWithRSRes) GetListenerPort ¶
func (m *A2SUnBindListenerWithRSRes) GetListenerPort() int32
func (*A2SUnBindListenerWithRSRes) GetNetProtocolName ¶
func (m *A2SUnBindListenerWithRSRes) GetNetProtocolName() string
func (*A2SUnBindListenerWithRSRes) GetProxyId ¶
func (m *A2SUnBindListenerWithRSRes) GetProxyId() string
func (*A2SUnBindListenerWithRSRes) GetResult ¶
func (m *A2SUnBindListenerWithRSRes) GetResult() KPErrorCode
func (*A2SUnBindListenerWithRSRes) GetTaskId ¶
func (m *A2SUnBindListenerWithRSRes) GetTaskId() string
func (*A2SUnBindListenerWithRSRes) GetVrrpRouterid ¶
func (m *A2SUnBindListenerWithRSRes) GetVrrpRouterid() int32
func (*A2SUnBindListenerWithRSRes) ProtoMessage ¶
func (*A2SUnBindListenerWithRSRes) ProtoMessage()
func (*A2SUnBindListenerWithRSRes) Reset ¶
func (m *A2SUnBindListenerWithRSRes) Reset()
func (*A2SUnBindListenerWithRSRes) String ¶
func (m *A2SUnBindListenerWithRSRes) String() string
type HeartBeat ¶
type HeartBeat struct { TimeStamp *int64 `protobuf:"varint,1,req,name=time_stamp" json:"time_stamp,omitempty"` FromHost *string `protobuf:"bytes,2,req,name=from_host" json:"from_host,omitempty"` XXX_unrecognized []byte `json:"-"` }
---------------------------------------------------------------------------
func (*HeartBeat) Descriptor ¶
func (*HeartBeat) GetFromHost ¶
func (*HeartBeat) GetTimeStamp ¶
func (*HeartBeat) ProtoMessage ¶
func (*HeartBeat) ProtoMessage()
type KPErrorCode ¶
type KPErrorCode int32
---------------------------------------------------------------------------
const ( KPErrorCode_E_KPERR_OK KPErrorCode = 0 KPErrorCode_E_KPERR_FAILED_PROXYID_INVALID KPErrorCode = 1 KPErrorCode_E_KPERR_FAILED_VRRPROUTERID_INVALID KPErrorCode = 2 KPErrorCode_E_KPERR_FAILED_ADDVIRTUALSVR_ALREADYEXISTS KPErrorCode = 3 KPErrorCode_E_KPERR_FAILED_DELVIRTUALSVR_NOTEXISTS KPErrorCode = 4 KPErrorCode_E_KPERR_FAILED_BINDRS_VIRTUALSVRNOTEXISTS KPErrorCode = 5 KPErrorCode_E_KPERR_FAILED_UNBINDRS_VIRTUALSVRNOTEXISTS KPErrorCode = 6 KPErrorCode_E_KPERR_FAILED_RELOAD KPErrorCode = 7 KPErrorCode_E_KPERR_FAILED_INSIDERROR KPErrorCode = 8 KPErrorCode_E_KPERR_FAILED_REGISTER_LOCALIPNOTEXISTS KPErrorCode = 9 KPErrorCode_E_KPERR_FAILED_REGISTER_DATABASEERROR KPErrorCode = 10 KPErrorCode_E_KPERR_FAILED_UNMARSHALEFAILED KPErrorCode = 11 KPErrorCode_E_KPERR_FAILED_MODLISTENER_VIRTUALSVRNOTEXISTS KPErrorCode = 12 )
func (KPErrorCode) Enum ¶
func (x KPErrorCode) Enum() *KPErrorCode
func (KPErrorCode) EnumDescriptor ¶
func (KPErrorCode) EnumDescriptor() ([]byte, []int)
func (KPErrorCode) String ¶
func (x KPErrorCode) String() string
func (*KPErrorCode) UnmarshalJSON ¶
func (x *KPErrorCode) UnmarshalJSON(data []byte) error
type KPMessage ¶
type KPMessage struct { Cmd *KPProtoCmd `protobuf:"varint,1,req,name=cmd,enum=kp_proto.KPProtoCmd" json:"cmd,omitempty"` RealMessageMarshaldata []byte `protobuf:"bytes,2,req,name=real_message_marshaldata" json:"real_message_marshaldata,omitempty"` XXX_unrecognized []byte `json:"-"` }
---------------------------------------------------------------------------
func (*KPMessage) Descriptor ¶
func (*KPMessage) GetCmd ¶
func (m *KPMessage) GetCmd() KPProtoCmd
func (*KPMessage) GetRealMessageMarshaldata ¶
func (*KPMessage) ProtoMessage ¶
func (*KPMessage) ProtoMessage()
type KPProtoCmd ¶
type KPProtoCmd int32
const ( KPProtoCmd_E_A2S_REGISTER_REQ KPProtoCmd = 0 KPProtoCmd_E_S2A_REGISTER_RES KPProtoCmd = 1 KPProtoCmd_E_S2A_ADD_LISTENER_REQ KPProtoCmd = 2 KPProtoCmd_E_A2S_ADD_LISTENER_RES KPProtoCmd = 3 KPProtoCmd_E_S2A_DEL_LISTENER_REQ KPProtoCmd = 4 KPProtoCmd_E_A2S_DEL_LISTENER_RES KPProtoCmd = 5 KPProtoCmd_E_S2A_BIND_LISTENER_WITH_RS_REQ KPProtoCmd = 6 KPProtoCmd_E_A2S_BIND_LISTENER_WITH_RS_RES KPProtoCmd = 7 KPProtoCmd_E_S2A_UNBIND_LISTENER_WITH_RS_REQ KPProtoCmd = 8 KPProtoCmd_E_A2S_UNBIND_LISTENER_WITH_RS_RES KPProtoCmd = 9 KPProtoCmd_E_A2S_RS_STATUS_NOTIFY KPProtoCmd = 10 KPProtoCmd_E_A2S_HEARTBEAT_REQ KPProtoCmd = 12 KPProtoCmd_E_S2A_HEARTBEAT_RES KPProtoCmd = 13 KPProtoCmd_E_S2A_KPRELOAD_REQ KPProtoCmd = 14 KPProtoCmd_E_A2S_KPRELOAD_RES KPProtoCmd = 15 KPProtoCmd_E_A2S_NETSPEEDMEASURE_NTF KPProtoCmd = 16 KPProtoCmd_E_A2S_NETSTATISTICS_NTF KPProtoCmd = 17 KPProtoCmd_E_S2A_MOD_LISTENER_REQ KPProtoCmd = 18 KPProtoCmd_E_A2S_MOD_LISTENER_RES KPProtoCmd = 19 )
func (KPProtoCmd) Enum ¶
func (x KPProtoCmd) Enum() *KPProtoCmd
func (KPProtoCmd) EnumDescriptor ¶
func (KPProtoCmd) EnumDescriptor() ([]byte, []int)
func (KPProtoCmd) String ¶
func (x KPProtoCmd) String() string
func (*KPProtoCmd) UnmarshalJSON ¶
func (x *KPProtoCmd) UnmarshalJSON(data []byte) error
type LinkNodeType ¶
type LinkNodeType int32
---------------------------------------------------------------------------
const ( LinkNodeType_E_LINKNODE_FRONTEND LinkNodeType = 0 LinkNodeType_E_LINKNODE_BACKEND LinkNodeType = 1 LinkNodeType_E_LINKNODE_INTERMEDIATE LinkNodeType = 2 )
func (LinkNodeType) Enum ¶
func (x LinkNodeType) Enum() *LinkNodeType
func (LinkNodeType) EnumDescriptor ¶
func (LinkNodeType) EnumDescriptor() ([]byte, []int)
func (LinkNodeType) String ¶
func (x LinkNodeType) String() string
func (*LinkNodeType) UnmarshalJSON ¶
func (x *LinkNodeType) UnmarshalJSON(data []byte) error
type NetStatisticsInfo ¶
type NetStatisticsInfo struct { Rxpcks *uint64 `protobuf:"varint,1,req,name=rxpcks" json:"rxpcks,omitempty"` Txpcks *uint64 `protobuf:"varint,2,req,name=txpcks" json:"txpcks,omitempty"` Droppcks *uint64 `protobuf:"varint,3,req,name=droppcks" json:"droppcks,omitempty"` Rxbytes *uint64 `protobuf:"varint,4,req,name=rxbytes" json:"rxbytes,omitempty"` Txbytes *uint64 `protobuf:"varint,5,req,name=txbytes" json:"txbytes,omitempty"` TcpPassiveopens *uint64 `protobuf:"varint,6,req,name=tcp_passiveopens" json:"tcp_passiveopens,omitempty"` TcpCurrestab *uint64 `protobuf:"varint,7,req,name=tcp_currestab" json:"tcp_currestab,omitempty"` TcpInsegs *uint64 `protobuf:"varint,8,req,name=tcp_insegs" json:"tcp_insegs,omitempty"` TcpOutsegs *uint64 `protobuf:"varint,9,req,name=tcp_outsegs" json:"tcp_outsegs,omitempty"` UdpIndatarams *uint64 `protobuf:"varint,10,req,name=udp_indatarams" json:"udp_indatarams,omitempty"` UdpOutdatarams *uint64 `protobuf:"varint,11,req,name=udp_outdatarams" json:"udp_outdatarams,omitempty"` RxbytesS *uint32 `protobuf:"varint,12,req,name=rxbytes_s" json:"rxbytes_s,omitempty"` TxbytesS *uint32 `protobuf:"varint,13,req,name=txbytes_s" json:"txbytes_s,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NetStatisticsInfo) Descriptor ¶
func (*NetStatisticsInfo) Descriptor() ([]byte, []int)
func (*NetStatisticsInfo) GetDroppcks ¶
func (m *NetStatisticsInfo) GetDroppcks() uint64
func (*NetStatisticsInfo) GetRxbytes ¶
func (m *NetStatisticsInfo) GetRxbytes() uint64
func (*NetStatisticsInfo) GetRxbytesS ¶
func (m *NetStatisticsInfo) GetRxbytesS() uint32
func (*NetStatisticsInfo) GetRxpcks ¶
func (m *NetStatisticsInfo) GetRxpcks() uint64
func (*NetStatisticsInfo) GetTcpCurrestab ¶
func (m *NetStatisticsInfo) GetTcpCurrestab() uint64
func (*NetStatisticsInfo) GetTcpInsegs ¶
func (m *NetStatisticsInfo) GetTcpInsegs() uint64
func (*NetStatisticsInfo) GetTcpOutsegs ¶
func (m *NetStatisticsInfo) GetTcpOutsegs() uint64
func (*NetStatisticsInfo) GetTcpPassiveopens ¶
func (m *NetStatisticsInfo) GetTcpPassiveopens() uint64
func (*NetStatisticsInfo) GetTxbytes ¶
func (m *NetStatisticsInfo) GetTxbytes() uint64
func (*NetStatisticsInfo) GetTxbytesS ¶
func (m *NetStatisticsInfo) GetTxbytesS() uint32
func (*NetStatisticsInfo) GetTxpcks ¶
func (m *NetStatisticsInfo) GetTxpcks() uint64
func (*NetStatisticsInfo) GetUdpIndatarams ¶
func (m *NetStatisticsInfo) GetUdpIndatarams() uint64
func (*NetStatisticsInfo) GetUdpOutdatarams ¶
func (m *NetStatisticsInfo) GetUdpOutdatarams() uint64
func (*NetStatisticsInfo) ProtoMessage ¶
func (*NetStatisticsInfo) ProtoMessage()
func (*NetStatisticsInfo) Reset ¶
func (m *NetStatisticsInfo) Reset()
func (*NetStatisticsInfo) String ¶
func (m *NetStatisticsInfo) String() string
type RSStatus ¶
type RSStatus struct { RsPort *int32 `protobuf:"varint,1,req,name=rs_port" json:"rs_port,omitempty"` RsIp *string `protobuf:"bytes,2,req,name=rs_ip" json:"rs_ip,omitempty"` NetProtocolName *string `protobuf:"bytes,3,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` Status *int32 `protobuf:"varint,5,req,name=status" json:"status,omitempty"` TimeStamp *int64 `protobuf:"varint,6,req,name=time_stamp" json:"time_stamp,omitempty"` XXX_unrecognized []byte `json:"-"` }
---------------------------------------------------------------------------
func (*RSStatus) Descriptor ¶
func (*RSStatus) GetListenerId ¶
func (*RSStatus) GetNetProtocolName ¶
func (*RSStatus) GetTimeStamp ¶
func (*RSStatus) ProtoMessage ¶
func (*RSStatus) ProtoMessage()
type RealServerInfo ¶
type RealServerInfo struct { Weight *int32 `protobuf:"varint,1,req,name=weight" json:"weight,omitempty"` Ip *string `protobuf:"bytes,2,req,name=ip" json:"ip,omitempty"` XXX_unrecognized []byte `json:"-"` }
添加监听器------------------------------------------------------------------
func (*RealServerInfo) Descriptor ¶
func (*RealServerInfo) Descriptor() ([]byte, []int)
func (*RealServerInfo) GetIp ¶
func (m *RealServerInfo) GetIp() string
func (*RealServerInfo) GetWeight ¶
func (m *RealServerInfo) GetWeight() int32
func (*RealServerInfo) ProtoMessage ¶
func (*RealServerInfo) ProtoMessage()
func (*RealServerInfo) Reset ¶
func (m *RealServerInfo) Reset()
func (*RealServerInfo) String ¶
func (m *RealServerInfo) String() string
type S2AAddListenerReq ¶
type S2AAddListenerReq struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Scheduler *string `protobuf:"bytes,7,req,name=scheduler" json:"scheduler,omitempty"` DelayLoop *int32 `protobuf:"varint,8,req,name=delay_loop" json:"delay_loop,omitempty"` // 这时前端代理机要配置后端的代理机的rs,最后一个代理机数据为空 ProxyRealsvrLst []*RealServerInfo `protobuf:"bytes,11,rep,name=proxy_realsvr_lst" json:"proxy_realsvr_lst,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*S2AAddListenerReq) Descriptor ¶
func (*S2AAddListenerReq) Descriptor() ([]byte, []int)
func (*S2AAddListenerReq) GetDelayLoop ¶
func (m *S2AAddListenerReq) GetDelayLoop() int32
func (*S2AAddListenerReq) GetListenerId ¶
func (m *S2AAddListenerReq) GetListenerId() string
func (*S2AAddListenerReq) GetListenerPort ¶
func (m *S2AAddListenerReq) GetListenerPort() int32
func (*S2AAddListenerReq) GetNetProtocolName ¶
func (m *S2AAddListenerReq) GetNetProtocolName() string
func (*S2AAddListenerReq) GetProxyId ¶
func (m *S2AAddListenerReq) GetProxyId() string
func (*S2AAddListenerReq) GetProxyRealsvrLst ¶
func (m *S2AAddListenerReq) GetProxyRealsvrLst() []*RealServerInfo
func (*S2AAddListenerReq) GetScheduler ¶
func (m *S2AAddListenerReq) GetScheduler() string
func (*S2AAddListenerReq) GetTaskId ¶
func (m *S2AAddListenerReq) GetTaskId() string
func (*S2AAddListenerReq) GetVrrpRouterid ¶
func (m *S2AAddListenerReq) GetVrrpRouterid() int32
func (*S2AAddListenerReq) ProtoMessage ¶
func (*S2AAddListenerReq) ProtoMessage()
func (*S2AAddListenerReq) Reset ¶
func (m *S2AAddListenerReq) Reset()
func (*S2AAddListenerReq) String ¶
func (m *S2AAddListenerReq) String() string
type S2ABindListenerWithRSReq ¶
type S2ABindListenerWithRSReq struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` RealserverLst []*RealServerInfo `protobuf:"bytes,7,rep,name=realserver_lst" json:"realserver_lst,omitempty"` XXX_unrecognized []byte `json:"-"` }
监听器和rs绑定----------------------------------------------------------------
func (*S2ABindListenerWithRSReq) Descriptor ¶
func (*S2ABindListenerWithRSReq) Descriptor() ([]byte, []int)
func (*S2ABindListenerWithRSReq) GetListenerId ¶
func (m *S2ABindListenerWithRSReq) GetListenerId() string
func (*S2ABindListenerWithRSReq) GetListenerPort ¶
func (m *S2ABindListenerWithRSReq) GetListenerPort() int32
func (*S2ABindListenerWithRSReq) GetNetProtocolName ¶
func (m *S2ABindListenerWithRSReq) GetNetProtocolName() string
func (*S2ABindListenerWithRSReq) GetProxyId ¶
func (m *S2ABindListenerWithRSReq) GetProxyId() string
func (*S2ABindListenerWithRSReq) GetRealserverLst ¶
func (m *S2ABindListenerWithRSReq) GetRealserverLst() []*RealServerInfo
func (*S2ABindListenerWithRSReq) GetTaskId ¶
func (m *S2ABindListenerWithRSReq) GetTaskId() string
func (*S2ABindListenerWithRSReq) GetVrrpRouterid ¶
func (m *S2ABindListenerWithRSReq) GetVrrpRouterid() int32
func (*S2ABindListenerWithRSReq) ProtoMessage ¶
func (*S2ABindListenerWithRSReq) ProtoMessage()
func (*S2ABindListenerWithRSReq) Reset ¶
func (m *S2ABindListenerWithRSReq) Reset()
func (*S2ABindListenerWithRSReq) String ¶
func (m *S2ABindListenerWithRSReq) String() string
type S2ADelListenerReq ¶
type S2ADelListenerReq struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` XXX_unrecognized []byte `json:"-"` }
删除监听器------------------------------------------------------------------
func (*S2ADelListenerReq) Descriptor ¶
func (*S2ADelListenerReq) Descriptor() ([]byte, []int)
func (*S2ADelListenerReq) GetListenerId ¶
func (m *S2ADelListenerReq) GetListenerId() string
func (*S2ADelListenerReq) GetListenerPort ¶
func (m *S2ADelListenerReq) GetListenerPort() int32
func (*S2ADelListenerReq) GetNetProtocolName ¶
func (m *S2ADelListenerReq) GetNetProtocolName() string
func (*S2ADelListenerReq) GetProxyId ¶
func (m *S2ADelListenerReq) GetProxyId() string
func (*S2ADelListenerReq) GetTaskId ¶
func (m *S2ADelListenerReq) GetTaskId() string
func (*S2ADelListenerReq) GetVrrpRouterid ¶
func (m *S2ADelListenerReq) GetVrrpRouterid() int32
func (*S2ADelListenerReq) ProtoMessage ¶
func (*S2ADelListenerReq) ProtoMessage()
func (*S2ADelListenerReq) Reset ¶
func (m *S2ADelListenerReq) Reset()
func (*S2ADelListenerReq) String ¶
func (m *S2ADelListenerReq) String() string
type S2AModListenerReq ¶
type S2AModListenerReq struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` Scheduler *string `protobuf:"bytes,7,req,name=scheduler" json:"scheduler,omitempty"` DelayLoop *int32 `protobuf:"varint,8,req,name=delay_loop" json:"delay_loop,omitempty"` XXX_unrecognized []byte `json:"-"` }
修改监听器设置----------------------------------------------------------------
func (*S2AModListenerReq) Descriptor ¶
func (*S2AModListenerReq) Descriptor() ([]byte, []int)
func (*S2AModListenerReq) GetDelayLoop ¶
func (m *S2AModListenerReq) GetDelayLoop() int32
func (*S2AModListenerReq) GetListenerId ¶
func (m *S2AModListenerReq) GetListenerId() string
func (*S2AModListenerReq) GetListenerPort ¶
func (m *S2AModListenerReq) GetListenerPort() int32
func (*S2AModListenerReq) GetNetProtocolName ¶
func (m *S2AModListenerReq) GetNetProtocolName() string
func (*S2AModListenerReq) GetProxyId ¶
func (m *S2AModListenerReq) GetProxyId() string
func (*S2AModListenerReq) GetScheduler ¶
func (m *S2AModListenerReq) GetScheduler() string
func (*S2AModListenerReq) GetTaskId ¶
func (m *S2AModListenerReq) GetTaskId() string
func (*S2AModListenerReq) GetVrrpRouterid ¶
func (m *S2AModListenerReq) GetVrrpRouterid() int32
func (*S2AModListenerReq) ProtoMessage ¶
func (*S2AModListenerReq) ProtoMessage()
func (*S2AModListenerReq) Reset ¶
func (m *S2AModListenerReq) Reset()
func (*S2AModListenerReq) String ¶
func (m *S2AModListenerReq) String() string
type S2ARegisterRes ¶
type S2ARegisterRes struct { Result *KPErrorCode `protobuf:"varint,1,req,name=result,enum=kp_proto.KPErrorCode" json:"result,omitempty"` ProxyId *string `protobuf:"bytes,2,req,name=proxy_id" json:"proxy_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` VrrpItfname *string `protobuf:"bytes,4,req,name=vrrp_itfname" json:"vrrp_itfname,omitempty"` KpLocalip *string `protobuf:"bytes,5,req,name=kp_localip" json:"kp_localip,omitempty"` KpVirtualIp *string `protobuf:"bytes,6,req,name=kp_virtual_ip" json:"kp_virtual_ip,omitempty"` DhKeyServer *string `protobuf:"bytes,7,req,name=dh_key_server" json:"dh_key_server,omitempty"` LinkNodeId *string `protobuf:"bytes,8,req,name=link_node_id" json:"link_node_id,omitempty"` LinkNodeType *LinkNodeType `protobuf:"varint,9,req,name=link_node_type,enum=kp_proto.LinkNodeType" json:"link_node_type,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*S2ARegisterRes) Descriptor ¶
func (*S2ARegisterRes) Descriptor() ([]byte, []int)
func (*S2ARegisterRes) GetDhKeyServer ¶
func (m *S2ARegisterRes) GetDhKeyServer() string
func (*S2ARegisterRes) GetKpLocalip ¶
func (m *S2ARegisterRes) GetKpLocalip() string
func (*S2ARegisterRes) GetKpVirtualIp ¶
func (m *S2ARegisterRes) GetKpVirtualIp() string
func (*S2ARegisterRes) GetLinkNodeId ¶
func (m *S2ARegisterRes) GetLinkNodeId() string
func (*S2ARegisterRes) GetLinkNodeType ¶
func (m *S2ARegisterRes) GetLinkNodeType() LinkNodeType
func (*S2ARegisterRes) GetProxyId ¶
func (m *S2ARegisterRes) GetProxyId() string
func (*S2ARegisterRes) GetResult ¶
func (m *S2ARegisterRes) GetResult() KPErrorCode
func (*S2ARegisterRes) GetVrrpItfname ¶
func (m *S2ARegisterRes) GetVrrpItfname() string
func (*S2ARegisterRes) GetVrrpRouterid ¶
func (m *S2ARegisterRes) GetVrrpRouterid() int32
func (*S2ARegisterRes) ProtoMessage ¶
func (*S2ARegisterRes) ProtoMessage()
func (*S2ARegisterRes) Reset ¶
func (m *S2ARegisterRes) Reset()
func (*S2ARegisterRes) String ¶
func (m *S2ARegisterRes) String() string
type S2AReloadReq ¶
type S2AReloadReq struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,2,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` TaskId *string `protobuf:"bytes,3,req,name=task_id" json:"task_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
reload--------------------------------------------------------------------
func (*S2AReloadReq) Descriptor ¶
func (*S2AReloadReq) Descriptor() ([]byte, []int)
func (*S2AReloadReq) GetProxyId ¶
func (m *S2AReloadReq) GetProxyId() string
func (*S2AReloadReq) GetTaskId ¶
func (m *S2AReloadReq) GetTaskId() string
func (*S2AReloadReq) GetVrrpRouterid ¶
func (m *S2AReloadReq) GetVrrpRouterid() int32
func (*S2AReloadReq) ProtoMessage ¶
func (*S2AReloadReq) ProtoMessage()
func (*S2AReloadReq) Reset ¶
func (m *S2AReloadReq) Reset()
func (*S2AReloadReq) String ¶
func (m *S2AReloadReq) String() string
type S2AUnBindListenerWithRsReq ¶
type S2AUnBindListenerWithRsReq struct { ProxyId *string `protobuf:"bytes,1,req,name=proxy_id" json:"proxy_id,omitempty"` TaskId *string `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"` VrrpRouterid *int32 `protobuf:"varint,3,req,name=vrrp_routerid" json:"vrrp_routerid,omitempty"` ListenerId *string `protobuf:"bytes,4,req,name=listener_id" json:"listener_id,omitempty"` NetProtocolName *string `protobuf:"bytes,5,req,name=net_protocol_name" json:"net_protocol_name,omitempty"` ListenerPort *int32 `protobuf:"varint,6,req,name=listener_port" json:"listener_port,omitempty"` RealserverLst []string `protobuf:"bytes,7,rep,name=realserver_lst" json:"realserver_lst,omitempty"` XXX_unrecognized []byte `json:"-"` }
监听器和rs解绑----------------------------------------------------------------
func (*S2AUnBindListenerWithRsReq) Descriptor ¶
func (*S2AUnBindListenerWithRsReq) Descriptor() ([]byte, []int)
func (*S2AUnBindListenerWithRsReq) GetListenerId ¶
func (m *S2AUnBindListenerWithRsReq) GetListenerId() string
func (*S2AUnBindListenerWithRsReq) GetListenerPort ¶
func (m *S2AUnBindListenerWithRsReq) GetListenerPort() int32
func (*S2AUnBindListenerWithRsReq) GetNetProtocolName ¶
func (m *S2AUnBindListenerWithRsReq) GetNetProtocolName() string
func (*S2AUnBindListenerWithRsReq) GetProxyId ¶
func (m *S2AUnBindListenerWithRsReq) GetProxyId() string
func (*S2AUnBindListenerWithRsReq) GetRealserverLst ¶
func (m *S2AUnBindListenerWithRsReq) GetRealserverLst() []string
func (*S2AUnBindListenerWithRsReq) GetTaskId ¶
func (m *S2AUnBindListenerWithRsReq) GetTaskId() string
func (*S2AUnBindListenerWithRsReq) GetVrrpRouterid ¶
func (m *S2AUnBindListenerWithRsReq) GetVrrpRouterid() int32
func (*S2AUnBindListenerWithRsReq) ProtoMessage ¶
func (*S2AUnBindListenerWithRsReq) ProtoMessage()
func (*S2AUnBindListenerWithRsReq) Reset ¶
func (m *S2AUnBindListenerWithRsReq) Reset()
func (*S2AUnBindListenerWithRsReq) String ¶
func (m *S2AUnBindListenerWithRsReq) String() string