distributed_match_engine

package
v1.2.5 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package distributed_match_engine is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	FLStatusFL_UNDEFINED uint64 = 1 << 0
	FLStatusFL_SUCCESS   uint64 = 1 << 1
	FLStatusFL_FAIL      uint64 = 1 << 2
)
View Source 
const (
	IDTypesID_UNDEFINED uint64 = 1 << 0
	IDTypesIMEI         uint64 = 1 << 1
	IDTypesMSISDN       uint64 = 1 << 2
	IDTypesIPADDR       uint64 = 1 << 3
)
View Source 
const (
	FindStatusFIND_UNKNOWN  uint64 = 1 << 0
	FindStatusFIND_FOUND    uint64 = 1 << 1
	FindStatusFIND_NOTFOUND uint64 = 1 << 2
)
View Source 
const (
	QosSessionResultQOS_NOT_ATTEMPTED   uint64 = 1 << 0
	QosSessionResultQOS_SESSION_CREATED uint64 = 1 << 1
	QosSessionResultQOS_SESSION_FAILED  uint64 = 1 << 2
)
View Source 
const (
	AIStatusAI_UNDEFINED uint64 = 1 << 0
	AIStatusAI_SUCCESS   uint64 = 1 << 1
	AIStatusAI_FAIL      uint64 = 1 << 2
)
View Source 
const (
	AOFStatusAOF_UNDEFINED uint64 = 1 << 0
	AOFStatusAOF_SUCCESS   uint64 = 1 << 1
	AOFStatusAOF_FAIL      uint64 = 1 << 2
)
View Source 
const (
	ClientEventTypeEVENT_UNKNOWN              uint64 = 1 << 0
	ClientEventTypeEVENT_INIT_CONNECTION      uint64 = 1 << 1
	ClientEventTypeEVENT_TERMINATE_CONNECTION uint64 = 1 << 2
	ClientEventTypeEVENT_LATENCY_SAMPLES      uint64 = 1 << 3
	ClientEventTypeEVENT_LOCATION_UPDATE      uint64 = 1 << 4
	ClientEventTypeEVENT_CUSTOM_EVENT         uint64 = 1 << 5
)
View Source 
const (
	ServerEventTypeEVENT_UNKNOWN              uint64 = 1 << 0
	ServerEventTypeEVENT_INIT_CONNECTION      uint64 = 1 << 1
	ServerEventTypeEVENT_LATENCY_REQUEST      uint64 = 1 << 2
	ServerEventTypeEVENT_LATENCY_PROCESSED    uint64 = 1 << 3
	ServerEventTypeEVENT_CLOUDLET_STATE       uint64 = 1 << 4
	ServerEventTypeEVENT_CLOUDLET_MAINTENANCE uint64 = 1 << 5
	ServerEventTypeEVENT_APPINST_HEALTH       uint64 = 1 << 6
	ServerEventTypeEVENT_CLOUDLET_UPDATE      uint64 = 1 << 7
	ServerEventTypeEVENT_ERROR                uint64 = 1 << 8
)
View Source 
const (
	LProtoL_PROTO_UNKNOWN uint64 = 1 << 0
	LProtoL_PROTO_TCP     uint64 = 1 << 1
	LProtoL_PROTO_UDP     uint64 = 1 << 2
)
View Source 
const (
	HealthCheckHEALTH_CHECK_UNKNOWN          uint64 = 1 << 0
	HealthCheckHEALTH_CHECK_ROOTLB_OFFLINE   uint64 = 1 << 1
	HealthCheckHEALTH_CHECK_SERVER_FAIL      uint64 = 1 << 2
	HealthCheckHEALTH_CHECK_OK               uint64 = 1 << 3
	HealthCheckHEALTH_CHECK_CLOUDLET_OFFLINE uint64 = 1 << 4
)
View Source 
const (
	CloudletStateCLOUDLET_STATE_UNKNOWN     uint64 = 1 << 0
	CloudletStateCLOUDLET_STATE_ERRORS      uint64 = 1 << 1
	CloudletStateCLOUDLET_STATE_READY       uint64 = 1 << 2
	CloudletStateCLOUDLET_STATE_OFFLINE     uint64 = 1 << 3
	CloudletStateCLOUDLET_STATE_NOT_PRESENT uint64 = 1 << 4
	CloudletStateCLOUDLET_STATE_INIT        uint64 = 1 << 5
	CloudletStateCLOUDLET_STATE_UPGRADE     uint64 = 1 << 6
	CloudletStateCLOUDLET_STATE_NEED_SYNC   uint64 = 1 << 7
)
View Source 
const (
	MaintenanceStateNORMAL_OPERATION              uint64 = 1 << 0
	MaintenanceStateMAINTENANCE_START             uint64 = 1 << 1
	MaintenanceStateFAILOVER_REQUESTED            uint64 = 1 << 2
	MaintenanceStateFAILOVER_DONE                 uint64 = 1 << 3
	MaintenanceStateFAILOVER_ERROR                uint64 = 1 << 4
	MaintenanceStateMAINTENANCE_START_NO_FAILOVER uint64 = 1 << 5
	MaintenanceStateCRM_REQUESTED                 uint64 = 1 << 6
	MaintenanceStateCRM_UNDER_MAINTENANCE         uint64 = 1 << 7
	MaintenanceStateCRM_ERROR                     uint64 = 1 << 8
	MaintenanceStateNORMAL_OPERATION_INIT         uint64 = 1 << 9
	MaintenanceStateUNDER_MAINTENANCE             uint64 = 1 << 10
)
View Source 
const (
	ReplyStatusRS_UNDEFINED uint64 = 1 << 0
	ReplyStatusRS_SUCCESS   uint64 = 1 << 1
	ReplyStatusRS_FAIL      uint64 = 1 << 2
)
View Source 
const (
	DlgAckDLG_ACK_EACH_MESSAGE    uint64 = 1 << 0
	DlgAckDLG_ASY_EVERY_N_MESSAGE uint64 = 1 << 1
	DlgAckDLG_NO_ACK              uint64 = 1 << 2
)
View Source 
const (
	DlgCommTypeDLG_UNDEFINED uint64 = 1 << 0
	DlgCommTypeDLG_SECURE    uint64 = 1 << 1
	DlgCommTypeDLG_OPEN      uint64 = 1 << 2
)
View Source 
const (
	TowerStatusTOWER_UNKNOWN                    uint64 = 1 << 0
	TowerStatusCONNECTED_TO_SPECIFIED_TOWER     uint64 = 1 << 1
	TowerStatusNOT_CONNECTED_TO_SPECIFIED_TOWER uint64 = 1 << 2
)
View Source 
const (
	GPSLocationStatusLOC_UNKNOWN                  uint64 = 1 << 0
	GPSLocationStatusLOC_VERIFIED                 uint64 = 1 << 1
	GPSLocationStatusLOC_MISMATCH_SAME_COUNTRY    uint64 = 1 << 2
	GPSLocationStatusLOC_MISMATCH_OTHER_COUNTRY   uint64 = 1 << 3
	GPSLocationStatusLOC_ROAMING_COUNTRY_MATCH    uint64 = 1 << 4
	GPSLocationStatusLOC_ROAMING_COUNTRY_MISMATCH uint64 = 1 << 5
	GPSLocationStatusLOC_ERROR_UNAUTHORIZED       uint64 = 1 << 6
	GPSLocationStatusLOC_ERROR_OTHER              uint64 = 1 << 7
)
View Source 
const (
	LocStatusLOC_UNKNOWN uint64 = 1 << 0
	LocStatusLOC_FOUND   uint64 = 1 << 1
	LocStatusLOC_DENIED  uint64 = 1 << 2
)
View Source 
const (
	QosSessionProfileQOS_NO_PRIORITY       uint64 = 1 << 0
	QosSessionProfileQOS_LOW_LATENCY       uint64 = 1 << 1
	QosSessionProfileQOS_THROUGHPUT_DOWN_S uint64 = 1 << 2
	QosSessionProfileQOS_THROUGHPUT_DOWN_M uint64 = 1 << 3
	QosSessionProfileQOS_THROUGHPUT_DOWN_L uint64 = 1 << 4
)
View Source 
const (
	QosSessionProtocolTCP uint64 = 1 << 0
	QosSessionProtocolUDP uint64 = 1 << 1
	QosSessionProtocolANY uint64 = 1 << 2
)
View Source 
const (
	DeleteStatusQDEL_UNKNOWN   uint64 = 1 << 0
	DeleteStatusQDEL_DELETED   uint64 = 1 << 1
	DeleteStatusQDEL_NOT_FOUND uint64 = 1 << 2
)

Variables

View Source 
var (
	ErrInvalidLengthAppClientPlatos        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAppClientPlatos          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAppClientPlatos = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthAppClient        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAppClient          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAppClient = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthAppcommon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAppcommon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAppcommon = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDynamicLocationGroup        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDynamicLocationGroup          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDynamicLocationGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLoc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLoc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLoc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLocverify        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLocverify          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLocverify = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQosPosition        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQosPosition          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQosPosition = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQos        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQos          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQos = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSession        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSession          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSession = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AIStatusCommonPrefix = "Ai"
View Source 
var AIStatusStrings = []string{
	"AI_UNDEFINED",
	"AI_SUCCESS",
	"AI_FAIL",
}
View Source 
var AOFStatusCommonPrefix = "Aof"
View Source 
var AOFStatusStrings = []string{
	"AOF_UNDEFINED",
	"AOF_SUCCESS",
	"AOF_FAIL",
}
View Source 
var AppInstListReply_AIStatus_CamelName = map[int32]string{

	0: "AiUndefined",

	1: "AiSuccess",

	2: "AiFail",
}
View Source 
var AppInstListReply_AIStatus_CamelValue = map[string]int32{
	"AiUndefined": 0,
	"AiSuccess":   1,
	"AiFail":      2,
}
View Source 
var AppInstListReply_AIStatus_name = map[int32]string{
	0: "AI_UNDEFINED",
	1: "AI_SUCCESS",
	2: "AI_FAIL",
}
View Source 
var AppInstListReply_AIStatus_value = map[string]int32{
	"AI_UNDEFINED": 0,
	"AI_SUCCESS":   1,
	"AI_FAIL":      2,
}
View Source 
var AppOfficialFqdnReply_AOFStatus_CamelName = map[int32]string{

	0: "AofUndefined",

	1: "AofSuccess",

	2: "AofFail",
}
View Source 
var AppOfficialFqdnReply_AOFStatus_CamelValue = map[string]int32{
	"AofUndefined": 0,
	"AofSuccess":   1,
	"AofFail":      2,
}
View Source 
var AppOfficialFqdnReply_AOFStatus_name = map[int32]string{
	0: "AOF_UNDEFINED",
	1: "AOF_SUCCESS",
	2: "AOF_FAIL",
}
View Source 
var AppOfficialFqdnReply_AOFStatus_value = map[string]int32{
	"AOF_UNDEFINED": 0,
	"AOF_SUCCESS":   1,
	"AOF_FAIL":      2,
}
View Source 
var ClientEdgeEvent_ClientEventType_CamelName = map[int32]string{

	0: "EventUnknown",

	1: "EventInitConnection",

	2: "EventTerminateConnection",

	3: "EventLatencySamples",

	4: "EventLocationUpdate",

	5: "EventCustomEvent",
}
View Source 
var ClientEdgeEvent_ClientEventType_CamelValue = map[string]int32{
	"EventUnknown":             0,
	"EventInitConnection":      1,
	"EventTerminateConnection": 2,
	"EventLatencySamples":      3,
	"EventLocationUpdate":      4,
	"EventCustomEvent":         5,
}
View Source 
var ClientEdgeEvent_ClientEventType_name = map[int32]string{
	0: "EVENT_UNKNOWN",
	1: "EVENT_INIT_CONNECTION",
	2: "EVENT_TERMINATE_CONNECTION",
	3: "EVENT_LATENCY_SAMPLES",
	4: "EVENT_LOCATION_UPDATE",
	5: "EVENT_CUSTOM_EVENT",
}
View Source 
var ClientEdgeEvent_ClientEventType_value = map[string]int32{
	"EVENT_UNKNOWN":              0,
	"EVENT_INIT_CONNECTION":      1,
	"EVENT_TERMINATE_CONNECTION": 2,
	"EVENT_LATENCY_SAMPLES":      3,
	"EVENT_LOCATION_UPDATE":      4,
	"EVENT_CUSTOM_EVENT":         5,
}
View Source 
var ClientEventTypeCommonPrefix = "Event"
View Source 
var ClientEventTypeStrings = []string{
	"EVENT_UNKNOWN",
	"EVENT_INIT_CONNECTION",
	"EVENT_TERMINATE_CONNECTION",
	"EVENT_LATENCY_SAMPLES",
	"EVENT_LOCATION_UPDATE",
	"EVENT_CUSTOM_EVENT",
}
View Source 
var CloudletStateCommonPrefix = "CloudletState"
View Source 
var CloudletStateStrings = []string{
	"CLOUDLET_STATE_UNKNOWN",
	"CLOUDLET_STATE_ERRORS",
	"CLOUDLET_STATE_READY",
	"CLOUDLET_STATE_OFFLINE",
	"CLOUDLET_STATE_NOT_PRESENT",
	"CLOUDLET_STATE_INIT",
	"CLOUDLET_STATE_UPGRADE",
	"CLOUDLET_STATE_NEED_SYNC",
}
View Source 
var CloudletState_CamelName = map[int32]string{

	0: "CloudletStateUnknown",

	1: "CloudletStateErrors",

	2: "CloudletStateReady",

	3: "CloudletStateOffline",

	4: "CloudletStateNotPresent",

	5: "CloudletStateInit",

	6: "CloudletStateUpgrade",

	7: "CloudletStateNeedSync",
}
View Source 
var CloudletState_CamelValue = map[string]int32{
	"CloudletStateUnknown":    0,
	"CloudletStateErrors":     1,
	"CloudletStateReady":      2,
	"CloudletStateOffline":    3,
	"CloudletStateNotPresent": 4,
	"CloudletStateInit":       5,
	"CloudletStateUpgrade":    6,
	"CloudletStateNeedSync":   7,
}
View Source 
var CloudletState_name = map[int32]string{
	0: "CLOUDLET_STATE_UNKNOWN",
	1: "CLOUDLET_STATE_ERRORS",
	2: "CLOUDLET_STATE_READY",
	3: "CLOUDLET_STATE_OFFLINE",
	4: "CLOUDLET_STATE_NOT_PRESENT",
	5: "CLOUDLET_STATE_INIT",
	6: "CLOUDLET_STATE_UPGRADE",
	7: "CLOUDLET_STATE_NEED_SYNC",
}
View Source 
var CloudletState_value = map[string]int32{
	"CLOUDLET_STATE_UNKNOWN":     0,
	"CLOUDLET_STATE_ERRORS":      1,
	"CLOUDLET_STATE_READY":       2,
	"CLOUDLET_STATE_OFFLINE":     3,
	"CLOUDLET_STATE_NOT_PRESENT": 4,
	"CLOUDLET_STATE_INIT":        5,
	"CLOUDLET_STATE_UPGRADE":     6,
	"CLOUDLET_STATE_NEED_SYNC":   7,
}
View Source 
var DeleteStatusCommonPrefix = "Qdel"
View Source 
var DeleteStatusStrings = []string{
	"QDEL_UNKNOWN",
	"QDEL_DELETED",
	"QDEL_NOT_FOUND",
}
View Source 
var DlgAckCommonPrefix = "Dlg"
View Source 
var DlgAckStrings = []string{
	"DLG_ACK_EACH_MESSAGE",
	"DLG_ASY_EVERY_N_MESSAGE",
	"DLG_NO_ACK",
}
View Source 
var DlgCommTypeCommonPrefix = "Dlg"
View Source 
var DlgCommTypeStrings = []string{
	"DLG_UNDEFINED",
	"DLG_SECURE",
	"DLG_OPEN",
}
View Source 
var DlgMessage_DlgAck_CamelName = map[int32]string{

	0: "DlgAckEachMessage",

	1: "DlgAsyEveryNMessage",

	2: "DlgNoAck",
}
View Source 
var DlgMessage_DlgAck_CamelValue = map[string]int32{
	"DlgAckEachMessage":   0,
	"DlgAsyEveryNMessage": 1,
	"DlgNoAck":            2,
}
View Source 
var DlgMessage_DlgAck_name = map[int32]string{
	0: "DLG_ACK_EACH_MESSAGE",
	1: "DLG_ASY_EVERY_N_MESSAGE",
	2: "DLG_NO_ACK",
}
View Source 
var DlgMessage_DlgAck_value = map[string]int32{
	"DLG_ACK_EACH_MESSAGE":    0,
	"DLG_ASY_EVERY_N_MESSAGE": 1,
	"DLG_NO_ACK":              2,
}
View Source 
var DynamicLocGroupRequest_DlgCommType_CamelName = map[int32]string{

	0: "DlgUndefined",

	1: "DlgSecure",

	2: "DlgOpen",
}
View Source 
var DynamicLocGroupRequest_DlgCommType_CamelValue = map[string]int32{
	"DlgUndefined": 0,
	"DlgSecure":    1,
	"DlgOpen":      2,
}
View Source 
var DynamicLocGroupRequest_DlgCommType_name = map[int32]string{
	0: "DLG_UNDEFINED",
	1: "DLG_SECURE",
	2: "DLG_OPEN",
}
View Source 
var DynamicLocGroupRequest_DlgCommType_value = map[string]int32{
	"DLG_UNDEFINED": 0,
	"DLG_SECURE":    1,
	"DLG_OPEN":      2,
}
View Source 
var FLStatusCommonPrefix = "Fl"
View Source 
var FLStatusStrings = []string{
	"FL_UNDEFINED",
	"FL_SUCCESS",
	"FL_FAIL",
}
View Source 
var FindCloudletReply_FindStatus_CamelName = map[int32]string{

	0: "FindUnknown",

	1: "FindFound",

	2: "FindNotfound",
}
View Source 
var FindCloudletReply_FindStatus_CamelValue = map[string]int32{
	"FindUnknown":  0,
	"FindFound":    1,
	"FindNotfound": 2,
}
View Source 
var FindCloudletReply_FindStatus_name = map[int32]string{
	0: "FIND_UNKNOWN",
	1: "FIND_FOUND",
	2: "FIND_NOTFOUND",
}
View Source 
var FindCloudletReply_FindStatus_value = map[string]int32{
	"FIND_UNKNOWN":  0,
	"FIND_FOUND":    1,
	"FIND_NOTFOUND": 2,
}
View Source 
var FindCloudletReply_QosSessionResult_CamelName = map[int32]string{

	0: "QosNotAttempted",

	1: "QosSessionCreated",

	2: "QosSessionFailed",
}
View Source 
var FindCloudletReply_QosSessionResult_CamelValue = map[string]int32{
	"QosNotAttempted":   0,
	"QosSessionCreated": 1,
	"QosSessionFailed":  2,
}
View Source 
var FindCloudletReply_QosSessionResult_name = map[int32]string{
	0: "QOS_NOT_ATTEMPTED",
	1: "QOS_SESSION_CREATED",
	2: "QOS_SESSION_FAILED",
}
View Source 
var FindCloudletReply_QosSessionResult_value = map[string]int32{
	"QOS_NOT_ATTEMPTED":   0,
	"QOS_SESSION_CREATED": 1,
	"QOS_SESSION_FAILED":  2,
}
View Source 
var FindStatusCommonPrefix = "Find"
View Source 
var FindStatusStrings = []string{
	"FIND_UNKNOWN",
	"FIND_FOUND",
	"FIND_NOTFOUND",
}
View Source 
var FqdnListReply_FLStatus_CamelName = map[int32]string{

	0: "FlUndefined",

	1: "FlSuccess",

	2: "FlFail",
}
View Source 
var FqdnListReply_FLStatus_CamelValue = map[string]int32{
	"FlUndefined": 0,
	"FlSuccess":   1,
	"FlFail":      2,
}
View Source 
var FqdnListReply_FLStatus_name = map[int32]string{
	0: "FL_UNDEFINED",
	1: "FL_SUCCESS",
	2: "FL_FAIL",
}
View Source 
var FqdnListReply_FLStatus_value = map[string]int32{
	"FL_UNDEFINED": 0,
	"FL_SUCCESS":   1,
	"FL_FAIL":      2,
}
View Source 
var GPSLocationStatusCommonPrefix = "Loc"
View Source 
var GPSLocationStatusStrings = []string{
	"LOC_UNKNOWN",
	"LOC_VERIFIED",
	"LOC_MISMATCH_SAME_COUNTRY",
	"LOC_MISMATCH_OTHER_COUNTRY",
	"LOC_ROAMING_COUNTRY_MATCH",
	"LOC_ROAMING_COUNTRY_MISMATCH",
	"LOC_ERROR_UNAUTHORIZED",
	"LOC_ERROR_OTHER",
}
View Source 
var GetLocationReply_LocStatus_CamelName = map[int32]string{

	0: "LocUnknown",

	1: "LocFound",

	2: "LocDenied",
}
View Source 
var GetLocationReply_LocStatus_CamelValue = map[string]int32{
	"LocUnknown": 0,
	"LocFound":   1,
	"LocDenied":  2,
}
View Source 
var GetLocationReply_LocStatus_name = map[int32]string{
	0: "LOC_UNKNOWN",
	1: "LOC_FOUND",
	2: "LOC_DENIED",
}
View Source 
var GetLocationReply_LocStatus_value = map[string]int32{
	"LOC_UNKNOWN": 0,
	"LOC_FOUND":   1,
	"LOC_DENIED":  2,
}
View Source 
var HealthCheckCommonPrefix = "HealthCheck"
View Source 
var HealthCheckStrings = []string{
	"HEALTH_CHECK_UNKNOWN",
	"HEALTH_CHECK_ROOTLB_OFFLINE",
	"HEALTH_CHECK_SERVER_FAIL",
	"HEALTH_CHECK_OK",
	"HEALTH_CHECK_CLOUDLET_OFFLINE",
}
View Source 
var HealthCheck_CamelName = map[int32]string{

	0: "HealthCheckUnknown",

	1: "HealthCheckRootlbOffline",

	2: "HealthCheckServerFail",

	3: "HealthCheckOk",

	4: "HealthCheckCloudletOffline",
}
View Source 
var HealthCheck_CamelValue = map[string]int32{
	"HealthCheckUnknown":         0,
	"HealthCheckRootlbOffline":   1,
	"HealthCheckServerFail":      2,
	"HealthCheckOk":              3,
	"HealthCheckCloudletOffline": 4,
}
View Source 
var HealthCheck_name = map[int32]string{
	0: "HEALTH_CHECK_UNKNOWN",
	1: "HEALTH_CHECK_ROOTLB_OFFLINE",
	2: "HEALTH_CHECK_SERVER_FAIL",
	3: "HEALTH_CHECK_OK",
	4: "HEALTH_CHECK_CLOUDLET_OFFLINE",
}
View Source 
var HealthCheck_value = map[string]int32{
	"HEALTH_CHECK_UNKNOWN":          0,
	"HEALTH_CHECK_ROOTLB_OFFLINE":   1,
	"HEALTH_CHECK_SERVER_FAIL":      2,
	"HEALTH_CHECK_OK":               3,
	"HEALTH_CHECK_CLOUDLET_OFFLINE": 4,
}
View Source 
var IDTypesStrings = []string{
	"ID_UNDEFINED",
	"IMEI",
	"MSISDN",
	"IPADDR",
}
View Source 
var IDTypes_CamelName = map[int32]string{

	0: "IdUndefined",

	1: "Imei",

	2: "Msisdn",

	3: "Ipaddr",
}
View Source 
var IDTypes_CamelValue = map[string]int32{
	"IdUndefined": 0,
	"Imei":        1,
	"Msisdn":      2,
	"Ipaddr":      3,
}
View Source 
var IDTypes_name = map[int32]string{
	0: "ID_UNDEFINED",
	1: "IMEI",
	2: "MSISDN",
	3: "IPADDR",
}
View Source 
var IDTypes_value = map[string]int32{
	"ID_UNDEFINED": 0,
	"IMEI":         1,
	"MSISDN":       2,
	"IPADDR":       3,
}
View Source 
var LProtoCommonPrefix = "LProto"
View Source 
var LProtoStrings = []string{
	"L_PROTO_UNKNOWN",
	"L_PROTO_TCP",
	"L_PROTO_UDP",
}
View Source 
var LProto_CamelName = map[int32]string{

	0: "LProtoUnknown",

	1: "LProtoTcp",

	2: "LProtoUdp",
}
View Source 
var LProto_CamelValue = map[string]int32{
	"LProtoUnknown": 0,
	"LProtoTcp":     1,
	"LProtoUdp":     2,
}
View Source 
var LProto_name = map[int32]string{
	0: "L_PROTO_UNKNOWN",
	1: "L_PROTO_TCP",
	2: "L_PROTO_UDP",
}
View Source 
var LProto_value = map[string]int32{
	"L_PROTO_UNKNOWN": 0,
	"L_PROTO_TCP":     1,
	"L_PROTO_UDP":     2,
}
View Source 
var LocStatusCommonPrefix = "Loc"
View Source 
var LocStatusStrings = []string{
	"LOC_UNKNOWN",
	"LOC_FOUND",
	"LOC_DENIED",
}
View Source 
var MaintenanceStateStrings = []string{
	"NORMAL_OPERATION",
	"MAINTENANCE_START",
	"FAILOVER_REQUESTED",
	"FAILOVER_DONE",
	"FAILOVER_ERROR",
	"MAINTENANCE_START_NO_FAILOVER",
	"CRM_REQUESTED",
	"CRM_UNDER_MAINTENANCE",
	"CRM_ERROR",
	"NORMAL_OPERATION_INIT",
	"UNDER_MAINTENANCE",
}
View Source 
var MaintenanceState_CamelName = map[int32]string{

	0: "NormalOperation",

	1: "MaintenanceStart",

	2: "FailoverRequested",

	3: "FailoverDone",

	4: "FailoverError",

	5: "MaintenanceStartNoFailover",

	6: "CrmRequested",

	7: "CrmUnderMaintenance",

	8: "CrmError",

	9: "NormalOperationInit",

	31: "UnderMaintenance",
}
View Source 
var MaintenanceState_CamelValue = map[string]int32{
	"NormalOperation":            0,
	"MaintenanceStart":           1,
	"FailoverRequested":          2,
	"FailoverDone":               3,
	"FailoverError":              4,
	"MaintenanceStartNoFailover": 5,
	"CrmRequested":               6,
	"CrmUnderMaintenance":        7,
	"CrmError":                   8,
	"NormalOperationInit":        9,
	"UnderMaintenance":           31,
}
View Source 
var MaintenanceState_name = map[int32]string{
	0:  "NORMAL_OPERATION",
	1:  "MAINTENANCE_START",
	2:  "FAILOVER_REQUESTED",
	3:  "FAILOVER_DONE",
	4:  "FAILOVER_ERROR",
	5:  "MAINTENANCE_START_NO_FAILOVER",
	6:  "CRM_REQUESTED",
	7:  "CRM_UNDER_MAINTENANCE",
	8:  "CRM_ERROR",
	9:  "NORMAL_OPERATION_INIT",
	31: "UNDER_MAINTENANCE",
}
View Source 
var MaintenanceState_value = map[string]int32{
	"NORMAL_OPERATION":              0,
	"MAINTENANCE_START":             1,
	"FAILOVER_REQUESTED":            2,
	"FAILOVER_DONE":                 3,
	"FAILOVER_ERROR":                4,
	"MAINTENANCE_START_NO_FAILOVER": 5,
	"CRM_REQUESTED":                 6,
	"CRM_UNDER_MAINTENANCE":         7,
	"CRM_ERROR":                     8,
	"NORMAL_OPERATION_INIT":         9,
	"UNDER_MAINTENANCE":             31,
}
View Source 
var QosPrioritySessionDeleteReply_DeleteStatus_CamelName = map[int32]string{

	0: "QdelUnknown",

	1: "QdelDeleted",

	2: "QdelNotFound",
}
View Source 
var QosPrioritySessionDeleteReply_DeleteStatus_CamelValue = map[string]int32{
	"QdelUnknown":  0,
	"QdelDeleted":  1,
	"QdelNotFound": 2,
}
View Source 
var QosPrioritySessionDeleteReply_DeleteStatus_name = map[int32]string{
	0: "QDEL_UNKNOWN",
	1: "QDEL_DELETED",
	2: "QDEL_NOT_FOUND",
}
View Source 
var QosPrioritySessionDeleteReply_DeleteStatus_value = map[string]int32{
	"QDEL_UNKNOWN":   0,
	"QDEL_DELETED":   1,
	"QDEL_NOT_FOUND": 2,
}
View Source 
var QosSessionProfileCommonPrefix = "Qos"
View Source 
var QosSessionProfileStrings = []string{
	"QOS_NO_PRIORITY",
	"QOS_LOW_LATENCY",
	"QOS_THROUGHPUT_DOWN_S",
	"QOS_THROUGHPUT_DOWN_M",
	"QOS_THROUGHPUT_DOWN_L",
}
View Source 
var QosSessionProfile_CamelName = map[int32]string{

	0: "QosNoPriority",

	1: "QosLowLatency",

	2: "QosThroughputDownS",

	3: "QosThroughputDownM",

	4: "QosThroughputDownL",
}
View Source 
var QosSessionProfile_CamelValue = map[string]int32{
	"QosNoPriority":      0,
	"QosLowLatency":      1,
	"QosThroughputDownS": 2,
	"QosThroughputDownM": 3,
	"QosThroughputDownL": 4,
}
View Source 
var QosSessionProfile_name = map[int32]string{
	0: "QOS_NO_PRIORITY",
	1: "QOS_LOW_LATENCY",
	2: "QOS_THROUGHPUT_DOWN_S",
	3: "QOS_THROUGHPUT_DOWN_M",
	4: "QOS_THROUGHPUT_DOWN_L",
}
View Source 
var QosSessionProfile_value = map[string]int32{
	"QOS_NO_PRIORITY":       0,
	"QOS_LOW_LATENCY":       1,
	"QOS_THROUGHPUT_DOWN_S": 2,
	"QOS_THROUGHPUT_DOWN_M": 3,
	"QOS_THROUGHPUT_DOWN_L": 4,
}
View Source 
var QosSessionProtocolStrings = []string{
	"TCP",
	"UDP",
	"ANY",
}
View Source 
var QosSessionProtocol_CamelName = map[int32]string{

	0: "Tcp",

	1: "Udp",

	2: "Any",
}
View Source 
var QosSessionProtocol_CamelValue = map[string]int32{
	"Tcp": 0,
	"Udp": 1,
	"Any": 2,
}
View Source 
var QosSessionProtocol_name = map[int32]string{
	0: "TCP",
	1: "UDP",
	2: "ANY",
}
View Source 
var QosSessionProtocol_value = map[string]int32{
	"TCP": 0,
	"UDP": 1,
	"ANY": 2,
}
View Source 
var QosSessionResultCommonPrefix = "Qos"
View Source 
var QosSessionResultStrings = []string{
	"QOS_NOT_ATTEMPTED",
	"QOS_SESSION_CREATED",
	"QOS_SESSION_FAILED",
}
View Source 
var ReplyStatusCommonPrefix = "Rs"
View Source 
var ReplyStatusStrings = []string{
	"RS_UNDEFINED",
	"RS_SUCCESS",
	"RS_FAIL",
}
View Source 
var ReplyStatus_CamelName = map[int32]string{

	0: "RsUndefined",

	1: "RsSuccess",

	2: "RsFail",
}
View Source 
var ReplyStatus_CamelValue = map[string]int32{
	"RsUndefined": 0,
	"RsSuccess":   1,
	"RsFail":      2,
}
View Source 
var ReplyStatus_name = map[int32]string{
	0: "RS_UNDEFINED",
	1: "RS_SUCCESS",
	2: "RS_FAIL",
}
View Source 
var ReplyStatus_value = map[string]int32{
	"RS_UNDEFINED": 0,
	"RS_SUCCESS":   1,
	"RS_FAIL":      2,
}
View Source 
var ServerEdgeEvent_ServerEventType_CamelName = map[int32]string{

	0: "EventUnknown",

	1: "EventInitConnection",

	2: "EventLatencyRequest",

	3: "EventLatencyProcessed",

	4: "EventCloudletState",

	5: "EventCloudletMaintenance",

	6: "EventAppinstHealth",

	7: "EventCloudletUpdate",

	8: "EventError",
}
View Source 
var ServerEdgeEvent_ServerEventType_CamelValue = map[string]int32{
	"EventUnknown":             0,
	"EventInitConnection":      1,
	"EventLatencyRequest":      2,
	"EventLatencyProcessed":    3,
	"EventCloudletState":       4,
	"EventCloudletMaintenance": 5,
	"EventAppinstHealth":       6,
	"EventCloudletUpdate":      7,
	"EventError":               8,
}
View Source 
var ServerEdgeEvent_ServerEventType_name = map[int32]string{
	0: "EVENT_UNKNOWN",
	1: "EVENT_INIT_CONNECTION",
	2: "EVENT_LATENCY_REQUEST",
	3: "EVENT_LATENCY_PROCESSED",
	4: "EVENT_CLOUDLET_STATE",
	5: "EVENT_CLOUDLET_MAINTENANCE",
	6: "EVENT_APPINST_HEALTH",
	7: "EVENT_CLOUDLET_UPDATE",
	8: "EVENT_ERROR",
}
View Source 
var ServerEdgeEvent_ServerEventType_value = map[string]int32{
	"EVENT_UNKNOWN":              0,
	"EVENT_INIT_CONNECTION":      1,
	"EVENT_LATENCY_REQUEST":      2,
	"EVENT_LATENCY_PROCESSED":    3,
	"EVENT_CLOUDLET_STATE":       4,
	"EVENT_CLOUDLET_MAINTENANCE": 5,
	"EVENT_APPINST_HEALTH":       6,
	"EVENT_CLOUDLET_UPDATE":      7,
	"EVENT_ERROR":                8,
}
View Source 
var ServerEventTypeCommonPrefix = "Event"
View Source 
var ServerEventTypeStrings = []string{
	"EVENT_UNKNOWN",
	"EVENT_INIT_CONNECTION",
	"EVENT_LATENCY_REQUEST",
	"EVENT_LATENCY_PROCESSED",
	"EVENT_CLOUDLET_STATE",
	"EVENT_CLOUDLET_MAINTENANCE",
	"EVENT_APPINST_HEALTH",
	"EVENT_CLOUDLET_UPDATE",
	"EVENT_ERROR",
}
View Source 
var ShowMethodNames = map[string]struct{}{}
View Source 
var TowerStatusStrings = []string{
	"TOWER_UNKNOWN",
	"CONNECTED_TO_SPECIFIED_TOWER",
	"NOT_CONNECTED_TO_SPECIFIED_TOWER",
}
View Source 
var VerifyLocationReply_GPSLocationStatus_CamelName = map[int32]string{

	0: "LocUnknown",

	1: "LocVerified",

	2: "LocMismatchSameCountry",

	3: "LocMismatchOtherCountry",

	4: "LocRoamingCountryMatch",

	5: "LocRoamingCountryMismatch",

	6: "LocErrorUnauthorized",

	7: "LocErrorOther",
}
View Source 
var VerifyLocationReply_GPSLocationStatus_CamelValue = map[string]int32{
	"LocUnknown":                0,
	"LocVerified":               1,
	"LocMismatchSameCountry":    2,
	"LocMismatchOtherCountry":   3,
	"LocRoamingCountryMatch":    4,
	"LocRoamingCountryMismatch": 5,
	"LocErrorUnauthorized":      6,
	"LocErrorOther":             7,
}
View Source 
var VerifyLocationReply_GPSLocationStatus_name = map[int32]string{
	0: "LOC_UNKNOWN",
	1: "LOC_VERIFIED",
	2: "LOC_MISMATCH_SAME_COUNTRY",
	3: "LOC_MISMATCH_OTHER_COUNTRY",
	4: "LOC_ROAMING_COUNTRY_MATCH",
	5: "LOC_ROAMING_COUNTRY_MISMATCH",
	6: "LOC_ERROR_UNAUTHORIZED",
	7: "LOC_ERROR_OTHER",
}
View Source 
var VerifyLocationReply_GPSLocationStatus_value = map[string]int32{
	"LOC_UNKNOWN":                  0,
	"LOC_VERIFIED":                 1,
	"LOC_MISMATCH_SAME_COUNTRY":    2,
	"LOC_MISMATCH_OTHER_COUNTRY":   3,
	"LOC_ROAMING_COUNTRY_MATCH":    4,
	"LOC_ROAMING_COUNTRY_MISMATCH": 5,
	"LOC_ERROR_UNAUTHORIZED":       6,
	"LOC_ERROR_OTHER":              7,
}
View Source 
var VerifyLocationReply_TowerStatus_CamelName = map[int32]string{

	0: "TowerUnknown",

	1: "ConnectedToSpecifiedTower",

	2: "NotConnectedToSpecifiedTower",
}
View Source 
var VerifyLocationReply_TowerStatus_CamelValue = map[string]int32{
	"TowerUnknown":                 0,
	"ConnectedToSpecifiedTower":    1,
	"NotConnectedToSpecifiedTower": 2,
}
View Source 
var VerifyLocationReply_TowerStatus_name = map[int32]string{
	0: "TOWER_UNKNOWN",
	1: "CONNECTED_TO_SPECIFIED_TOWER",
	2: "NOT_CONNECTED_TO_SPECIFIED_TOWER",
}
View Source 
var VerifyLocationReply_TowerStatus_value = map[string]int32{
	"TOWER_UNKNOWN":                    0,
	"CONNECTED_TO_SPECIFIED_TOWER":     1,
	"NOT_CONNECTED_TO_SPECIFIED_TOWER": 2,
}

Functions

func EnumDecodeHook 

func EnumDecodeHook(from, to reflect.Type, data interface{}) (interface{}, error)

DecodeHook for use with the mapstructure package. Allows decoding to handle protobuf enums that are represented as strings.

func GetEnumParseHelp 

func GetEnumParseHelp(t reflect.Type) (string, string, bool)

GetEnumParseHelp gets end-user specific messages for enum parse errors. It returns the enum type name, a help message with valid values, and a bool that indicates if a type was matched.

func IsShow 

func IsShow(cmd string) bool

func RegisterDynamicLocGroupApiHandler 

func RegisterDynamicLocGroupApiHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDynamicLocGroupApiHandler registers the http handlers for service DynamicLocGroupApi to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDynamicLocGroupApiHandlerClient 

func RegisterDynamicLocGroupApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DynamicLocGroupApiClient) error

RegisterDynamicLocGroupApiHandlerClient registers the http handlers for service DynamicLocGroupApi to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DynamicLocGroupApiClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DynamicLocGroupApiClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DynamicLocGroupApiClient" to call the correct interceptors.

func RegisterDynamicLocGroupApiHandlerFromEndpoint 

func RegisterDynamicLocGroupApiHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDynamicLocGroupApiHandlerFromEndpoint is same as RegisterDynamicLocGroupApiHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDynamicLocGroupApiHandlerServer 

func RegisterDynamicLocGroupApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DynamicLocGroupApiServer) error

RegisterDynamicLocGroupApiHandlerServer registers the http handlers for service DynamicLocGroupApi to "mux". UnaryRPC :call DynamicLocGroupApiServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDynamicLocGroupApiHandlerFromEndpoint instead.

func RegisterDynamicLocGroupApiServer 

func RegisterDynamicLocGroupApiServer(s *grpc.Server, srv DynamicLocGroupApiServer)

func RegisterLocationHandler 

func RegisterLocationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLocationHandler registers the http handlers for service Location to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLocationHandlerClient 

func RegisterLocationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LocationClient) error

RegisterLocationHandlerClient registers the http handlers for service Location to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LocationClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LocationClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LocationClient" to call the correct interceptors.

func RegisterLocationHandlerFromEndpoint 

func RegisterLocationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLocationHandlerFromEndpoint is same as RegisterLocationHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLocationHandlerServer 

func RegisterLocationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LocationServer) error

RegisterLocationHandlerServer registers the http handlers for service Location to "mux". UnaryRPC :call LocationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterLocationHandlerFromEndpoint instead.

func RegisterLocationServer 

func RegisterLocationServer(s *grpc.Server, srv LocationServer)

func RegisterMatchEngineApiHandler 

func RegisterMatchEngineApiHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMatchEngineApiHandler registers the http handlers for service MatchEngineApi to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMatchEngineApiHandlerClient 

func RegisterMatchEngineApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MatchEngineApiClient) error

RegisterMatchEngineApiHandlerClient registers the http handlers for service MatchEngineApi to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MatchEngineApiClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MatchEngineApiClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MatchEngineApiClient" to call the correct interceptors.

func RegisterMatchEngineApiHandlerFromEndpoint 

func RegisterMatchEngineApiHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMatchEngineApiHandlerFromEndpoint is same as RegisterMatchEngineApiHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMatchEngineApiHandlerServer 

func RegisterMatchEngineApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MatchEngineApiServer) error

RegisterMatchEngineApiHandlerServer registers the http handlers for service MatchEngineApi to "mux". UnaryRPC :call MatchEngineApiServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMatchEngineApiHandlerFromEndpoint instead.

func RegisterMatchEngineApiServer 

func RegisterMatchEngineApiServer(s *grpc.Server, srv MatchEngineApiServer)

func RegisterPlatformOSHandler 

func RegisterPlatformOSHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPlatformOSHandler registers the http handlers for service PlatformOS to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPlatformOSHandlerClient 

func RegisterPlatformOSHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PlatformOSClient) error

RegisterPlatformOSHandlerClient registers the http handlers for service PlatformOS to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PlatformOSClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PlatformOSClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PlatformOSClient" to call the correct interceptors.

func RegisterPlatformOSHandlerFromEndpoint 

func RegisterPlatformOSHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPlatformOSHandlerFromEndpoint is same as RegisterPlatformOSHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPlatformOSHandlerServer 

func RegisterPlatformOSHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PlatformOSServer) error

RegisterPlatformOSHandlerServer registers the http handlers for service PlatformOS to "mux". UnaryRPC :call PlatformOSServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPlatformOSHandlerFromEndpoint instead.

func RegisterPlatformOSServer 

func RegisterPlatformOSServer(s *grpc.Server, srv PlatformOSServer)

func RegisterQosPositionKpiHandler 

func RegisterQosPositionKpiHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQosPositionKpiHandler registers the http handlers for service QosPositionKpi to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQosPositionKpiHandlerClient 

func RegisterQosPositionKpiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QosPositionKpiClient) error

RegisterQosPositionKpiHandlerClient registers the http handlers for service QosPositionKpi to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QosPositionKpiClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QosPositionKpiClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QosPositionKpiClient" to call the correct interceptors.

func RegisterQosPositionKpiHandlerFromEndpoint 

func RegisterQosPositionKpiHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQosPositionKpiHandlerFromEndpoint is same as RegisterQosPositionKpiHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQosPositionKpiHandlerServer 

func RegisterQosPositionKpiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QosPositionKpiServer) error

RegisterQosPositionKpiHandlerServer registers the http handlers for service QosPositionKpi to "mux". UnaryRPC :call QosPositionKpiServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQosPositionKpiHandlerFromEndpoint instead.

func RegisterQosPositionKpiServer 

func RegisterQosPositionKpiServer(s *grpc.Server, srv QosPositionKpiServer)

func RegisterQualityOfServiceHandler 

func RegisterQualityOfServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQualityOfServiceHandler registers the http handlers for service QualityOfService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQualityOfServiceHandlerClient 

func RegisterQualityOfServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QualityOfServiceClient) error

RegisterQualityOfServiceHandlerClient registers the http handlers for service QualityOfService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QualityOfServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QualityOfServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QualityOfServiceClient" to call the correct interceptors.

func RegisterQualityOfServiceHandlerFromEndpoint 

func RegisterQualityOfServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQualityOfServiceHandlerFromEndpoint is same as RegisterQualityOfServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQualityOfServiceHandlerServer 

func RegisterQualityOfServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QualityOfServiceServer) error

RegisterQualityOfServiceHandlerServer registers the http handlers for service QualityOfService to "mux". UnaryRPC :call QualityOfServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQualityOfServiceHandlerFromEndpoint instead.

func RegisterQualityOfServiceServer 

func RegisterQualityOfServiceServer(s *grpc.Server, srv QualityOfServiceServer)

func RegisterSessionHandler 

func RegisterSessionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSessionHandler registers the http handlers for service Session to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSessionHandlerClient 

func RegisterSessionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SessionClient) error

RegisterSessionHandlerClient registers the http handlers for service Session to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SessionClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SessionClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SessionClient" to call the correct interceptors.

func RegisterSessionHandlerFromEndpoint 

func RegisterSessionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSessionHandlerFromEndpoint is same as RegisterSessionHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSessionHandlerServer 

func RegisterSessionHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SessionServer) error

RegisterSessionHandlerServer registers the http handlers for service Session to "mux". UnaryRPC :call SessionServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSessionHandlerFromEndpoint instead.

func RegisterSessionServer 

func RegisterSessionServer(s *grpc.Server, srv SessionServer)

func TimestampToTime 

func TimestampToTime(ts Timestamp) time.Time

Types

type AppFqdn 

type AppFqdn struct {
	// App  Name
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// App Version
	AppVers string `protobuf:"bytes,2,opt,name=app_vers,json=appVers,proto3" json:"app_vers,omitempty"`
	// App organization name
	OrgName string `protobuf:"bytes,3,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
	// App FQDN
	Fqdns []string `protobuf:"bytes,4,rep,name=fqdns,proto3" json:"fqdns,omitempty"`
	// _(optional)_ Android package name
	AndroidPackageName   string   `protobuf:"bytes,5,opt,name=android_package_name,json=androidPackageName,proto3" json:"android_package_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AppFqdn) AddFqdns 

func (m *AppFqdn) AddFqdns(vals ...string) int

func (*AppFqdn) ClearTagged 

func (s *AppFqdn) ClearTagged(tags map[string]struct{})

func (*AppFqdn) Clone 

func (m *AppFqdn) Clone() *AppFqdn

func (*AppFqdn) CopyInFields 

func (m *AppFqdn) CopyInFields(src *AppFqdn) int

func (*AppFqdn) DeepCopyIn 

func (m *AppFqdn) DeepCopyIn(src *AppFqdn)

func (*AppFqdn) Descriptor 

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

func (*AppFqdn) Marshal 

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

func (*AppFqdn) MarshalTo 

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

func (*AppFqdn) MarshalToSizedBuffer 

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

func (*AppFqdn) ProtoMessage 

func (*AppFqdn) ProtoMessage()

func (*AppFqdn) RemoveFqdns 

func (m *AppFqdn) RemoveFqdns(vals ...string) int

func (*AppFqdn) Reset 

func (m *AppFqdn) Reset()

func (*AppFqdn) Size 

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

func (*AppFqdn) String 

func (m *AppFqdn) String() string

func (*AppFqdn) Unmarshal 

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

func (*AppFqdn) ValidateEnums 

func (m *AppFqdn) ValidateEnums() error

Helper method to check that enums have valid values

func (*AppFqdn) XXX_DiscardUnknown 

func (m *AppFqdn) XXX_DiscardUnknown()

func (*AppFqdn) XXX_Marshal 

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

func (*AppFqdn) XXX_Merge 

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

func (*AppFqdn) XXX_Size 

func (m *AppFqdn) XXX_Size() int

func (*AppFqdn) XXX_Unmarshal 

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

type AppInstListReply 

type AppInstListReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver       uint32                    `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	Status    AppInstListReply_AIStatus `protobuf:"varint,2,opt,name=status,proto3,enum=distributed_match_engine.AppInstListReply_AIStatus" json:"status,omitempty"`
	Cloudlets []*CloudletLocation       `protobuf:"bytes,3,rep,name=cloudlets,proto3" json:"cloudlets,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AppInstListReply) AddCloudlets 

func (m *AppInstListReply) AddCloudlets(vals ...*CloudletLocation) int

func (*AppInstListReply) ClearTagged 

func (s *AppInstListReply) ClearTagged(tags map[string]struct{})

func (*AppInstListReply) Clone 

func (m *AppInstListReply) Clone() *AppInstListReply

func (*AppInstListReply) CopyInFields 

func (m *AppInstListReply) CopyInFields(src *AppInstListReply) int

func (*AppInstListReply) DeepCopyIn 

func (m *AppInstListReply) DeepCopyIn(src *AppInstListReply)

func (*AppInstListReply) Descriptor 

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

func (*AppInstListReply) Marshal 

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

func (*AppInstListReply) MarshalTo 

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

func (*AppInstListReply) MarshalToSizedBuffer 

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

func (*AppInstListReply) ProtoMessage 

func (*AppInstListReply) ProtoMessage()

func (*AppInstListReply) RemoveCloudlets 

func (m *AppInstListReply) RemoveCloudlets(vals ...*CloudletLocation) int

func (*AppInstListReply) Reset 

func (m *AppInstListReply) Reset()

func (*AppInstListReply) Size 

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

func (*AppInstListReply) String 

func (m *AppInstListReply) String() string

func (*AppInstListReply) Unmarshal 

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

func (*AppInstListReply) ValidateEnums 

func (m *AppInstListReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*AppInstListReply) XXX_DiscardUnknown 

func (m *AppInstListReply) XXX_DiscardUnknown()

func (*AppInstListReply) XXX_Marshal 

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

func (*AppInstListReply) XXX_Merge 

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

func (*AppInstListReply) XXX_Size 

func (m *AppInstListReply) XXX_Size() int

func (*AppInstListReply) XXX_Unmarshal 

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

type AppInstListReply_AIStatus 

type AppInstListReply_AIStatus int32

Status of the reply 

const (
	AppInstListReply_AI_UNDEFINED AppInstListReply_AIStatus = 0
	AppInstListReply_AI_SUCCESS   AppInstListReply_AIStatus = 1
	AppInstListReply_AI_FAIL      AppInstListReply_AIStatus = 2
)

func ParseAppInstListReply_AIStatus 

func ParseAppInstListReply_AIStatus(data interface{}) (AppInstListReply_AIStatus, error)

func (AppInstListReply_AIStatus) EnumDescriptor 

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

func (AppInstListReply_AIStatus) MarshalJSON 

func (e AppInstListReply_AIStatus) MarshalJSON() ([]byte, error)

func (AppInstListReply_AIStatus) MarshalYAML 

func (e AppInstListReply_AIStatus) MarshalYAML() (interface{}, error)

func (AppInstListReply_AIStatus) String 

func (x AppInstListReply_AIStatus) String() string

func (*AppInstListReply_AIStatus) UnmarshalJSON 

func (e *AppInstListReply_AIStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*AppInstListReply_AIStatus) UnmarshalYAML 

func (e *AppInstListReply_AIStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type AppInstListRequest 

type AppInstListRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	//
	// Carrier Name
	//
	// _(optional)_ By default, all SDKs will automatically fill in this parameter with the MCC+MNC of your current provider. Only override this parameter if you need to filter for a specific carrier on the DME. The DME will filter for App instances that are associated with the specified carrier.
	// If you wish to search for any App Instance on the DME regardless of carrier name, you can input “” to consider all carriers as “Any”.
	CarrierName string `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	// The GPS location of the user
	GpsLocation *Loc `protobuf:"bytes,4,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	// _(optional)_ Limit the number of results, defaults to 3
	Limit uint32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AppInstListRequest) ClearTagged 

func (s *AppInstListRequest) ClearTagged(tags map[string]struct{})

func (*AppInstListRequest) Clone 

func (m *AppInstListRequest) Clone() *AppInstListRequest

func (*AppInstListRequest) CopyInFields 

func (m *AppInstListRequest) CopyInFields(src *AppInstListRequest) int

func (*AppInstListRequest) DeepCopyIn 

func (m *AppInstListRequest) DeepCopyIn(src *AppInstListRequest)

func (*AppInstListRequest) Descriptor 

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

func (*AppInstListRequest) IsValidArgsForGetAppInstList 

func (m *AppInstListRequest) IsValidArgsForGetAppInstList() error

func (*AppInstListRequest) Marshal 

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

func (*AppInstListRequest) MarshalTo 

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

func (*AppInstListRequest) MarshalToSizedBuffer 

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

func (*AppInstListRequest) ProtoMessage 

func (*AppInstListRequest) ProtoMessage()

func (*AppInstListRequest) Reset 

func (m *AppInstListRequest) Reset()

func (*AppInstListRequest) Size 

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

func (*AppInstListRequest) String 

func (m *AppInstListRequest) String() string

func (*AppInstListRequest) Unmarshal 

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

func (*AppInstListRequest) ValidateEnums 

func (m *AppInstListRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*AppInstListRequest) XXX_DiscardUnknown 

func (m *AppInstListRequest) XXX_DiscardUnknown()

func (*AppInstListRequest) XXX_Marshal 

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

func (*AppInstListRequest) XXX_Merge 

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

func (*AppInstListRequest) XXX_Size 

func (m *AppInstListRequest) XXX_Size() int

func (*AppInstListRequest) XXX_Unmarshal 

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

type AppOfficialFqdnReply 

type AppOfficialFqdnReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// The FQDN to which the app is reached independent of the edge
	AppOfficialFqdn string `protobuf:"bytes,2,opt,name=app_official_fqdn,json=appOfficialFqdn,proto3" json:"app_official_fqdn,omitempty"`
	// Tokenized client data
	ClientToken string `protobuf:"bytes,3,opt,name=client_token,json=clientToken,proto3" json:"client_token,omitempty"`
	// Status of the reply
	Status AppOfficialFqdnReply_AOFStatus `` /* 127-byte string literal not displayed */
	// List of Service Endpoints for AppInst
	Ports []*AppPort `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AppOfficialFqdnReply) AddPorts 

func (m *AppOfficialFqdnReply) AddPorts(vals ...*AppPort) int

func (*AppOfficialFqdnReply) ClearTagged 

func (s *AppOfficialFqdnReply) ClearTagged(tags map[string]struct{})

func (*AppOfficialFqdnReply) Clone 

func (m *AppOfficialFqdnReply) Clone() *AppOfficialFqdnReply

func (*AppOfficialFqdnReply) CopyInFields 

func (m *AppOfficialFqdnReply) CopyInFields(src *AppOfficialFqdnReply) int

func (*AppOfficialFqdnReply) DeepCopyIn 

func (m *AppOfficialFqdnReply) DeepCopyIn(src *AppOfficialFqdnReply)

func (*AppOfficialFqdnReply) Descriptor 

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

func (*AppOfficialFqdnReply) Marshal 

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

func (*AppOfficialFqdnReply) MarshalTo 

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

func (*AppOfficialFqdnReply) MarshalToSizedBuffer 

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

func (*AppOfficialFqdnReply) ProtoMessage 

func (*AppOfficialFqdnReply) ProtoMessage()

func (*AppOfficialFqdnReply) RemovePorts 

func (m *AppOfficialFqdnReply) RemovePorts(vals ...*AppPort) int

func (*AppOfficialFqdnReply) Reset 

func (m *AppOfficialFqdnReply) Reset()

func (*AppOfficialFqdnReply) Size 

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

func (*AppOfficialFqdnReply) String 

func (m *AppOfficialFqdnReply) String() string

func (*AppOfficialFqdnReply) Unmarshal 

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

func (*AppOfficialFqdnReply) ValidateEnums 

func (m *AppOfficialFqdnReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*AppOfficialFqdnReply) XXX_DiscardUnknown 

func (m *AppOfficialFqdnReply) XXX_DiscardUnknown()

func (*AppOfficialFqdnReply) XXX_Marshal 

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

func (*AppOfficialFqdnReply) XXX_Merge 

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

func (*AppOfficialFqdnReply) XXX_Size 

func (m *AppOfficialFqdnReply) XXX_Size() int

func (*AppOfficialFqdnReply) XXX_Unmarshal 

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

type AppOfficialFqdnReply_AOFStatus 

type AppOfficialFqdnReply_AOFStatus int32
const (
	AppOfficialFqdnReply_AOF_UNDEFINED AppOfficialFqdnReply_AOFStatus = 0
	AppOfficialFqdnReply_AOF_SUCCESS   AppOfficialFqdnReply_AOFStatus = 1
	AppOfficialFqdnReply_AOF_FAIL      AppOfficialFqdnReply_AOFStatus = 2
)

func ParseAppOfficialFqdnReply_AOFStatus 

func ParseAppOfficialFqdnReply_AOFStatus(data interface{}) (AppOfficialFqdnReply_AOFStatus, error)

func (AppOfficialFqdnReply_AOFStatus) EnumDescriptor 

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

func (AppOfficialFqdnReply_AOFStatus) MarshalJSON 

func (e AppOfficialFqdnReply_AOFStatus) MarshalJSON() ([]byte, error)

func (AppOfficialFqdnReply_AOFStatus) MarshalYAML 

func (e AppOfficialFqdnReply_AOFStatus) MarshalYAML() (interface{}, error)

func (AppOfficialFqdnReply_AOFStatus) String 

func (x AppOfficialFqdnReply_AOFStatus) String() string

func (*AppOfficialFqdnReply_AOFStatus) UnmarshalJSON 

func (e *AppOfficialFqdnReply_AOFStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*AppOfficialFqdnReply_AOFStatus) UnmarshalYAML 

func (e *AppOfficialFqdnReply_AOFStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type AppOfficialFqdnRequest 

type AppOfficialFqdnRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// The GPS location of the user
	GpsLocation *Loc `protobuf:"bytes,3,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AppOfficialFqdnRequest) ClearTagged 

func (s *AppOfficialFqdnRequest) ClearTagged(tags map[string]struct{})

func (*AppOfficialFqdnRequest) Clone 

func (m *AppOfficialFqdnRequest) Clone() *AppOfficialFqdnRequest

func (*AppOfficialFqdnRequest) CopyInFields 

func (m *AppOfficialFqdnRequest) CopyInFields(src *AppOfficialFqdnRequest) int

func (*AppOfficialFqdnRequest) DeepCopyIn 

func (m *AppOfficialFqdnRequest) DeepCopyIn(src *AppOfficialFqdnRequest)

func (*AppOfficialFqdnRequest) Descriptor 

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

func (*AppOfficialFqdnRequest) IsValidArgsForGetAppOfficialFqdn 

func (m *AppOfficialFqdnRequest) IsValidArgsForGetAppOfficialFqdn() error

func (*AppOfficialFqdnRequest) Marshal 

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

func (*AppOfficialFqdnRequest) MarshalTo 

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

func (*AppOfficialFqdnRequest) MarshalToSizedBuffer 

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

func (*AppOfficialFqdnRequest) ProtoMessage 

func (*AppOfficialFqdnRequest) ProtoMessage()

func (*AppOfficialFqdnRequest) Reset 

func (m *AppOfficialFqdnRequest) Reset()

func (*AppOfficialFqdnRequest) Size 

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

func (*AppOfficialFqdnRequest) String 

func (m *AppOfficialFqdnRequest) String() string

func (*AppOfficialFqdnRequest) Unmarshal 

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

func (*AppOfficialFqdnRequest) ValidateEnums 

func (m *AppOfficialFqdnRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*AppOfficialFqdnRequest) XXX_DiscardUnknown 

func (m *AppOfficialFqdnRequest) XXX_DiscardUnknown()

func (*AppOfficialFqdnRequest) XXX_Marshal 

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

func (*AppOfficialFqdnRequest) XXX_Merge 

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

func (*AppOfficialFqdnRequest) XXX_Size 

func (m *AppOfficialFqdnRequest) XXX_Size() int

func (*AppOfficialFqdnRequest) XXX_Unmarshal 

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

type AppPort 

type AppPort struct {
	// TCP (L4) or UDP (L4) protocol
	Proto LProto `protobuf:"varint,1,opt,name=proto,proto3,enum=distributed_match_engine.LProto" json:"proto,omitempty"`
	// Container port
	InternalPort int32 `protobuf:"varint,2,opt,name=internal_port,json=internalPort,proto3" json:"internal_port,omitempty"`
	// Public facing port for TCP/UDP (may be mapped on shared LB reverse proxy)
	PublicPort int32 `protobuf:"varint,3,opt,name=public_port,json=publicPort,proto3" json:"public_port,omitempty"`
	// FQDN prefix to append to base FQDN in FindCloudlet response. May be empty.
	FqdnPrefix string `protobuf:"bytes,5,opt,name=fqdn_prefix,json=fqdnPrefix,proto3" json:"fqdn_prefix,omitempty"`
	// A non-zero end port indicates a port range from internal port to end port, inclusive.
	EndPort int32 `protobuf:"varint,6,opt,name=end_port,json=endPort,proto3" json:"end_port,omitempty"`
	// TLS termination for this port
	Tls bool `protobuf:"varint,7,opt,name=tls,proto3" json:"tls,omitempty"`
	// Use nginx proxy for this port if you really need a transparent proxy (udp only)
	Nginx bool `protobuf:"varint,8,opt,name=nginx,proto3" json:"nginx,omitempty"`
	// Maximum datagram size (udp only)
	MaxPktSize           int64    `protobuf:"varint,9,opt,name=max_pkt_size,json=maxPktSize,proto3" json:"max_pkt_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Application Port

AppPort describes an L4 public access port/path mapping. This is used to track external to internal mappings for access via a shared load balancer or reverse proxy.

func (*AppPort) ClearTagged 

func (s *AppPort) ClearTagged(tags map[string]struct{})

func (*AppPort) Clone 

func (m *AppPort) Clone() *AppPort

func (*AppPort) CopyInFields 

func (m *AppPort) CopyInFields(src *AppPort) int

func (*AppPort) DeepCopyIn 

func (m *AppPort) DeepCopyIn(src *AppPort)

func (*AppPort) Descriptor 

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

func (*AppPort) Marshal 

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

func (*AppPort) MarshalTo 

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

func (*AppPort) MarshalToSizedBuffer 

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

func (*AppPort) ProtoMessage 

func (*AppPort) ProtoMessage()

func (*AppPort) Reset 

func (m *AppPort) Reset()

func (*AppPort) Size 

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

func (*AppPort) String 

func (m *AppPort) String() string

func (*AppPort) Unmarshal 

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

func (*AppPort) ValidateEnums 

func (m *AppPort) ValidateEnums() error

Helper method to check that enums have valid values

func (*AppPort) XXX_DiscardUnknown 

func (m *AppPort) XXX_DiscardUnknown()

func (*AppPort) XXX_Marshal 

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

func (*AppPort) XXX_Merge 

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

func (*AppPort) XXX_Size 

func (m *AppPort) XXX_Size() int

func (*AppPort) XXX_Unmarshal 

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

type Appinstance 

type Appinstance struct {
	// App Instance Name
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// App Instance Version
	AppVers string `protobuf:"bytes,2,opt,name=app_vers,json=appVers,proto3" json:"app_vers,omitempty"`
	// App Instance FQDN
	Fqdn string `protobuf:"bytes,3,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	// ports to access app
	Ports []*AppPort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// App Organization Name
	OrgName string `protobuf:"bytes,5,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
	// Session Cookie for specific EdgeEvents for specific AppInst
	EdgeEventsCookie     string   `protobuf:"bytes,6,opt,name=edge_events_cookie,json=edgeEventsCookie,proto3" json:"edge_events_cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Appinstance) AddPorts 

func (m *Appinstance) AddPorts(vals ...*AppPort) int

func (*Appinstance) ClearTagged 

func (s *Appinstance) ClearTagged(tags map[string]struct{})

func (*Appinstance) Clone 

func (m *Appinstance) Clone() *Appinstance

func (*Appinstance) CopyInFields 

func (m *Appinstance) CopyInFields(src *Appinstance) int

func (*Appinstance) DeepCopyIn 

func (m *Appinstance) DeepCopyIn(src *Appinstance)

func (*Appinstance) Descriptor 

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

func (*Appinstance) Marshal 

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

func (*Appinstance) MarshalTo 

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

func (*Appinstance) MarshalToSizedBuffer 

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

func (*Appinstance) ProtoMessage 

func (*Appinstance) ProtoMessage()

func (*Appinstance) RemovePorts 

func (m *Appinstance) RemovePorts(vals ...*AppPort) int

func (*Appinstance) Reset 

func (m *Appinstance) Reset()

func (*Appinstance) Size 

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

func (*Appinstance) String 

func (m *Appinstance) String() string

func (*Appinstance) Unmarshal 

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

func (*Appinstance) ValidateEnums 

func (m *Appinstance) ValidateEnums() error

Helper method to check that enums have valid values

func (*Appinstance) XXX_DiscardUnknown 

func (m *Appinstance) XXX_DiscardUnknown()

func (*Appinstance) XXX_Marshal 

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

func (*Appinstance) XXX_Merge 

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

func (*Appinstance) XXX_Size 

func (m *Appinstance) XXX_Size() int

func (*Appinstance) XXX_Unmarshal 

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

type BandSelection 

type BandSelection struct {
	// Radio Access Technologies
	Rat2G                []string `protobuf:"bytes,1,rep,name=rat2g,proto3" json:"rat2g,omitempty"`
	Rat3G                []string `protobuf:"bytes,2,rep,name=rat3g,proto3" json:"rat3g,omitempty"`
	Rat4G                []string `protobuf:"bytes,3,rep,name=rat4g,proto3" json:"rat4g,omitempty"`
	Rat5G                []string `protobuf:"bytes,4,rep,name=rat5g,proto3" json:"rat5g,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

supported band values

func (*BandSelection) AddRat2G 

func (m *BandSelection) AddRat2G(vals ...string) int

func (*BandSelection) AddRat3G 

func (m *BandSelection) AddRat3G(vals ...string) int

func (*BandSelection) AddRat4G 

func (m *BandSelection) AddRat4G(vals ...string) int

func (*BandSelection) AddRat5G 

func (m *BandSelection) AddRat5G(vals ...string) int

func (*BandSelection) ClearTagged 

func (s *BandSelection) ClearTagged(tags map[string]struct{})

func (*BandSelection) Clone 

func (m *BandSelection) Clone() *BandSelection

func (*BandSelection) CopyInFields 

func (m *BandSelection) CopyInFields(src *BandSelection) int

func (*BandSelection) DeepCopyIn 

func (m *BandSelection) DeepCopyIn(src *BandSelection)

func (*BandSelection) Descriptor 

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

func (*BandSelection) Marshal 

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

func (*BandSelection) MarshalTo 

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

func (*BandSelection) MarshalToSizedBuffer 

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

func (*BandSelection) ProtoMessage 

func (*BandSelection) ProtoMessage()

func (*BandSelection) RemoveRat2G 

func (m *BandSelection) RemoveRat2G(vals ...string) int

func (*BandSelection) RemoveRat3G 

func (m *BandSelection) RemoveRat3G(vals ...string) int

func (*BandSelection) RemoveRat4G 

func (m *BandSelection) RemoveRat4G(vals ...string) int

func (*BandSelection) RemoveRat5G 

func (m *BandSelection) RemoveRat5G(vals ...string) int

func (*BandSelection) Reset 

func (m *BandSelection) Reset()

func (*BandSelection) Size 

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

func (*BandSelection) String 

func (m *BandSelection) String() string

func (*BandSelection) Unmarshal 

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

func (*BandSelection) ValidateEnums 

func (m *BandSelection) ValidateEnums() error

Helper method to check that enums have valid values

func (*BandSelection) XXX_DiscardUnknown 

func (m *BandSelection) XXX_DiscardUnknown()

func (*BandSelection) XXX_Marshal 

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

func (*BandSelection) XXX_Merge 

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

func (*BandSelection) XXX_Size 

func (m *BandSelection) XXX_Size() int

func (*BandSelection) XXX_Unmarshal 

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

type ClientEdgeEvent 

type ClientEdgeEvent struct {
	// Session Cookie from RegisterClientReply
	SessionCookie string `protobuf:"bytes,1,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// Session Cookie from FindCloudletReply
	EdgeEventsCookie string                          `protobuf:"bytes,2,opt,name=edge_events_cookie,json=edgeEventsCookie,proto3" json:"edge_events_cookie,omitempty"`
	EventType        ClientEdgeEvent_ClientEventType `` /* 151-byte string literal not displayed */
	// GPS Location info if event_type is EVENT_LOCATION_UPDATE or EVENT_LATENCY_SAMPLES
	GpsLocation *Loc `protobuf:"bytes,4,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	// Latency Samples if event_type is EVENT_LATENCY_SAMPLES or EVENT_CUSTOM_EVENT
	Samples []*Sample `protobuf:"bytes,5,rep,name=samples,proto3" json:"samples,omitempty"`
	//
	// _(optional)_ Static device information for latency and deviceinfo stats
	// Send on EVENT_INIT_CONNECTION to get this information in latency stats and deviceinfo stats
	DeviceInfoStatic *DeviceInfoStatic `protobuf:"bytes,6,opt,name=device_info_static,json=deviceInfoStatic,proto3" json:"device_info_static,omitempty"`
	//
	// _(optional)_ Dynamic device information for latency and deviceinfo stats
	// Send on EVENT_INIT_CONNECTION to get this information in first deviceinfo stat
	// Send on EVENT_LOCATION_UPDATE to get this information in dynamic deviceinfo stats
	// Send on EVENT_LATENCY_SAMPLES to get this information in latency stats
	DeviceInfoDynamic *DeviceInfoDynamic `protobuf:"bytes,7,opt,name=device_info_dynamic,json=deviceInfoDynamic,proto3" json:"device_info_dynamic,omitempty"`
	// Custom event specified by the application
	CustomEvent string `protobuf:"bytes,8,opt,name=custom_event,json=customEvent,proto3" json:"custom_event,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Messages from SDK to DME

func (*ClientEdgeEvent) AddSamples 

func (m *ClientEdgeEvent) AddSamples(vals ...*Sample) int

func (*ClientEdgeEvent) ClearTagged 

func (s *ClientEdgeEvent) ClearTagged(tags map[string]struct{})

func (*ClientEdgeEvent) Clone 

func (m *ClientEdgeEvent) Clone() *ClientEdgeEvent

func (*ClientEdgeEvent) CopyInFields 

func (m *ClientEdgeEvent) CopyInFields(src *ClientEdgeEvent) int

func (*ClientEdgeEvent) DeepCopyIn 

func (m *ClientEdgeEvent) DeepCopyIn(src *ClientEdgeEvent)

func (*ClientEdgeEvent) Descriptor 

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

func (*ClientEdgeEvent) IsValidArgsForStreamEdgeEvent 

func (m *ClientEdgeEvent) IsValidArgsForStreamEdgeEvent() error

func (*ClientEdgeEvent) Marshal 

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

func (*ClientEdgeEvent) MarshalTo 

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

func (*ClientEdgeEvent) MarshalToSizedBuffer 

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

func (*ClientEdgeEvent) ProtoMessage 

func (*ClientEdgeEvent) ProtoMessage()

func (*ClientEdgeEvent) RemoveSamples 

func (m *ClientEdgeEvent) RemoveSamples(vals ...*Sample) int

func (*ClientEdgeEvent) Reset 

func (m *ClientEdgeEvent) Reset()

func (*ClientEdgeEvent) Size 

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

func (*ClientEdgeEvent) String 

func (m *ClientEdgeEvent) String() string

func (*ClientEdgeEvent) Unmarshal 

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

func (*ClientEdgeEvent) ValidateEnums 

func (m *ClientEdgeEvent) ValidateEnums() error

Helper method to check that enums have valid values

func (*ClientEdgeEvent) XXX_DiscardUnknown 

func (m *ClientEdgeEvent) XXX_DiscardUnknown()

func (*ClientEdgeEvent) XXX_Marshal 

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

func (*ClientEdgeEvent) XXX_Merge 

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

func (*ClientEdgeEvent) XXX_Size 

func (m *ClientEdgeEvent) XXX_Size() int

func (*ClientEdgeEvent) XXX_Unmarshal 

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

type ClientEdgeEvent_ClientEventType 

type ClientEdgeEvent_ClientEventType int32
const (
	ClientEdgeEvent_EVENT_UNKNOWN              ClientEdgeEvent_ClientEventType = 0
	ClientEdgeEvent_EVENT_INIT_CONNECTION      ClientEdgeEvent_ClientEventType = 1
	ClientEdgeEvent_EVENT_TERMINATE_CONNECTION ClientEdgeEvent_ClientEventType = 2
	ClientEdgeEvent_EVENT_LATENCY_SAMPLES      ClientEdgeEvent_ClientEventType = 3
	ClientEdgeEvent_EVENT_LOCATION_UPDATE      ClientEdgeEvent_ClientEventType = 4
	ClientEdgeEvent_EVENT_CUSTOM_EVENT         ClientEdgeEvent_ClientEventType = 5
)

func ParseClientEdgeEvent_ClientEventType 

func ParseClientEdgeEvent_ClientEventType(data interface{}) (ClientEdgeEvent_ClientEventType, error)

func (ClientEdgeEvent_ClientEventType) EnumDescriptor 

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

func (ClientEdgeEvent_ClientEventType) MarshalJSON 

func (e ClientEdgeEvent_ClientEventType) MarshalJSON() ([]byte, error)

func (ClientEdgeEvent_ClientEventType) MarshalYAML 

func (e ClientEdgeEvent_ClientEventType) MarshalYAML() (interface{}, error)

func (ClientEdgeEvent_ClientEventType) String 

func (x ClientEdgeEvent_ClientEventType) String() string

func (*ClientEdgeEvent_ClientEventType) UnmarshalJSON 

func (e *ClientEdgeEvent_ClientEventType) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*ClientEdgeEvent_ClientEventType) UnmarshalYAML 

func (e *ClientEdgeEvent_ClientEventType) UnmarshalYAML(unmarshal func(interface{}) error) error

type CloudletLocation 

type CloudletLocation struct {
	// Cloudlet Organization Name
	CarrierName string `protobuf:"bytes,1,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	// Cloudlet Name
	CloudletName string `protobuf:"bytes,2,opt,name=cloudlet_name,json=cloudletName,proto3" json:"cloudlet_name,omitempty"`
	// The GPS Location of the cloudlet
	GpsLocation *Loc `protobuf:"bytes,3,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	// Distance of cloudlet vs loc in request
	Distance float64 `protobuf:"fixed64,4,opt,name=distance,proto3" json:"distance,omitempty"`
	// App instances
	Appinstances         []*Appinstance `protobuf:"bytes,5,rep,name=appinstances,proto3" json:"appinstances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CloudletLocation) AddAppinstances 

func (m *CloudletLocation) AddAppinstances(vals ...*Appinstance) int

func (*CloudletLocation) ClearTagged 

func (s *CloudletLocation) ClearTagged(tags map[string]struct{})

func (*CloudletLocation) Clone 

func (m *CloudletLocation) Clone() *CloudletLocation

func (*CloudletLocation) CopyInFields 

func (m *CloudletLocation) CopyInFields(src *CloudletLocation) int

func (*CloudletLocation) DeepCopyIn 

func (m *CloudletLocation) DeepCopyIn(src *CloudletLocation)

func (*CloudletLocation) Descriptor 

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

func (*CloudletLocation) Marshal 

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

func (*CloudletLocation) MarshalTo 

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

func (*CloudletLocation) MarshalToSizedBuffer 

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

func (*CloudletLocation) ProtoMessage 

func (*CloudletLocation) ProtoMessage()

func (*CloudletLocation) RemoveAppinstances 

func (m *CloudletLocation) RemoveAppinstances(vals ...*Appinstance) int

func (*CloudletLocation) Reset 

func (m *CloudletLocation) Reset()

func (*CloudletLocation) Size 

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

func (*CloudletLocation) String 

func (m *CloudletLocation) String() string

func (*CloudletLocation) Unmarshal 

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

func (*CloudletLocation) ValidateEnums 

func (m *CloudletLocation) ValidateEnums() error

Helper method to check that enums have valid values

func (*CloudletLocation) XXX_DiscardUnknown 

func (m *CloudletLocation) XXX_DiscardUnknown()

func (*CloudletLocation) XXX_Marshal 

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

func (*CloudletLocation) XXX_Merge 

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

func (*CloudletLocation) XXX_Size 

func (m *CloudletLocation) XXX_Size() int

func (*CloudletLocation) XXX_Unmarshal 

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

type CloudletState 

type CloudletState int32

CloudletState is the state of the Cloudlet. 

const (
	// Unknown
	CloudletState_CLOUDLET_STATE_UNKNOWN CloudletState = 0
	// Create/Delete/Update encountered errors (see Errors field of CloudletInfo)
	CloudletState_CLOUDLET_STATE_ERRORS CloudletState = 1
	// Cloudlet is created and ready
	CloudletState_CLOUDLET_STATE_READY CloudletState = 2
	// Cloudlet is offline (unreachable)
	CloudletState_CLOUDLET_STATE_OFFLINE CloudletState = 3
	// Cloudlet is not present
	CloudletState_CLOUDLET_STATE_NOT_PRESENT CloudletState = 4
	// Cloudlet is initializing
	CloudletState_CLOUDLET_STATE_INIT CloudletState = 5
	// Cloudlet is upgrading
	CloudletState_CLOUDLET_STATE_UPGRADE CloudletState = 6
	// Cloudlet needs data to synchronize
	CloudletState_CLOUDLET_STATE_NEED_SYNC CloudletState = 7
)

func ParseCloudletState 

func ParseCloudletState(data interface{}) (CloudletState, error)

func (CloudletState) EnumDescriptor 

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

func (CloudletState) MarshalJSON 

func (e CloudletState) MarshalJSON() ([]byte, error)

func (CloudletState) MarshalYAML 

func (e CloudletState) MarshalYAML() (interface{}, error)

func (CloudletState) String 

func (x CloudletState) String() string

func (*CloudletState) UnmarshalJSON 

func (e *CloudletState) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*CloudletState) UnmarshalYAML 

func (e *CloudletState) UnmarshalYAML(unmarshal func(interface{}) error) error

type DeviceInfoDynamic 

type DeviceInfoDynamic struct {
	// LTE, 5G, etc.
	DataNetworkType string `protobuf:"bytes,1,opt,name=data_network_type,json=dataNetworkType,proto3" json:"data_network_type,omitempty"`
	// Device signal strength
	SignalStrength uint64 `protobuf:"varint,2,opt,name=signal_strength,json=signalStrength,proto3" json:"signal_strength,omitempty"`
	// Carrier name (can be different from cloudlet org if using "")
	CarrierName          string   `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeviceInfoDynamic

func (*DeviceInfoDynamic) ClearTagged 

func (s *DeviceInfoDynamic) ClearTagged(tags map[string]struct{})

func (*DeviceInfoDynamic) Clone 

func (m *DeviceInfoDynamic) Clone() *DeviceInfoDynamic

func (*DeviceInfoDynamic) CopyInFields 

func (m *DeviceInfoDynamic) CopyInFields(src *DeviceInfoDynamic) int

func (*DeviceInfoDynamic) DeepCopyIn 

func (m *DeviceInfoDynamic) DeepCopyIn(src *DeviceInfoDynamic)

func (*DeviceInfoDynamic) Descriptor 

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

func (*DeviceInfoDynamic) Marshal 

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

func (*DeviceInfoDynamic) MarshalTo 

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

func (*DeviceInfoDynamic) MarshalToSizedBuffer 

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

func (*DeviceInfoDynamic) ProtoMessage 

func (*DeviceInfoDynamic) ProtoMessage()

func (*DeviceInfoDynamic) Reset 

func (m *DeviceInfoDynamic) Reset()

func (*DeviceInfoDynamic) Size 

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

func (*DeviceInfoDynamic) String 

func (m *DeviceInfoDynamic) String() string

func (*DeviceInfoDynamic) Unmarshal 

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

func (*DeviceInfoDynamic) ValidateEnums 

func (m *DeviceInfoDynamic) ValidateEnums() error

Helper method to check that enums have valid values

func (*DeviceInfoDynamic) XXX_DiscardUnknown 

func (m *DeviceInfoDynamic) XXX_DiscardUnknown()

func (*DeviceInfoDynamic) XXX_Marshal 

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

func (*DeviceInfoDynamic) XXX_Merge 

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

func (*DeviceInfoDynamic) XXX_Size 

func (m *DeviceInfoDynamic) XXX_Size() int

func (*DeviceInfoDynamic) XXX_Unmarshal 

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

type DeviceInfoStatic 

type DeviceInfoStatic struct {
	// Android or iOS
	DeviceOs string `protobuf:"bytes,1,opt,name=device_os,json=deviceOs,proto3" json:"device_os,omitempty"`
	// Device model
	DeviceModel          string   `protobuf:"bytes,2,opt,name=device_model,json=deviceModel,proto3" json:"device_model,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeviceInfoStatic

func (*DeviceInfoStatic) ClearTagged 

func (s *DeviceInfoStatic) ClearTagged(tags map[string]struct{})

func (*DeviceInfoStatic) Clone 

func (m *DeviceInfoStatic) Clone() *DeviceInfoStatic

func (*DeviceInfoStatic) CopyInFields 

func (m *DeviceInfoStatic) CopyInFields(src *DeviceInfoStatic) int

func (*DeviceInfoStatic) DeepCopyIn 

func (m *DeviceInfoStatic) DeepCopyIn(src *DeviceInfoStatic)

func (*DeviceInfoStatic) Descriptor 

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

func (*DeviceInfoStatic) Marshal 

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

func (*DeviceInfoStatic) MarshalTo 

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

func (*DeviceInfoStatic) MarshalToSizedBuffer 

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

func (*DeviceInfoStatic) ProtoMessage 

func (*DeviceInfoStatic) ProtoMessage()

func (*DeviceInfoStatic) Reset 

func (m *DeviceInfoStatic) Reset()

func (*DeviceInfoStatic) Size 

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

func (*DeviceInfoStatic) String 

func (m *DeviceInfoStatic) String() string

func (*DeviceInfoStatic) Unmarshal 

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

func (*DeviceInfoStatic) ValidateEnums 

func (m *DeviceInfoStatic) ValidateEnums() error

Helper method to check that enums have valid values

func (*DeviceInfoStatic) XXX_DiscardUnknown 

func (m *DeviceInfoStatic) XXX_DiscardUnknown()

func (*DeviceInfoStatic) XXX_Marshal 

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

func (*DeviceInfoStatic) XXX_Merge 

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

func (*DeviceInfoStatic) XXX_Size 

func (m *DeviceInfoStatic) XXX_Size() int

func (*DeviceInfoStatic) XXX_Unmarshal 

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

type DlgMessage 

type DlgMessage struct {
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Dynamic Location Group Id
	LgId uint64 `protobuf:"varint,2,opt,name=lg_id,json=lgId,proto3" json:"lg_id,omitempty"`
	// Group Cookie if secure
	GroupCookie string `protobuf:"bytes,3,opt,name=group_cookie,json=groupCookie,proto3" json:"group_cookie,omitempty"`
	// Message ID
	MessageId uint64            `protobuf:"varint,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	AckType   DlgMessage_DlgAck `` /* 131-byte string literal not displayed */
	// Message
	Message              string   `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DlgMessage) ClearTagged 

func (s *DlgMessage) ClearTagged(tags map[string]struct{})

func (*DlgMessage) Clone 

func (m *DlgMessage) Clone() *DlgMessage

func (*DlgMessage) CopyInFields 

func (m *DlgMessage) CopyInFields(src *DlgMessage) int

func (*DlgMessage) DeepCopyIn 

func (m *DlgMessage) DeepCopyIn(src *DlgMessage)

func (*DlgMessage) Descriptor 

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

func (*DlgMessage) IsValidArgsForSendToGroup 

func (m *DlgMessage) IsValidArgsForSendToGroup() error

func (*DlgMessage) Marshal 

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

func (*DlgMessage) MarshalTo 

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

func (*DlgMessage) MarshalToSizedBuffer 

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

func (*DlgMessage) ProtoMessage 

func (*DlgMessage) ProtoMessage()

func (*DlgMessage) Reset 

func (m *DlgMessage) Reset()

func (*DlgMessage) Size 

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

func (*DlgMessage) String 

func (m *DlgMessage) String() string

func (*DlgMessage) Unmarshal 

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

func (*DlgMessage) ValidateEnums 

func (m *DlgMessage) ValidateEnums() error

Helper method to check that enums have valid values

func (*DlgMessage) XXX_DiscardUnknown 

func (m *DlgMessage) XXX_DiscardUnknown()

func (*DlgMessage) XXX_Marshal 

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

func (*DlgMessage) XXX_Merge 

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

func (*DlgMessage) XXX_Size 

func (m *DlgMessage) XXX_Size() int

func (*DlgMessage) XXX_Unmarshal 

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

type DlgMessage_DlgAck 

type DlgMessage_DlgAck int32

Need acknowledgement 

const (
	DlgMessage_DLG_ACK_EACH_MESSAGE    DlgMessage_DlgAck = 0
	DlgMessage_DLG_ASY_EVERY_N_MESSAGE DlgMessage_DlgAck = 1
	DlgMessage_DLG_NO_ACK              DlgMessage_DlgAck = 2
)

func ParseDlgMessage_DlgAck 

func ParseDlgMessage_DlgAck(data interface{}) (DlgMessage_DlgAck, error)

func (DlgMessage_DlgAck) EnumDescriptor 

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

func (DlgMessage_DlgAck) MarshalJSON 

func (e DlgMessage_DlgAck) MarshalJSON() ([]byte, error)

func (DlgMessage_DlgAck) MarshalYAML 

func (e DlgMessage_DlgAck) MarshalYAML() (interface{}, error)

func (DlgMessage_DlgAck) String 

func (x DlgMessage_DlgAck) String() string

func (*DlgMessage_DlgAck) UnmarshalJSON 

func (e *DlgMessage_DlgAck) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*DlgMessage_DlgAck) UnmarshalYAML 

func (e *DlgMessage_DlgAck) UnmarshalYAML(unmarshal func(interface{}) error) error

type DlgReply 

type DlgReply struct {
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// AckId
	AckId uint64 `protobuf:"varint,2,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"`
	// Group Cookie for Secure comm
	GroupCookie          string   `protobuf:"bytes,3,opt,name=group_cookie,json=groupCookie,proto3" json:"group_cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DlgReply) ClearTagged 

func (s *DlgReply) ClearTagged(tags map[string]struct{})

func (*DlgReply) Clone 

func (m *DlgReply) Clone() *DlgReply

func (*DlgReply) CopyInFields 

func (m *DlgReply) CopyInFields(src *DlgReply) int

func (*DlgReply) DeepCopyIn 

func (m *DlgReply) DeepCopyIn(src *DlgReply)

func (*DlgReply) Descriptor 

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

func (*DlgReply) Marshal 

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

func (*DlgReply) MarshalTo 

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

func (*DlgReply) MarshalToSizedBuffer 

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

func (*DlgReply) ProtoMessage 

func (*DlgReply) ProtoMessage()

func (*DlgReply) Reset 

func (m *DlgReply) Reset()

func (*DlgReply) Size 

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

func (*DlgReply) String 

func (m *DlgReply) String() string

func (*DlgReply) Unmarshal 

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

func (*DlgReply) ValidateEnums 

func (m *DlgReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*DlgReply) XXX_DiscardUnknown 

func (m *DlgReply) XXX_DiscardUnknown()

func (*DlgReply) XXX_Marshal 

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

func (*DlgReply) XXX_Merge 

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

func (*DlgReply) XXX_Size 

func (m *DlgReply) XXX_Size() int

func (*DlgReply) XXX_Unmarshal 

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

type DynamicLocGroupApiClient 

type DynamicLocGroupApiClient interface {
	SendToGroup(ctx context.Context, in *DlgMessage, opts ...grpc.CallOption) (*DlgReply, error)
	AddUserToGroup(ctx context.Context, in *DynamicLocGroupRequest, opts ...grpc.CallOption) (*DynamicLocGroupReply, error)
}

DynamicLocGroupApiClient is the client API for DynamicLocGroupApi service.

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

func NewDynamicLocGroupApiClient 

func NewDynamicLocGroupApiClient(cc *grpc.ClientConn) DynamicLocGroupApiClient

type DynamicLocGroupApiServer 

type DynamicLocGroupApiServer interface {
	SendToGroup(context.Context, *DlgMessage) (*DlgReply, error)
	AddUserToGroup(context.Context, *DynamicLocGroupRequest) (*DynamicLocGroupReply, error)
}

DynamicLocGroupApiServer is the server API for DynamicLocGroupApi service.

type DynamicLocGroupReply 

type DynamicLocGroupReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Status of the reply
	Status ReplyStatus `protobuf:"varint,2,opt,name=status,proto3,enum=distributed_match_engine.ReplyStatus" json:"status,omitempty"`
	// Error Code based on Failure
	ErrorCode uint32 `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// Group Cookie for Secure Group Communication
	GroupCookie string `protobuf:"bytes,5,opt,name=group_cookie,json=groupCookie,proto3" json:"group_cookie,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DynamicLocGroupReply) ClearTagged 

func (s *DynamicLocGroupReply) ClearTagged(tags map[string]struct{})

func (*DynamicLocGroupReply) Clone 

func (m *DynamicLocGroupReply) Clone() *DynamicLocGroupReply

func (*DynamicLocGroupReply) CopyInFields 

func (m *DynamicLocGroupReply) CopyInFields(src *DynamicLocGroupReply) int

func (*DynamicLocGroupReply) DeepCopyIn 

func (m *DynamicLocGroupReply) DeepCopyIn(src *DynamicLocGroupReply)

func (*DynamicLocGroupReply) Descriptor 

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

func (*DynamicLocGroupReply) Marshal 

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

func (*DynamicLocGroupReply) MarshalTo 

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

func (*DynamicLocGroupReply) MarshalToSizedBuffer 

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

func (*DynamicLocGroupReply) ProtoMessage 

func (*DynamicLocGroupReply) ProtoMessage()

func (*DynamicLocGroupReply) Reset 

func (m *DynamicLocGroupReply) Reset()

func (*DynamicLocGroupReply) Size 

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

func (*DynamicLocGroupReply) String 

func (m *DynamicLocGroupReply) String() string

func (*DynamicLocGroupReply) Unmarshal 

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

func (*DynamicLocGroupReply) ValidateEnums 

func (m *DynamicLocGroupReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*DynamicLocGroupReply) XXX_DiscardUnknown 

func (m *DynamicLocGroupReply) XXX_DiscardUnknown()

func (*DynamicLocGroupReply) XXX_Marshal 

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

func (*DynamicLocGroupReply) XXX_Merge 

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

func (*DynamicLocGroupReply) XXX_Size 

func (m *DynamicLocGroupReply) XXX_Size() int

func (*DynamicLocGroupReply) XXX_Unmarshal 

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

type DynamicLocGroupRequest 

type DynamicLocGroupRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// Dynamic Location Group Id
	LgId     uint64                             `protobuf:"varint,3,opt,name=lg_id,json=lgId,proto3" json:"lg_id,omitempty"`
	CommType DynamicLocGroupRequest_DlgCommType `` /* 152-byte string literal not displayed */
	// Unused
	UserData string `protobuf:"bytes,12,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DynamicLocGroupRequest) ClearTagged 

func (s *DynamicLocGroupRequest) ClearTagged(tags map[string]struct{})

func (*DynamicLocGroupRequest) Clone 

func (m *DynamicLocGroupRequest) Clone() *DynamicLocGroupRequest

func (*DynamicLocGroupRequest) CopyInFields 

func (m *DynamicLocGroupRequest) CopyInFields(src *DynamicLocGroupRequest) int

func (*DynamicLocGroupRequest) DeepCopyIn 

func (m *DynamicLocGroupRequest) DeepCopyIn(src *DynamicLocGroupRequest)

func (*DynamicLocGroupRequest) Descriptor 

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

func (*DynamicLocGroupRequest) IsValidArgsForAddUserToGroup 

func (m *DynamicLocGroupRequest) IsValidArgsForAddUserToGroup() error

func (*DynamicLocGroupRequest) Marshal 

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

func (*DynamicLocGroupRequest) MarshalTo 

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

func (*DynamicLocGroupRequest) MarshalToSizedBuffer 

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

func (*DynamicLocGroupRequest) ProtoMessage 

func (*DynamicLocGroupRequest) ProtoMessage()

func (*DynamicLocGroupRequest) Reset 

func (m *DynamicLocGroupRequest) Reset()

func (*DynamicLocGroupRequest) Size 

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

func (*DynamicLocGroupRequest) String 

func (m *DynamicLocGroupRequest) String() string

func (*DynamicLocGroupRequest) Unmarshal 

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

func (*DynamicLocGroupRequest) ValidateEnums 

func (m *DynamicLocGroupRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*DynamicLocGroupRequest) XXX_DiscardUnknown 

func (m *DynamicLocGroupRequest) XXX_DiscardUnknown()

func (*DynamicLocGroupRequest) XXX_Marshal 

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

func (*DynamicLocGroupRequest) XXX_Merge 

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

func (*DynamicLocGroupRequest) XXX_Size 

func (m *DynamicLocGroupRequest) XXX_Size() int

func (*DynamicLocGroupRequest) XXX_Unmarshal 

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

type DynamicLocGroupRequest_DlgCommType 

type DynamicLocGroupRequest_DlgCommType int32

Use Secure communication or Open with the group 

const (
	DynamicLocGroupRequest_DLG_UNDEFINED DynamicLocGroupRequest_DlgCommType = 0
	DynamicLocGroupRequest_DLG_SECURE    DynamicLocGroupRequest_DlgCommType = 1
	DynamicLocGroupRequest_DLG_OPEN      DynamicLocGroupRequest_DlgCommType = 2
)

func ParseDynamicLocGroupRequest_DlgCommType 

func ParseDynamicLocGroupRequest_DlgCommType(data interface{}) (DynamicLocGroupRequest_DlgCommType, error)

func (DynamicLocGroupRequest_DlgCommType) EnumDescriptor 

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

func (DynamicLocGroupRequest_DlgCommType) MarshalJSON 

func (e DynamicLocGroupRequest_DlgCommType) MarshalJSON() ([]byte, error)

func (DynamicLocGroupRequest_DlgCommType) MarshalYAML 

func (e DynamicLocGroupRequest_DlgCommType) MarshalYAML() (interface{}, error)

func (DynamicLocGroupRequest_DlgCommType) String 

func (x DynamicLocGroupRequest_DlgCommType) String() string

func (*DynamicLocGroupRequest_DlgCommType) UnmarshalJSON 

func (e *DynamicLocGroupRequest_DlgCommType) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*DynamicLocGroupRequest_DlgCommType) UnmarshalYAML 

func (e *DynamicLocGroupRequest_DlgCommType) UnmarshalYAML(unmarshal func(interface{}) error) error

type FieldMap 

type FieldMap struct {
	// contains filtered or unexported fields
}

func MakeFieldMap 

func MakeFieldMap(fields []string) *FieldMap

func NewFieldMap 

func NewFieldMap(fields map[string]struct{}) *FieldMap

func (*FieldMap) Clear 

func (s *FieldMap) Clear(key string)

func (*FieldMap) Count 

func (s *FieldMap) Count() int

func (*FieldMap) Fields 

func (s *FieldMap) Fields() []string

func (*FieldMap) Has 

func (s *FieldMap) Has(key string) bool

Has checks if the key is set. Note that setting a parent key implies that all child keys are also set.

func (*FieldMap) HasOrHasChild 

func (s *FieldMap) HasOrHasChild(key string) bool

HasOrHasChild checks if the key, or any child of the key is set. Note that as with Has(), if a parent of the key is set, this returns true.

func (*FieldMap) Set 

func (s *FieldMap) Set(key string)

type FindCloudletReply 

type FindCloudletReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Status return
	Status FindCloudletReply_FindStatus `protobuf:"varint,2,opt,name=status,proto3,enum=distributed_match_engine.FindCloudletReply_FindStatus" json:"status,omitempty"`
	// Fully Qualified Domain Name of the Closest App instance
	Fqdn string `protobuf:"bytes,3,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	// List of Service Endpoints for AppInst
	Ports []*AppPort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// Location of the cloudlet
	CloudletLocation *Loc `protobuf:"bytes,5,opt,name=cloudlet_location,json=cloudletLocation,proto3" json:"cloudlet_location,omitempty"`
	// Session Cookie for specific EdgeEvents for specific AppInst
	EdgeEventsCookie string `protobuf:"bytes,6,opt,name=edge_events_cookie,json=edgeEventsCookie,proto3" json:"edge_events_cookie,omitempty"`
	// Result of QOS priority session creation attempt
	QosResult FindCloudletReply_QosSessionResult `` /* 154-byte string literal not displayed */
	// Error message in case of QOS_SESSION_FAILED
	QosErrorMsg string `protobuf:"bytes,8,opt,name=qos_error_msg,json=qosErrorMsg,proto3" json:"qos_error_msg,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FindCloudletReply) AddPorts 

func (m *FindCloudletReply) AddPorts(vals ...*AppPort) int

func (*FindCloudletReply) ClearTagged 

func (s *FindCloudletReply) ClearTagged(tags map[string]struct{})

func (*FindCloudletReply) Clone 

func (m *FindCloudletReply) Clone() *FindCloudletReply

func (*FindCloudletReply) CopyInFields 

func (m *FindCloudletReply) CopyInFields(src *FindCloudletReply) int

func (*FindCloudletReply) DeepCopyIn 

func (m *FindCloudletReply) DeepCopyIn(src *FindCloudletReply)

func (*FindCloudletReply) Descriptor 

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

func (*FindCloudletReply) Marshal 

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

func (*FindCloudletReply) MarshalTo 

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

func (*FindCloudletReply) MarshalToSizedBuffer 

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

func (*FindCloudletReply) ProtoMessage 

func (*FindCloudletReply) ProtoMessage()

func (*FindCloudletReply) RemovePorts 

func (m *FindCloudletReply) RemovePorts(vals ...*AppPort) int

func (*FindCloudletReply) Reset 

func (m *FindCloudletReply) Reset()

func (*FindCloudletReply) Size 

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

func (*FindCloudletReply) String 

func (m *FindCloudletReply) String() string

func (*FindCloudletReply) Unmarshal 

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

func (*FindCloudletReply) ValidateEnums 

func (m *FindCloudletReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*FindCloudletReply) XXX_DiscardUnknown 

func (m *FindCloudletReply) XXX_DiscardUnknown()

func (*FindCloudletReply) XXX_Marshal 

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

func (*FindCloudletReply) XXX_Merge 

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

func (*FindCloudletReply) XXX_Size 

func (m *FindCloudletReply) XXX_Size() int

func (*FindCloudletReply) XXX_Unmarshal 

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

type FindCloudletReply_FindStatus 

type FindCloudletReply_FindStatus int32
const (
	FindCloudletReply_FIND_UNKNOWN  FindCloudletReply_FindStatus = 0
	FindCloudletReply_FIND_FOUND    FindCloudletReply_FindStatus = 1
	FindCloudletReply_FIND_NOTFOUND FindCloudletReply_FindStatus = 2
)

func ParseFindCloudletReply_FindStatus 

func ParseFindCloudletReply_FindStatus(data interface{}) (FindCloudletReply_FindStatus, error)

func (FindCloudletReply_FindStatus) EnumDescriptor 

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

func (FindCloudletReply_FindStatus) MarshalJSON 

func (e FindCloudletReply_FindStatus) MarshalJSON() ([]byte, error)

func (FindCloudletReply_FindStatus) MarshalYAML 

func (e FindCloudletReply_FindStatus) MarshalYAML() (interface{}, error)

func (FindCloudletReply_FindStatus) String 

func (x FindCloudletReply_FindStatus) String() string

func (*FindCloudletReply_FindStatus) UnmarshalJSON 

func (e *FindCloudletReply_FindStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*FindCloudletReply_FindStatus) UnmarshalYAML 

func (e *FindCloudletReply_FindStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type FindCloudletReply_QosSessionResult 

type FindCloudletReply_QosSessionResult int32
const (
	FindCloudletReply_QOS_NOT_ATTEMPTED   FindCloudletReply_QosSessionResult = 0
	FindCloudletReply_QOS_SESSION_CREATED FindCloudletReply_QosSessionResult = 1
	FindCloudletReply_QOS_SESSION_FAILED  FindCloudletReply_QosSessionResult = 2
)

func ParseFindCloudletReply_QosSessionResult 

func ParseFindCloudletReply_QosSessionResult(data interface{}) (FindCloudletReply_QosSessionResult, error)

func (FindCloudletReply_QosSessionResult) EnumDescriptor 

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

func (FindCloudletReply_QosSessionResult) MarshalJSON 

func (e FindCloudletReply_QosSessionResult) MarshalJSON() ([]byte, error)

func (FindCloudletReply_QosSessionResult) MarshalYAML 

func (e FindCloudletReply_QosSessionResult) MarshalYAML() (interface{}, error)

func (FindCloudletReply_QosSessionResult) String 

func (x FindCloudletReply_QosSessionResult) String() string

func (*FindCloudletReply_QosSessionResult) UnmarshalJSON 

func (e *FindCloudletReply_QosSessionResult) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*FindCloudletReply_QosSessionResult) UnmarshalYAML 

func (e *FindCloudletReply_QosSessionResult) UnmarshalYAML(unmarshal func(interface{}) error) error

type FindCloudletRequest 

type FindCloudletRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// Session Cookie
	//
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	//
	// Carrier Name
	//
	// _(optional)_ By default, all SDKs will automatically fill in this parameter with the MCC+MNC of your current provider. Only override this parameter if you need to filter for a specific carrier on the DME. The DME will filter for App instances that are associated with the specified carrier.
	// If you wish to search for any App Instance on the DME regardless of carrier name, you can input “” to consider all carriers as “Any”.
	CarrierName string `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	//
	// GPS Location
	//
	// The GPS location of the user
	GpsLocation *Loc `protobuf:"bytes,4,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	//
	// Tags
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FindCloudletRequest) ClearTagged 

func (s *FindCloudletRequest) ClearTagged(tags map[string]struct{})

func (*FindCloudletRequest) Clone 

func (m *FindCloudletRequest) Clone() *FindCloudletRequest

func (*FindCloudletRequest) CopyInFields 

func (m *FindCloudletRequest) CopyInFields(src *FindCloudletRequest) int

func (*FindCloudletRequest) DeepCopyIn 

func (m *FindCloudletRequest) DeepCopyIn(src *FindCloudletRequest)

func (*FindCloudletRequest) Descriptor 

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

func (*FindCloudletRequest) IsValidArgsForFindCloudlet 

func (m *FindCloudletRequest) IsValidArgsForFindCloudlet() error

func (*FindCloudletRequest) Marshal 

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

func (*FindCloudletRequest) MarshalTo 

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

func (*FindCloudletRequest) MarshalToSizedBuffer 

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

func (*FindCloudletRequest) ProtoMessage 

func (*FindCloudletRequest) ProtoMessage()

func (*FindCloudletRequest) Reset 

func (m *FindCloudletRequest) Reset()

func (*FindCloudletRequest) Size 

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

func (*FindCloudletRequest) String 

func (m *FindCloudletRequest) String() string

func (*FindCloudletRequest) Unmarshal 

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

func (*FindCloudletRequest) ValidateEnums 

func (m *FindCloudletRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*FindCloudletRequest) XXX_DiscardUnknown 

func (m *FindCloudletRequest) XXX_DiscardUnknown()

func (*FindCloudletRequest) XXX_Marshal 

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

func (*FindCloudletRequest) XXX_Merge 

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

func (*FindCloudletRequest) XXX_Size 

func (m *FindCloudletRequest) XXX_Size() int

func (*FindCloudletRequest) XXX_Unmarshal 

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

type FqdnListReply 

type FqdnListReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver      uint32                 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	AppFqdns []*AppFqdn             `protobuf:"bytes,3,rep,name=app_fqdns,json=appFqdns,proto3" json:"app_fqdns,omitempty"`
	Status   FqdnListReply_FLStatus `protobuf:"varint,4,opt,name=status,proto3,enum=distributed_match_engine.FqdnListReply_FLStatus" json:"status,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FqdnListReply) AddAppFqdns 

func (m *FqdnListReply) AddAppFqdns(vals ...*AppFqdn) int

func (*FqdnListReply) ClearTagged 

func (s *FqdnListReply) ClearTagged(tags map[string]struct{})

func (*FqdnListReply) Clone 

func (m *FqdnListReply) Clone() *FqdnListReply

func (*FqdnListReply) CopyInFields 

func (m *FqdnListReply) CopyInFields(src *FqdnListReply) int

func (*FqdnListReply) DeepCopyIn 

func (m *FqdnListReply) DeepCopyIn(src *FqdnListReply)

func (*FqdnListReply) Descriptor 

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

func (*FqdnListReply) Marshal 

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

func (*FqdnListReply) MarshalTo 

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

func (*FqdnListReply) MarshalToSizedBuffer 

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

func (*FqdnListReply) ProtoMessage 

func (*FqdnListReply) ProtoMessage()

func (*FqdnListReply) RemoveAppFqdns 

func (m *FqdnListReply) RemoveAppFqdns(vals ...*AppFqdn) int

func (*FqdnListReply) Reset 

func (m *FqdnListReply) Reset()

func (*FqdnListReply) Size 

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

func (*FqdnListReply) String 

func (m *FqdnListReply) String() string

func (*FqdnListReply) Unmarshal 

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

func (*FqdnListReply) ValidateEnums 

func (m *FqdnListReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*FqdnListReply) XXX_DiscardUnknown 

func (m *FqdnListReply) XXX_DiscardUnknown()

func (*FqdnListReply) XXX_Marshal 

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

func (*FqdnListReply) XXX_Merge 

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

func (*FqdnListReply) XXX_Size 

func (m *FqdnListReply) XXX_Size() int

func (*FqdnListReply) XXX_Unmarshal 

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

type FqdnListReply_FLStatus 

type FqdnListReply_FLStatus int32

Status of the reply 

const (
	FqdnListReply_FL_UNDEFINED FqdnListReply_FLStatus = 0
	FqdnListReply_FL_SUCCESS   FqdnListReply_FLStatus = 1
	FqdnListReply_FL_FAIL      FqdnListReply_FLStatus = 2
)

func ParseFqdnListReply_FLStatus 

func ParseFqdnListReply_FLStatus(data interface{}) (FqdnListReply_FLStatus, error)

func (FqdnListReply_FLStatus) EnumDescriptor 

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

func (FqdnListReply_FLStatus) MarshalJSON 

func (e FqdnListReply_FLStatus) MarshalJSON() ([]byte, error)

func (FqdnListReply_FLStatus) MarshalYAML 

func (e FqdnListReply_FLStatus) MarshalYAML() (interface{}, error)

func (FqdnListReply_FLStatus) String 

func (x FqdnListReply_FLStatus) String() string

func (*FqdnListReply_FLStatus) UnmarshalJSON 

func (e *FqdnListReply_FLStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*FqdnListReply_FLStatus) UnmarshalYAML 

func (e *FqdnListReply_FLStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type FqdnListRequest 

type FqdnListRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FqdnListRequest) ClearTagged 

func (s *FqdnListRequest) ClearTagged(tags map[string]struct{})

func (*FqdnListRequest) Clone 

func (m *FqdnListRequest) Clone() *FqdnListRequest

func (*FqdnListRequest) CopyInFields 

func (m *FqdnListRequest) CopyInFields(src *FqdnListRequest) int

func (*FqdnListRequest) DeepCopyIn 

func (m *FqdnListRequest) DeepCopyIn(src *FqdnListRequest)

func (*FqdnListRequest) Descriptor 

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

func (*FqdnListRequest) IsValidArgsForGetFqdnList 

func (m *FqdnListRequest) IsValidArgsForGetFqdnList() error

func (*FqdnListRequest) Marshal 

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

func (*FqdnListRequest) MarshalTo 

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

func (*FqdnListRequest) MarshalToSizedBuffer 

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

func (*FqdnListRequest) ProtoMessage 

func (*FqdnListRequest) ProtoMessage()

func (*FqdnListRequest) Reset 

func (m *FqdnListRequest) Reset()

func (*FqdnListRequest) Size 

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

func (*FqdnListRequest) String 

func (m *FqdnListRequest) String() string

func (*FqdnListRequest) Unmarshal 

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

func (*FqdnListRequest) ValidateEnums 

func (m *FqdnListRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*FqdnListRequest) XXX_DiscardUnknown 

func (m *FqdnListRequest) XXX_DiscardUnknown()

func (*FqdnListRequest) XXX_Marshal 

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

func (*FqdnListRequest) XXX_Merge 

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

func (*FqdnListRequest) XXX_Size 

func (m *FqdnListRequest) XXX_Size() int

func (*FqdnListRequest) XXX_Unmarshal 

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

type GetLocationReply 

type GetLocationReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver    uint32                     `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	Status GetLocationReply_LocStatus `protobuf:"varint,2,opt,name=status,proto3,enum=distributed_match_engine.GetLocationReply_LocStatus" json:"status,omitempty"`
	// Unique carrier identification (typically MCC + MNC)
	CarrierName string `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	// The tower that the user is currently connected to
	Tower uint64 `protobuf:"varint,4,opt,name=tower,proto3" json:"tower,omitempty"`
	// The GPS location of the user
	NetworkLocation *Loc `protobuf:"bytes,5,opt,name=network_location,json=networkLocation,proto3" json:"network_location,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetLocationReply) ClearTagged 

func (s *GetLocationReply) ClearTagged(tags map[string]struct{})

func (*GetLocationReply) Clone 

func (m *GetLocationReply) Clone() *GetLocationReply

func (*GetLocationReply) CopyInFields 

func (m *GetLocationReply) CopyInFields(src *GetLocationReply) int

func (*GetLocationReply) DeepCopyIn 

func (m *GetLocationReply) DeepCopyIn(src *GetLocationReply)

func (*GetLocationReply) Descriptor 

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

func (*GetLocationReply) Marshal 

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

func (*GetLocationReply) MarshalTo 

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

func (*GetLocationReply) MarshalToSizedBuffer 

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

func (*GetLocationReply) ProtoMessage 

func (*GetLocationReply) ProtoMessage()

func (*GetLocationReply) Reset 

func (m *GetLocationReply) Reset()

func (*GetLocationReply) Size 

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

func (*GetLocationReply) String 

func (m *GetLocationReply) String() string

func (*GetLocationReply) Unmarshal 

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

func (*GetLocationReply) ValidateEnums 

func (m *GetLocationReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*GetLocationReply) XXX_DiscardUnknown 

func (m *GetLocationReply) XXX_DiscardUnknown()

func (*GetLocationReply) XXX_Marshal 

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

func (*GetLocationReply) XXX_Merge 

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

func (*GetLocationReply) XXX_Size 

func (m *GetLocationReply) XXX_Size() int

func (*GetLocationReply) XXX_Unmarshal 

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

type GetLocationReply_LocStatus 

type GetLocationReply_LocStatus int32

Status of the reply 

const (
	GetLocationReply_LOC_UNKNOWN GetLocationReply_LocStatus = 0
	GetLocationReply_LOC_FOUND   GetLocationReply_LocStatus = 1
	// The user does not allow his location to be tracked
	GetLocationReply_LOC_DENIED GetLocationReply_LocStatus = 2
)

func ParseGetLocationReply_LocStatus 

func ParseGetLocationReply_LocStatus(data interface{}) (GetLocationReply_LocStatus, error)

func (GetLocationReply_LocStatus) EnumDescriptor 

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

func (GetLocationReply_LocStatus) MarshalJSON 

func (e GetLocationReply_LocStatus) MarshalJSON() ([]byte, error)

func (GetLocationReply_LocStatus) MarshalYAML 

func (e GetLocationReply_LocStatus) MarshalYAML() (interface{}, error)

func (GetLocationReply_LocStatus) String 

func (x GetLocationReply_LocStatus) String() string

func (*GetLocationReply_LocStatus) UnmarshalJSON 

func (e *GetLocationReply_LocStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*GetLocationReply_LocStatus) UnmarshalYAML 

func (e *GetLocationReply_LocStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type GetLocationRequest 

type GetLocationRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// Unique carrier identification (typically MCC + MNC)
	CarrierName string `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetLocationRequest) ClearTagged 

func (s *GetLocationRequest) ClearTagged(tags map[string]struct{})

func (*GetLocationRequest) Clone 

func (m *GetLocationRequest) Clone() *GetLocationRequest

func (*GetLocationRequest) CopyInFields 

func (m *GetLocationRequest) CopyInFields(src *GetLocationRequest) int

func (*GetLocationRequest) DeepCopyIn 

func (m *GetLocationRequest) DeepCopyIn(src *GetLocationRequest)

func (*GetLocationRequest) Descriptor 

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

func (*GetLocationRequest) IsValidArgsForGetLocation 

func (m *GetLocationRequest) IsValidArgsForGetLocation() error

func (*GetLocationRequest) Marshal 

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

func (*GetLocationRequest) MarshalTo 

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

func (*GetLocationRequest) MarshalToSizedBuffer 

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

func (*GetLocationRequest) ProtoMessage 

func (*GetLocationRequest) ProtoMessage()

func (*GetLocationRequest) Reset 

func (m *GetLocationRequest) Reset()

func (*GetLocationRequest) Size 

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

func (*GetLocationRequest) String 

func (m *GetLocationRequest) String() string

func (*GetLocationRequest) Unmarshal 

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

func (*GetLocationRequest) ValidateEnums 

func (m *GetLocationRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*GetLocationRequest) XXX_DiscardUnknown 

func (m *GetLocationRequest) XXX_DiscardUnknown()

func (*GetLocationRequest) XXX_Marshal 

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

func (*GetLocationRequest) XXX_Merge 

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

func (*GetLocationRequest) XXX_Size 

func (m *GetLocationRequest) XXX_Size() int

func (*GetLocationRequest) XXX_Unmarshal 

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

type HealthCheck 

type HealthCheck int32

Health check status

Health check status gets set by external, or rootLB health check 

const (
	// Health Check is unknown
	HealthCheck_HEALTH_CHECK_UNKNOWN HealthCheck = 0
	// Health Check failure due to RootLB being offline
	HealthCheck_HEALTH_CHECK_ROOTLB_OFFLINE HealthCheck = 1
	// Health Check failure due to Backend server being unavailable
	HealthCheck_HEALTH_CHECK_SERVER_FAIL HealthCheck = 2
	// Health Check is ok
	HealthCheck_HEALTH_CHECK_OK HealthCheck = 3
	// Health Check failure due to Cloudlet Offline
	HealthCheck_HEALTH_CHECK_CLOUDLET_OFFLINE HealthCheck = 4
)

func ParseHealthCheck 

func ParseHealthCheck(data interface{}) (HealthCheck, error)

func (HealthCheck) EnumDescriptor 

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

func (HealthCheck) MarshalJSON 

func (e HealthCheck) MarshalJSON() ([]byte, error)

func (HealthCheck) MarshalYAML 

func (e HealthCheck) MarshalYAML() (interface{}, error)

func (HealthCheck) String 

func (x HealthCheck) String() string

func (*HealthCheck) UnmarshalJSON 

func (e *HealthCheck) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*HealthCheck) UnmarshalYAML 

func (e *HealthCheck) UnmarshalYAML(unmarshal func(interface{}) error) error

type IDTypes 

type IDTypes int32
const (
	IDTypes_ID_UNDEFINED IDTypes = 0
	IDTypes_IMEI         IDTypes = 1
	IDTypes_MSISDN       IDTypes = 2
	IDTypes_IPADDR       IDTypes = 3
)

func ParseIDTypes 

func ParseIDTypes(data interface{}) (IDTypes, error)

func (IDTypes) EnumDescriptor 

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

func (IDTypes) MarshalJSON 

func (e IDTypes) MarshalJSON() ([]byte, error)

func (IDTypes) MarshalYAML 

func (e IDTypes) MarshalYAML() (interface{}, error)

func (IDTypes) String 

func (x IDTypes) String() string

func (*IDTypes) UnmarshalJSON 

func (e *IDTypes) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*IDTypes) UnmarshalYAML 

func (e *IDTypes) UnmarshalYAML(unmarshal func(interface{}) error) error

type LProto 

type LProto int32

Layer4 Protocol

LProto indicates which protocol to use for accessing an application on a particular port. This is required by Kubernetes for port mapping.

0: `L_PROTO_UNKNOWN` 1: `L_PROTO_TCP` 2: `L_PROTO_UDP` 

const (
	// Unknown protocol
	LProto_L_PROTO_UNKNOWN LProto = 0
	// TCP (L4) protocol
	LProto_L_PROTO_TCP LProto = 1
	// UDP (L4) protocol
	LProto_L_PROTO_UDP LProto = 2
)

func ParseLProto 

func ParseLProto(data interface{}) (LProto, error)

func (LProto) EnumDescriptor 

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

func (LProto) MarshalJSON 

func (e LProto) MarshalJSON() ([]byte, error)

func (LProto) MarshalYAML 

func (e LProto) MarshalYAML() (interface{}, error)

func (LProto) String 

func (x LProto) String() string

func (*LProto) UnmarshalJSON 

func (e *LProto) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*LProto) UnmarshalYAML 

func (e *LProto) UnmarshalYAML(unmarshal func(interface{}) error) error

type Loc 

type Loc struct {
	// Latitude in WGS 84 coordinates
	Latitude float64 `protobuf:"fixed64,1,opt,name=latitude,proto3" json:"latitude,omitempty"`
	// Longitude in WGS 84 coordinates
	Longitude float64 `protobuf:"fixed64,2,opt,name=longitude,proto3" json:"longitude,omitempty"`
	// Horizontal accuracy (radius in meters)
	HorizontalAccuracy float64 `protobuf:"fixed64,3,opt,name=horizontal_accuracy,json=horizontalAccuracy,proto3" json:"horizontal_accuracy,omitempty"`
	// Vertical accuracy (meters)
	VerticalAccuracy float64 `protobuf:"fixed64,4,opt,name=vertical_accuracy,json=verticalAccuracy,proto3" json:"vertical_accuracy,omitempty"`
	// On android only lat and long are guaranteed to be supplied
	// Altitude in meters
	Altitude float64 `protobuf:"fixed64,5,opt,name=altitude,proto3" json:"altitude,omitempty"`
	// Course (IOS) / bearing (Android) (degrees east relative to true north)
	Course float64 `protobuf:"fixed64,6,opt,name=course,proto3" json:"course,omitempty"`
	// Speed (IOS) / velocity (Android) (meters/sec)
	Speed float64 `protobuf:"fixed64,7,opt,name=speed,proto3" json:"speed,omitempty"`
	// Timestamp
	Timestamp            *Timestamp `protobuf:"bytes,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

GPS Location

func (*Loc) ClearTagged 

func (s *Loc) ClearTagged(tags map[string]struct{})

func (*Loc) Clone 

func (m *Loc) Clone() *Loc

func (*Loc) CopyInFields 

func (m *Loc) CopyInFields(src *Loc) int

func (*Loc) DeepCopyIn 

func (m *Loc) DeepCopyIn(src *Loc)

func (*Loc) Descriptor 

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

func (*Loc) Marshal 

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

func (*Loc) MarshalTo 

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

func (*Loc) MarshalToSizedBuffer 

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

func (*Loc) ProtoMessage 

func (*Loc) ProtoMessage()

func (*Loc) Reset 

func (m *Loc) Reset()

func (*Loc) Size 

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

func (*Loc) String 

func (m *Loc) String() string

func (*Loc) Unmarshal 

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

func (*Loc) ValidateEnums 

func (m *Loc) ValidateEnums() error

Helper method to check that enums have valid values

func (*Loc) XXX_DiscardUnknown 

func (m *Loc) XXX_DiscardUnknown()

func (*Loc) XXX_Marshal 

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

func (*Loc) XXX_Merge 

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

func (*Loc) XXX_Size 

func (m *Loc) XXX_Size() int

func (*Loc) XXX_Unmarshal 

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

type LocationClient 

type LocationClient interface {
	//
	// VerifyLocation
	//
	// Verifies that the GPS coordinates accurately report the actual location of the device.
	VerifyLocation(ctx context.Context, in *VerifyLocationRequest, opts ...grpc.CallOption) (*VerifyLocationReply, error)
	GetLocation(ctx context.Context, in *GetLocationRequest, opts ...grpc.CallOption) (*GetLocationReply, error)
}

LocationClient is the client API for Location service.

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

func NewLocationClient 

func NewLocationClient(cc *grpc.ClientConn) LocationClient

type LocationServer 

type LocationServer interface {
	//
	// VerifyLocation
	//
	// Verifies that the GPS coordinates accurately report the actual location of the device.
	VerifyLocation(context.Context, *VerifyLocationRequest) (*VerifyLocationReply, error)
	GetLocation(context.Context, *GetLocationRequest) (*GetLocationReply, error)
}

LocationServer is the server API for Location service.

type MaintenanceState 

type MaintenanceState int32

Cloudlet Maintenance States

Maintenance allows for planned downtimes of Cloudlets. These states involve message exchanges between the Controller, the AutoProv service, and the CRM. Certain states are only set by certain actors. 

const (
	// Normal operational state
	MaintenanceState_NORMAL_OPERATION MaintenanceState = 0
	// Request start of maintenance
	MaintenanceState_MAINTENANCE_START MaintenanceState = 1
	// Trigger failover for any HA AppInsts
	MaintenanceState_FAILOVER_REQUESTED MaintenanceState = 2
	// Failover done
	MaintenanceState_FAILOVER_DONE MaintenanceState = 3
	// Some errors encountered during maintenance failover
	MaintenanceState_FAILOVER_ERROR MaintenanceState = 4
	// Request start of maintenance without AutoProv failover
	MaintenanceState_MAINTENANCE_START_NO_FAILOVER MaintenanceState = 5
	// Request CRM to transition to maintenance
	MaintenanceState_CRM_REQUESTED MaintenanceState = 6
	// CRM request done and under maintenance
	MaintenanceState_CRM_UNDER_MAINTENANCE MaintenanceState = 7
	// CRM failed to go into maintenance
	MaintenanceState_CRM_ERROR MaintenanceState = 8
	// Request CRM to transition to normal operation
	MaintenanceState_NORMAL_OPERATION_INIT MaintenanceState = 9
	// Under maintenance
	MaintenanceState_UNDER_MAINTENANCE MaintenanceState = 31
)

func ParseMaintenanceState 

func ParseMaintenanceState(data interface{}) (MaintenanceState, error)

func (MaintenanceState) EnumDescriptor 

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

func (MaintenanceState) MarshalJSON 

func (e MaintenanceState) MarshalJSON() ([]byte, error)

func (MaintenanceState) MarshalYAML 

func (e MaintenanceState) MarshalYAML() (interface{}, error)

func (MaintenanceState) String 

func (x MaintenanceState) String() string

func (*MaintenanceState) UnmarshalJSON 

func (e *MaintenanceState) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*MaintenanceState) UnmarshalYAML 

func (e *MaintenanceState) UnmarshalYAML(unmarshal func(interface{}) error) error

type MatchEngineApiClient 

type MatchEngineApiClient interface {
	//
	// FindCloudlet
	//
	// Find the best application service running on a cloudlet in the
	// Edge Cloud for the client to use, based on proximity and other policies.
	FindCloudlet(ctx context.Context, in *FindCloudletRequest, opts ...grpc.CallOption) (*FindCloudletReply, error)
	//
	// GetAppInstList
	//
	// Like FindCloudlet, but returns a short list of the best instances
	// instead of a single result, allowing the client to choose based on
	// its own criteria, or maintain several parallel connections to
	// different sites.
	GetAppInstList(ctx context.Context, in *AppInstListRequest, opts ...grpc.CallOption) (*AppInstListReply, error)
	//
	// GetAppOfficialFqdn
	//
	// Get an App's official FQDN if configured, which points to a default
	// public cloud instance of the application service that can be
	// used if no Edge Cloud application instances are available.
	GetAppOfficialFqdn(ctx context.Context, in *AppOfficialFqdnRequest, opts ...grpc.CallOption) (*AppOfficialFqdnReply, error)
	//
	// StreamEdgeEvent
	//
	// Streams events bidirectionally between device client and the
	// Edge Cloud platform for notifications.
	StreamEdgeEvent(ctx context.Context, opts ...grpc.CallOption) (MatchEngineApi_StreamEdgeEventClient, error)
}

MatchEngineApiClient is the client API for MatchEngineApi service.

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

func NewMatchEngineApiClient 

func NewMatchEngineApiClient(cc *grpc.ClientConn) MatchEngineApiClient

type MatchEngineApiServer 

type MatchEngineApiServer interface {
	//
	// FindCloudlet
	//
	// Find the best application service running on a cloudlet in the
	// Edge Cloud for the client to use, based on proximity and other policies.
	FindCloudlet(context.Context, *FindCloudletRequest) (*FindCloudletReply, error)
	//
	// GetAppInstList
	//
	// Like FindCloudlet, but returns a short list of the best instances
	// instead of a single result, allowing the client to choose based on
	// its own criteria, or maintain several parallel connections to
	// different sites.
	GetAppInstList(context.Context, *AppInstListRequest) (*AppInstListReply, error)
	//
	// GetAppOfficialFqdn
	//
	// Get an App's official FQDN if configured, which points to a default
	// public cloud instance of the application service that can be
	// used if no Edge Cloud application instances are available.
	GetAppOfficialFqdn(context.Context, *AppOfficialFqdnRequest) (*AppOfficialFqdnReply, error)
	//
	// StreamEdgeEvent
	//
	// Streams events bidirectionally between device client and the
	// Edge Cloud platform for notifications.
	StreamEdgeEvent(MatchEngineApi_StreamEdgeEventServer) error
}

MatchEngineApiServer is the server API for MatchEngineApi service.

type MatchEngineApi_StreamEdgeEventClient 

type MatchEngineApi_StreamEdgeEventClient interface {
	Send(*ClientEdgeEvent) error
	Recv() (*ServerEdgeEvent, error)
	grpc.ClientStream
}

type MatchEngineApi_StreamEdgeEventServer 

type MatchEngineApi_StreamEdgeEventServer interface {
	Send(*ServerEdgeEvent) error
	Recv() (*ClientEdgeEvent, error)
	grpc.ServerStream
}

type MatchOpt 

type MatchOpt func(*MatchOptions)

func MatchFilter 

func MatchFilter() MatchOpt

func MatchIgnoreBackend 

func MatchIgnoreBackend() MatchOpt

func MatchSortArrayedKeys 

func MatchSortArrayedKeys() MatchOpt

type MatchOptions 

type MatchOptions struct {
	// Filter will ignore 0 or nil fields on the passed in object
	Filter bool
	// IgnoreBackend will ignore fields that were marked backend in .proto
	IgnoreBackend bool
	// Sort repeated (arrays) of Key objects so matching does not
	// fail due to order.
	SortArrayedKeys bool
}

type PlatformFindCloudletRequest 

type PlatformFindCloudletRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// Session Cookie
	//
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	//
	// Carrier Name
	//
	// _(optional)_ By default, all SDKs will automatically fill in this parameter with the MCC+MNC of your current provider. Only override this parameter if you need to filter for a specific carrier on the DME. The DME will filter for App instances that are associated with the specified carrier.
	// If you wish to search for any app instance on the DME regardless of carrier name, you can input “” to consider all carriers as “Any”.
	CarrierName string `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	//
	// Client Token
	//
	// Token with encoded client data
	ClientToken string `protobuf:"bytes,4,opt,name=client_token,json=clientToken,proto3" json:"client_token,omitempty"`
	//
	// Tags
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PlatformFindCloudletRequest) ClearTagged 

func (s *PlatformFindCloudletRequest) ClearTagged(tags map[string]struct{})

func (*PlatformFindCloudletRequest) Clone 

func (m *PlatformFindCloudletRequest) Clone() *PlatformFindCloudletRequest

func (*PlatformFindCloudletRequest) CopyInFields 

func (m *PlatformFindCloudletRequest) CopyInFields(src *PlatformFindCloudletRequest) int

func (*PlatformFindCloudletRequest) DeepCopyIn 

func (m *PlatformFindCloudletRequest) DeepCopyIn(src *PlatformFindCloudletRequest)

func (*PlatformFindCloudletRequest) Descriptor 

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

func (*PlatformFindCloudletRequest) IsValidArgsForPlatformFindCloudlet 

func (m *PlatformFindCloudletRequest) IsValidArgsForPlatformFindCloudlet() error

func (*PlatformFindCloudletRequest) Marshal 

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

func (*PlatformFindCloudletRequest) MarshalTo 

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

func (*PlatformFindCloudletRequest) MarshalToSizedBuffer 

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

func (*PlatformFindCloudletRequest) ProtoMessage 

func (*PlatformFindCloudletRequest) ProtoMessage()

func (*PlatformFindCloudletRequest) Reset 

func (m *PlatformFindCloudletRequest) Reset()

func (*PlatformFindCloudletRequest) Size 

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

func (*PlatformFindCloudletRequest) String 

func (m *PlatformFindCloudletRequest) String() string

func (*PlatformFindCloudletRequest) Unmarshal 

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

func (*PlatformFindCloudletRequest) ValidateEnums 

func (m *PlatformFindCloudletRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*PlatformFindCloudletRequest) XXX_DiscardUnknown 

func (m *PlatformFindCloudletRequest) XXX_DiscardUnknown()

func (*PlatformFindCloudletRequest) XXX_Marshal 

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

func (*PlatformFindCloudletRequest) XXX_Merge 

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

func (*PlatformFindCloudletRequest) XXX_Size 

func (m *PlatformFindCloudletRequest) XXX_Size() int

func (*PlatformFindCloudletRequest) XXX_Unmarshal 

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

type PlatformOSClient 

type PlatformOSClient interface {
	//
	// PlatformFindCloudlet
	//
	// Similar to FindCloudlet, except uses a token for client data.
	// This API is only applicable for Platform Applications.
	PlatformFindCloudlet(ctx context.Context, in *PlatformFindCloudletRequest, opts ...grpc.CallOption) (*FindCloudletReply, error)
	GetFqdnList(ctx context.Context, in *FqdnListRequest, opts ...grpc.CallOption) (*FqdnListReply, error)
}

PlatformOSClient is the client API for PlatformOS service.

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

func NewPlatformOSClient 

func NewPlatformOSClient(cc *grpc.ClientConn) PlatformOSClient

type PlatformOSServer 

type PlatformOSServer interface {
	//
	// PlatformFindCloudlet
	//
	// Similar to FindCloudlet, except uses a token for client data.
	// This API is only applicable for Platform Applications.
	PlatformFindCloudlet(context.Context, *PlatformFindCloudletRequest) (*FindCloudletReply, error)
	GetFqdnList(context.Context, *FqdnListRequest) (*FqdnListReply, error)
}

PlatformOSServer is the server API for PlatformOS service.

type QosPosition 

type QosPosition struct {
	// as set by the client, must be unique within QosRequest
	Positionid int64 `protobuf:"varint,1,opt,name=positionid,proto3" json:"positionid,omitempty"`
	//location
	GpsLocation          *Loc     `protobuf:"bytes,2,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QosPosition) ClearTagged 

func (s *QosPosition) ClearTagged(tags map[string]struct{})

func (*QosPosition) Clone 

func (m *QosPosition) Clone() *QosPosition

func (*QosPosition) CopyInFields 

func (m *QosPosition) CopyInFields(src *QosPosition) int

func (*QosPosition) DeepCopyIn 

func (m *QosPosition) DeepCopyIn(src *QosPosition)

func (*QosPosition) Descriptor 

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

func (*QosPosition) Marshal 

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

func (*QosPosition) MarshalTo 

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

func (*QosPosition) MarshalToSizedBuffer 

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

func (*QosPosition) ProtoMessage 

func (*QosPosition) ProtoMessage()

func (*QosPosition) Reset 

func (m *QosPosition) Reset()

func (*QosPosition) Size 

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

func (*QosPosition) String 

func (m *QosPosition) String() string

func (*QosPosition) Unmarshal 

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

func (*QosPosition) ValidateEnums 

func (m *QosPosition) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPosition) XXX_DiscardUnknown 

func (m *QosPosition) XXX_DiscardUnknown()

func (*QosPosition) XXX_Marshal 

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

func (*QosPosition) XXX_Merge 

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

func (*QosPosition) XXX_Size 

func (m *QosPosition) XXX_Size() int

func (*QosPosition) XXX_Unmarshal 

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

type QosPositionKpiClient 

type QosPositionKpiClient interface {
	GetQosPositionKpi(ctx context.Context, in *QosPositionRequest, opts ...grpc.CallOption) (QosPositionKpi_GetQosPositionKpiClient, error)
}

QosPositionKpiClient is the client API for QosPositionKpi service.

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

func NewQosPositionKpiClient 

func NewQosPositionKpiClient(cc *grpc.ClientConn) QosPositionKpiClient

type QosPositionKpiReply 

type QosPositionKpiReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Status of the reply
	Status ReplyStatus `protobuf:"varint,2,opt,name=status,proto3,enum=distributed_match_engine.ReplyStatus" json:"status,omitempty"`
	// kpi details
	PositionResults []*QosPositionKpiResult `protobuf:"bytes,3,rep,name=position_results,json=positionResults,proto3" json:"position_results,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*QosPositionKpiReply) AddPositionResults 

func (m *QosPositionKpiReply) AddPositionResults(vals ...*QosPositionKpiResult) int

func (*QosPositionKpiReply) ClearTagged 

func (s *QosPositionKpiReply) ClearTagged(tags map[string]struct{})

func (*QosPositionKpiReply) Clone 

func (m *QosPositionKpiReply) Clone() *QosPositionKpiReply

func (*QosPositionKpiReply) CopyInFields 

func (m *QosPositionKpiReply) CopyInFields(src *QosPositionKpiReply) int

func (*QosPositionKpiReply) DeepCopyIn 

func (m *QosPositionKpiReply) DeepCopyIn(src *QosPositionKpiReply)

func (*QosPositionKpiReply) Descriptor 

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

func (*QosPositionKpiReply) Marshal 

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

func (*QosPositionKpiReply) MarshalTo 

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

func (*QosPositionKpiReply) MarshalToSizedBuffer 

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

func (*QosPositionKpiReply) ProtoMessage 

func (*QosPositionKpiReply) ProtoMessage()

func (*QosPositionKpiReply) RemovePositionResults 

func (m *QosPositionKpiReply) RemovePositionResults(vals ...*QosPositionKpiResult) int

func (*QosPositionKpiReply) Reset 

func (m *QosPositionKpiReply) Reset()

func (*QosPositionKpiReply) Size 

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

func (*QosPositionKpiReply) String 

func (m *QosPositionKpiReply) String() string

func (*QosPositionKpiReply) Unmarshal 

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

func (*QosPositionKpiReply) ValidateEnums 

func (m *QosPositionKpiReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPositionKpiReply) XXX_DiscardUnknown 

func (m *QosPositionKpiReply) XXX_DiscardUnknown()

func (*QosPositionKpiReply) XXX_Marshal 

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

func (*QosPositionKpiReply) XXX_Merge 

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

func (*QosPositionKpiReply) XXX_Size 

func (m *QosPositionKpiReply) XXX_Size() int

func (*QosPositionKpiReply) XXX_Unmarshal 

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

type QosPositionKpiResult 

type QosPositionKpiResult struct {
	// as set by the client, must be unique within one QosPositionRequest
	Positionid int64 `protobuf:"varint,1,opt,name=positionid,proto3" json:"positionid,omitempty"`
	// the location which was requested
	GpsLocation *Loc `protobuf:"bytes,2,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	// throughput
	DluserthroughputMin  float32  `protobuf:"fixed32,3,opt,name=dluserthroughput_min,json=dluserthroughputMin,proto3" json:"dluserthroughput_min,omitempty"`
	DluserthroughputAvg  float32  `protobuf:"fixed32,4,opt,name=dluserthroughput_avg,json=dluserthroughputAvg,proto3" json:"dluserthroughput_avg,omitempty"`
	DluserthroughputMax  float32  `protobuf:"fixed32,5,opt,name=dluserthroughput_max,json=dluserthroughputMax,proto3" json:"dluserthroughput_max,omitempty"`
	UluserthroughputMin  float32  `protobuf:"fixed32,6,opt,name=uluserthroughput_min,json=uluserthroughputMin,proto3" json:"uluserthroughput_min,omitempty"`
	UluserthroughputAvg  float32  `protobuf:"fixed32,7,opt,name=uluserthroughput_avg,json=uluserthroughputAvg,proto3" json:"uluserthroughput_avg,omitempty"`
	UluserthroughputMax  float32  `protobuf:"fixed32,8,opt,name=uluserthroughput_max,json=uluserthroughputMax,proto3" json:"uluserthroughput_max,omitempty"`
	LatencyMin           float32  `protobuf:"fixed32,9,opt,name=latency_min,json=latencyMin,proto3" json:"latency_min,omitempty"`
	LatencyAvg           float32  `protobuf:"fixed32,10,opt,name=latency_avg,json=latencyAvg,proto3" json:"latency_avg,omitempty"`
	LatencyMax           float32  `protobuf:"fixed32,11,opt,name=latency_max,json=latencyMax,proto3" json:"latency_max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QosPositionKpiResult) ClearTagged 

func (s *QosPositionKpiResult) ClearTagged(tags map[string]struct{})

func (*QosPositionKpiResult) Clone 

func (m *QosPositionKpiResult) Clone() *QosPositionKpiResult

func (*QosPositionKpiResult) CopyInFields 

func (m *QosPositionKpiResult) CopyInFields(src *QosPositionKpiResult) int

func (*QosPositionKpiResult) DeepCopyIn 

func (m *QosPositionKpiResult) DeepCopyIn(src *QosPositionKpiResult)

func (*QosPositionKpiResult) Descriptor 

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

func (*QosPositionKpiResult) Marshal 

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

func (*QosPositionKpiResult) MarshalTo 

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

func (*QosPositionKpiResult) MarshalToSizedBuffer 

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

func (*QosPositionKpiResult) ProtoMessage 

func (*QosPositionKpiResult) ProtoMessage()

func (*QosPositionKpiResult) Reset 

func (m *QosPositionKpiResult) Reset()

func (*QosPositionKpiResult) Size 

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

func (*QosPositionKpiResult) String 

func (m *QosPositionKpiResult) String() string

func (*QosPositionKpiResult) Unmarshal 

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

func (*QosPositionKpiResult) ValidateEnums 

func (m *QosPositionKpiResult) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPositionKpiResult) XXX_DiscardUnknown 

func (m *QosPositionKpiResult) XXX_DiscardUnknown()

func (*QosPositionKpiResult) XXX_Marshal 

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

func (*QosPositionKpiResult) XXX_Merge 

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

func (*QosPositionKpiResult) XXX_Size 

func (m *QosPositionKpiResult) XXX_Size() int

func (*QosPositionKpiResult) XXX_Unmarshal 

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

type QosPositionKpiServer 

type QosPositionKpiServer interface {
	GetQosPositionKpi(*QosPositionRequest, QosPositionKpi_GetQosPositionKpiServer) error
}

QosPositionKpiServer is the server API for QosPositionKpi service.

type QosPositionKpi_GetQosPositionKpiClient 

type QosPositionKpi_GetQosPositionKpiClient interface {
	Recv() (*QosPositionKpiReply, error)
	grpc.ClientStream
}

type QosPositionKpi_GetQosPositionKpiServer 

type QosPositionKpi_GetQosPositionKpiServer interface {
	Send(*QosPositionKpiReply) error
	grpc.ServerStream
}

type QosPositionRequest 

type QosPositionRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// list of positions
	Positions []*QosPosition `protobuf:"bytes,3,rep,name=positions,proto3" json:"positions,omitempty"`
	// _(optional)_ Client's device LTE category number.
	LteCategory int32 `protobuf:"varint,4,opt,name=lte_category,json=lteCategory,proto3" json:"lte_category,omitempty"`
	// _(optional)_ Band list used by the client.
	BandSelection *BandSelection `protobuf:"bytes,5,opt,name=band_selection,json=bandSelection,proto3" json:"band_selection,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

QosPositionRequest is used for both GetQosPositionKpi

func (*QosPositionRequest) AddBandSelectionRat2G 

func (m *QosPositionRequest) AddBandSelectionRat2G(vals ...string) int

func (*QosPositionRequest) AddBandSelectionRat3G 

func (m *QosPositionRequest) AddBandSelectionRat3G(vals ...string) int

func (*QosPositionRequest) AddBandSelectionRat4G 

func (m *QosPositionRequest) AddBandSelectionRat4G(vals ...string) int

func (*QosPositionRequest) AddBandSelectionRat5G 

func (m *QosPositionRequest) AddBandSelectionRat5G(vals ...string) int

func (*QosPositionRequest) AddPositions 

func (m *QosPositionRequest) AddPositions(vals ...*QosPosition) int

func (*QosPositionRequest) ClearTagged 

func (s *QosPositionRequest) ClearTagged(tags map[string]struct{})

func (*QosPositionRequest) Clone 

func (m *QosPositionRequest) Clone() *QosPositionRequest

func (*QosPositionRequest) CopyInFields 

func (m *QosPositionRequest) CopyInFields(src *QosPositionRequest) int

func (*QosPositionRequest) DeepCopyIn 

func (m *QosPositionRequest) DeepCopyIn(src *QosPositionRequest)

func (*QosPositionRequest) Descriptor 

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

func (*QosPositionRequest) IsValidArgsForGetQosPositionKpi 

func (m *QosPositionRequest) IsValidArgsForGetQosPositionKpi() error

func (*QosPositionRequest) Marshal 

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

func (*QosPositionRequest) MarshalTo 

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

func (*QosPositionRequest) MarshalToSizedBuffer 

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

func (*QosPositionRequest) ProtoMessage 

func (*QosPositionRequest) ProtoMessage()

func (*QosPositionRequest) RemoveBandSelectionRat2G 

func (m *QosPositionRequest) RemoveBandSelectionRat2G(vals ...string) int

func (*QosPositionRequest) RemoveBandSelectionRat3G 

func (m *QosPositionRequest) RemoveBandSelectionRat3G(vals ...string) int

func (*QosPositionRequest) RemoveBandSelectionRat4G 

func (m *QosPositionRequest) RemoveBandSelectionRat4G(vals ...string) int

func (*QosPositionRequest) RemoveBandSelectionRat5G 

func (m *QosPositionRequest) RemoveBandSelectionRat5G(vals ...string) int

func (*QosPositionRequest) RemovePositions 

func (m *QosPositionRequest) RemovePositions(vals ...*QosPosition) int

func (*QosPositionRequest) Reset 

func (m *QosPositionRequest) Reset()

func (*QosPositionRequest) Size 

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

func (*QosPositionRequest) String 

func (m *QosPositionRequest) String() string

func (*QosPositionRequest) Unmarshal 

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

func (*QosPositionRequest) ValidateEnums 

func (m *QosPositionRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPositionRequest) XXX_DiscardUnknown 

func (m *QosPositionRequest) XXX_DiscardUnknown()

func (*QosPositionRequest) XXX_Marshal 

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

func (*QosPositionRequest) XXX_Merge 

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

func (*QosPositionRequest) XXX_Size 

func (m *QosPositionRequest) XXX_Size() int

func (*QosPositionRequest) XXX_Unmarshal 

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

type QosPrioritySessionCreateRequest 

type QosPrioritySessionCreateRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	//
	// _(optional)_ QOS Priority Session duration in seconds
	SessionDuration uint32 `protobuf:"varint,3,opt,name=session_duration,json=sessionDuration,proto3" json:"session_duration,omitempty"`
	//
	// IP address of mobile device
	IpUserEquipment string `protobuf:"bytes,4,opt,name=ip_user_equipment,json=ipUserEquipment,proto3" json:"ip_user_equipment,omitempty"`
	//
	// IP address of the application server
	IpApplicationServer string `protobuf:"bytes,5,opt,name=ip_application_server,json=ipApplicationServer,proto3" json:"ip_application_server,omitempty"`
	//
	// _(optional)_ A list of single ports or port ranges on the user equipment.
	PortUserEquipment string `protobuf:"bytes,6,opt,name=port_user_equipment,json=portUserEquipment,proto3" json:"port_user_equipment,omitempty"`
	//
	// _(optional)_ A list of single ports or port ranges on the application server
	PortApplicationServer string `` /* 126-byte string literal not displayed */
	//
	// _(optional)_ The used transport protocol for the uplink
	ProtocolIn QosSessionProtocol `` /* 141-byte string literal not displayed */
	//
	// _(optional)_ The used transport protocol for the downlink
	ProtocolOut QosSessionProtocol `` /* 144-byte string literal not displayed */
	//
	// QOS Priority Session profile name
	Profile QosSessionProfile `protobuf:"varint,10,opt,name=profile,proto3,enum=distributed_match_engine.QosSessionProfile" json:"profile,omitempty"`
	//
	//  _(optional)_ URI of the callback receiver. Allows asynchronous delivery of session related events.
	NotificationUri string `protobuf:"bytes,11,opt,name=notification_uri,json=notificationUri,proto3" json:"notification_uri,omitempty"`
	//
	// _(optional)_ Authentification token for callback API
	NotificationAuthToken string `` /* 127-byte string literal not displayed */
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*QosPrioritySessionCreateRequest) ClearTagged 

func (s *QosPrioritySessionCreateRequest) ClearTagged(tags map[string]struct{})

func (*QosPrioritySessionCreateRequest) Clone 

func (m *QosPrioritySessionCreateRequest) Clone() *QosPrioritySessionCreateRequest

func (*QosPrioritySessionCreateRequest) CopyInFields 

func (m *QosPrioritySessionCreateRequest) CopyInFields(src *QosPrioritySessionCreateRequest) int

func (*QosPrioritySessionCreateRequest) DeepCopyIn 

func (m *QosPrioritySessionCreateRequest) DeepCopyIn(src *QosPrioritySessionCreateRequest)

func (*QosPrioritySessionCreateRequest) Descriptor 

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

func (*QosPrioritySessionCreateRequest) IsValidArgsForQosPrioritySessionCreate 

func (m *QosPrioritySessionCreateRequest) IsValidArgsForQosPrioritySessionCreate() error

func (*QosPrioritySessionCreateRequest) Marshal 

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

func (*QosPrioritySessionCreateRequest) MarshalTo 

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

func (*QosPrioritySessionCreateRequest) MarshalToSizedBuffer 

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

func (*QosPrioritySessionCreateRequest) ProtoMessage 

func (*QosPrioritySessionCreateRequest) ProtoMessage()

func (*QosPrioritySessionCreateRequest) Reset 

func (m *QosPrioritySessionCreateRequest) Reset()

func (*QosPrioritySessionCreateRequest) Size 

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

func (*QosPrioritySessionCreateRequest) String 

func (m *QosPrioritySessionCreateRequest) String() string

func (*QosPrioritySessionCreateRequest) Unmarshal 

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

func (*QosPrioritySessionCreateRequest) ValidateEnums 

func (m *QosPrioritySessionCreateRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPrioritySessionCreateRequest) XXX_DiscardUnknown 

func (m *QosPrioritySessionCreateRequest) XXX_DiscardUnknown()

func (*QosPrioritySessionCreateRequest) XXX_Marshal 

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

func (*QosPrioritySessionCreateRequest) XXX_Merge 

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

func (*QosPrioritySessionCreateRequest) XXX_Size 

func (m *QosPrioritySessionCreateRequest) XXX_Size() int

func (*QosPrioritySessionCreateRequest) XXX_Unmarshal 

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

type QosPrioritySessionDeleteReply 

type QosPrioritySessionDeleteReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Status return.
	Status QosPrioritySessionDeleteReply_DeleteStatus `` /* 139-byte string literal not displayed */
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*QosPrioritySessionDeleteReply) ClearTagged 

func (s *QosPrioritySessionDeleteReply) ClearTagged(tags map[string]struct{})

func (*QosPrioritySessionDeleteReply) Clone 

func (m *QosPrioritySessionDeleteReply) Clone() *QosPrioritySessionDeleteReply

func (*QosPrioritySessionDeleteReply) CopyInFields 

func (m *QosPrioritySessionDeleteReply) CopyInFields(src *QosPrioritySessionDeleteReply) int

func (*QosPrioritySessionDeleteReply) DeepCopyIn 

func (m *QosPrioritySessionDeleteReply) DeepCopyIn(src *QosPrioritySessionDeleteReply)

func (*QosPrioritySessionDeleteReply) Descriptor 

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

func (*QosPrioritySessionDeleteReply) Marshal 

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

func (*QosPrioritySessionDeleteReply) MarshalTo 

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

func (*QosPrioritySessionDeleteReply) MarshalToSizedBuffer 

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

func (*QosPrioritySessionDeleteReply) ProtoMessage 

func (*QosPrioritySessionDeleteReply) ProtoMessage()

func (*QosPrioritySessionDeleteReply) Reset 

func (m *QosPrioritySessionDeleteReply) Reset()

func (*QosPrioritySessionDeleteReply) Size 

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

func (*QosPrioritySessionDeleteReply) String 

func (m *QosPrioritySessionDeleteReply) String() string

func (*QosPrioritySessionDeleteReply) Unmarshal 

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

func (*QosPrioritySessionDeleteReply) ValidateEnums 

func (m *QosPrioritySessionDeleteReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPrioritySessionDeleteReply) XXX_DiscardUnknown 

func (m *QosPrioritySessionDeleteReply) XXX_DiscardUnknown()

func (*QosPrioritySessionDeleteReply) XXX_Marshal 

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

func (*QosPrioritySessionDeleteReply) XXX_Merge 

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

func (*QosPrioritySessionDeleteReply) XXX_Size 

func (m *QosPrioritySessionDeleteReply) XXX_Size() int

func (*QosPrioritySessionDeleteReply) XXX_Unmarshal 

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

type QosPrioritySessionDeleteReply_DeleteStatus 

type QosPrioritySessionDeleteReply_DeleteStatus int32
const (
	QosPrioritySessionDeleteReply_QDEL_UNKNOWN   QosPrioritySessionDeleteReply_DeleteStatus = 0
	QosPrioritySessionDeleteReply_QDEL_DELETED   QosPrioritySessionDeleteReply_DeleteStatus = 1
	QosPrioritySessionDeleteReply_QDEL_NOT_FOUND QosPrioritySessionDeleteReply_DeleteStatus = 2
)

func ParseQosPrioritySessionDeleteReply_DeleteStatus 

func ParseQosPrioritySessionDeleteReply_DeleteStatus(data interface{}) (QosPrioritySessionDeleteReply_DeleteStatus, error)

func (QosPrioritySessionDeleteReply_DeleteStatus) EnumDescriptor 

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

func (QosPrioritySessionDeleteReply_DeleteStatus) MarshalJSON 

func (e QosPrioritySessionDeleteReply_DeleteStatus) MarshalJSON() ([]byte, error)

func (QosPrioritySessionDeleteReply_DeleteStatus) MarshalYAML 

func (e QosPrioritySessionDeleteReply_DeleteStatus) MarshalYAML() (interface{}, error)

func (QosPrioritySessionDeleteReply_DeleteStatus) String 

func (x QosPrioritySessionDeleteReply_DeleteStatus) String() string

func (*QosPrioritySessionDeleteReply_DeleteStatus) UnmarshalJSON 

func (e *QosPrioritySessionDeleteReply_DeleteStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*QosPrioritySessionDeleteReply_DeleteStatus) UnmarshalYAML 

func (e *QosPrioritySessionDeleteReply_DeleteStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type QosPrioritySessionDeleteRequest 

type QosPrioritySessionDeleteRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	//
	// QOS Priority Session profile name
	Profile QosSessionProfile `protobuf:"varint,3,opt,name=profile,proto3,enum=distributed_match_engine.QosSessionProfile" json:"profile,omitempty"`
	//
	// QOS Priority Session ID to be deleted
	SessionId string `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*QosPrioritySessionDeleteRequest) ClearTagged 

func (s *QosPrioritySessionDeleteRequest) ClearTagged(tags map[string]struct{})

func (*QosPrioritySessionDeleteRequest) Clone 

func (m *QosPrioritySessionDeleteRequest) Clone() *QosPrioritySessionDeleteRequest

func (*QosPrioritySessionDeleteRequest) CopyInFields 

func (m *QosPrioritySessionDeleteRequest) CopyInFields(src *QosPrioritySessionDeleteRequest) int

func (*QosPrioritySessionDeleteRequest) DeepCopyIn 

func (m *QosPrioritySessionDeleteRequest) DeepCopyIn(src *QosPrioritySessionDeleteRequest)

func (*QosPrioritySessionDeleteRequest) Descriptor 

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

func (*QosPrioritySessionDeleteRequest) IsValidArgsForQosPrioritySessionDelete 

func (m *QosPrioritySessionDeleteRequest) IsValidArgsForQosPrioritySessionDelete() error

func (*QosPrioritySessionDeleteRequest) Marshal 

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

func (*QosPrioritySessionDeleteRequest) MarshalTo 

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

func (*QosPrioritySessionDeleteRequest) MarshalToSizedBuffer 

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

func (*QosPrioritySessionDeleteRequest) ProtoMessage 

func (*QosPrioritySessionDeleteRequest) ProtoMessage()

func (*QosPrioritySessionDeleteRequest) Reset 

func (m *QosPrioritySessionDeleteRequest) Reset()

func (*QosPrioritySessionDeleteRequest) Size 

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

func (*QosPrioritySessionDeleteRequest) String 

func (m *QosPrioritySessionDeleteRequest) String() string

func (*QosPrioritySessionDeleteRequest) Unmarshal 

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

func (*QosPrioritySessionDeleteRequest) ValidateEnums 

func (m *QosPrioritySessionDeleteRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPrioritySessionDeleteRequest) XXX_DiscardUnknown 

func (m *QosPrioritySessionDeleteRequest) XXX_DiscardUnknown()

func (*QosPrioritySessionDeleteRequest) XXX_Marshal 

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

func (*QosPrioritySessionDeleteRequest) XXX_Merge 

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

func (*QosPrioritySessionDeleteRequest) XXX_Size 

func (m *QosPrioritySessionDeleteRequest) XXX_Size() int

func (*QosPrioritySessionDeleteRequest) XXX_Unmarshal 

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

type QosPrioritySessionReply 

type QosPrioritySessionReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// QOS Priority Session duration in seconds
	SessionDuration uint32 `protobuf:"varint,2,opt,name=session_duration,json=sessionDuration,proto3" json:"session_duration,omitempty"`
	//
	// QOS Priority Session profile name
	Profile QosSessionProfile `protobuf:"varint,3,opt,name=profile,proto3,enum=distributed_match_engine.QosSessionProfile" json:"profile,omitempty"`
	//
	// Session ID in UUID format
	SessionId string `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	//
	// Timestamp of session start in seconds since unix epoch
	StartedAt uint32 `protobuf:"varint,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	//
	// Timestamp of session expiration if the session was not deleted in seconds since unix epoch
	ExpiresAt uint32 `protobuf:"varint,6,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	//
	// HTTP Status Code of call to operator's API server.
	HttpStatus uint32 `protobuf:"varint,7,opt,name=http_status,json=httpStatus,proto3" json:"http_status,omitempty"`
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*QosPrioritySessionReply) ClearTagged 

func (s *QosPrioritySessionReply) ClearTagged(tags map[string]struct{})

func (*QosPrioritySessionReply) Clone 

func (m *QosPrioritySessionReply) Clone() *QosPrioritySessionReply

func (*QosPrioritySessionReply) CopyInFields 

func (m *QosPrioritySessionReply) CopyInFields(src *QosPrioritySessionReply) int

func (*QosPrioritySessionReply) DeepCopyIn 

func (m *QosPrioritySessionReply) DeepCopyIn(src *QosPrioritySessionReply)

func (*QosPrioritySessionReply) Descriptor 

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

func (*QosPrioritySessionReply) Marshal 

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

func (*QosPrioritySessionReply) MarshalTo 

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

func (*QosPrioritySessionReply) MarshalToSizedBuffer 

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

func (*QosPrioritySessionReply) ProtoMessage 

func (*QosPrioritySessionReply) ProtoMessage()

func (*QosPrioritySessionReply) Reset 

func (m *QosPrioritySessionReply) Reset()

func (*QosPrioritySessionReply) Size 

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

func (*QosPrioritySessionReply) String 

func (m *QosPrioritySessionReply) String() string

func (*QosPrioritySessionReply) Unmarshal 

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

func (*QosPrioritySessionReply) ValidateEnums 

func (m *QosPrioritySessionReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*QosPrioritySessionReply) XXX_DiscardUnknown 

func (m *QosPrioritySessionReply) XXX_DiscardUnknown()

func (*QosPrioritySessionReply) XXX_Marshal 

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

func (*QosPrioritySessionReply) XXX_Merge 

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

func (*QosPrioritySessionReply) XXX_Size 

func (m *QosPrioritySessionReply) XXX_Size() int

func (*QosPrioritySessionReply) XXX_Unmarshal 

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

type QosSessionProfile 

type QosSessionProfile int32
const (
	// Specifies that no priority session should be created
	QosSessionProfile_QOS_NO_PRIORITY QosSessionProfile = 0
	// Corresponds to a specific set of network parameters for low latency that will be
	// negotiated with the network provider in advance
	QosSessionProfile_QOS_LOW_LATENCY QosSessionProfile = 1
	// Downlink traffic from AppInst to client is prioritized up to 20Mbps
	QosSessionProfile_QOS_THROUGHPUT_DOWN_S QosSessionProfile = 2
	// Downlink traffic from AppInst to client is prioritized up to 50Mbps
	QosSessionProfile_QOS_THROUGHPUT_DOWN_M QosSessionProfile = 3
	// Downlink traffic from AppInst to client is prioritized up to 100Mbps
	QosSessionProfile_QOS_THROUGHPUT_DOWN_L QosSessionProfile = 4
)

func ParseQosSessionProfile 

func ParseQosSessionProfile(data interface{}) (QosSessionProfile, error)

func (QosSessionProfile) EnumDescriptor 

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

func (QosSessionProfile) MarshalJSON 

func (e QosSessionProfile) MarshalJSON() ([]byte, error)

func (QosSessionProfile) MarshalYAML 

func (e QosSessionProfile) MarshalYAML() (interface{}, error)

func (QosSessionProfile) String 

func (x QosSessionProfile) String() string

func (*QosSessionProfile) UnmarshalJSON 

func (e *QosSessionProfile) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*QosSessionProfile) UnmarshalYAML 

func (e *QosSessionProfile) UnmarshalYAML(unmarshal func(interface{}) error) error

type QosSessionProtocol 

type QosSessionProtocol int32
const (
	QosSessionProtocol_TCP QosSessionProtocol = 0
	QosSessionProtocol_UDP QosSessionProtocol = 1
	QosSessionProtocol_ANY QosSessionProtocol = 2
)

func ParseQosSessionProtocol 

func ParseQosSessionProtocol(data interface{}) (QosSessionProtocol, error)

func (QosSessionProtocol) EnumDescriptor 

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

func (QosSessionProtocol) MarshalJSON 

func (e QosSessionProtocol) MarshalJSON() ([]byte, error)

func (QosSessionProtocol) MarshalYAML 

func (e QosSessionProtocol) MarshalYAML() (interface{}, error)

func (QosSessionProtocol) String 

func (x QosSessionProtocol) String() string

func (*QosSessionProtocol) UnmarshalJSON 

func (e *QosSessionProtocol) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*QosSessionProtocol) UnmarshalYAML 

func (e *QosSessionProtocol) UnmarshalYAML(unmarshal func(interface{}) error) error

type QualityOfServiceClient 

type QualityOfServiceClient interface {
	//
	// QosPrioritySessionCreate
	//
	// Creates a QOS priority session (latency or throughput priority) from the client
	// to the app inst by making a call to the operator's priority session API server.
	QosPrioritySessionCreate(ctx context.Context, in *QosPrioritySessionCreateRequest, opts ...grpc.CallOption) (*QosPrioritySessionReply, error)
	//
	// QosPrioritySessionDelete
	//
	// Deletes a previously created QOS priority session by making a call to the operator's
	// priority session API server.
	QosPrioritySessionDelete(ctx context.Context, in *QosPrioritySessionDeleteRequest, opts ...grpc.CallOption) (*QosPrioritySessionDeleteReply, error)
}

QualityOfServiceClient is the client API for QualityOfService service.

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

func NewQualityOfServiceClient 

func NewQualityOfServiceClient(cc *grpc.ClientConn) QualityOfServiceClient

type QualityOfServiceServer 

type QualityOfServiceServer interface {
	//
	// QosPrioritySessionCreate
	//
	// Creates a QOS priority session (latency or throughput priority) from the client
	// to the app inst by making a call to the operator's priority session API server.
	QosPrioritySessionCreate(context.Context, *QosPrioritySessionCreateRequest) (*QosPrioritySessionReply, error)
	//
	// QosPrioritySessionDelete
	//
	// Deletes a previously created QOS priority session by making a call to the operator's
	// priority session API server.
	QosPrioritySessionDelete(context.Context, *QosPrioritySessionDeleteRequest) (*QosPrioritySessionDeleteReply, error)
}

QualityOfServiceServer is the server API for QualityOfService service.

type RegisterClientReply 

type RegisterClientReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	// Status of the reply
	Status ReplyStatus `protobuf:"varint,2,opt,name=status,proto3,enum=distributed_match_engine.ReplyStatus" json:"status,omitempty"`
	// Session Cookie to be used in later API calls
	SessionCookie string `protobuf:"bytes,3,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	// URI for the Token Server
	TokenServerUri string `protobuf:"bytes,4,opt,name=token_server_uri,json=tokenServerUri,proto3" json:"token_server_uri,omitempty"`
	//
	// Unique ID Type
	//
	// _(optional)_ Type of unique ID provided by the server
	// A unique_id_type and unique_id may be provided by the client to be registered.
	// During registering, if a unique_id_type and unique_id are provided by the client in their request,
	// the unique_id_type and unique_id will be left blank in the response.
	// But, if the client does not provide a unique_id_type and unique_id, then the server generates
	// one and provides the unique_id in the response. If possible, the unique_id should be saved by the
	// client locally and used for subsequent RegisterClient API calls. Otherwise, a new unique_id will be
	// generated for further API calls.
	UniqueIdType string `protobuf:"bytes,5,opt,name=unique_id_type,json=uniqueIdType,proto3" json:"unique_id_type,omitempty"`
	//
	// Unique ID
	//
	// _(optional)_ Unique identification of the client device or user
	// A unique_id_type and unique_id may be provided by the client to be registered.
	// During registering, if a unique_id_type and unique_id are provided by the client in their request,
	// the unique_id_type and unique_id will be left blank in the response.
	// But, if the client does not provide a unique_id_type and unique_id, then the server generates
	// one and provides the unique_id in the response. If possible, the unique_id should be saved by the
	// client locally and used for subsequent RegisterClient API calls. Otherwise, a new unique_id will be
	// generated for further API calls.
	UniqueId string `protobuf:"bytes,6,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	// Vendor specific data
	//
	// _(optional)_ Array of Tags.
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RegisterClientReply) ClearTagged 

func (s *RegisterClientReply) ClearTagged(tags map[string]struct{})

func (*RegisterClientReply) Clone 

func (m *RegisterClientReply) Clone() *RegisterClientReply

func (*RegisterClientReply) CopyInFields 

func (m *RegisterClientReply) CopyInFields(src *RegisterClientReply) int

func (*RegisterClientReply) DeepCopyIn 

func (m *RegisterClientReply) DeepCopyIn(src *RegisterClientReply)

func (*RegisterClientReply) Descriptor 

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

func (*RegisterClientReply) Marshal 

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

func (*RegisterClientReply) MarshalTo 

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

func (*RegisterClientReply) MarshalToSizedBuffer 

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

func (*RegisterClientReply) ProtoMessage 

func (*RegisterClientReply) ProtoMessage()

func (*RegisterClientReply) Reset 

func (m *RegisterClientReply) Reset()

func (*RegisterClientReply) Size 

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

func (*RegisterClientReply) String 

func (m *RegisterClientReply) String() string

func (*RegisterClientReply) Unmarshal 

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

func (*RegisterClientReply) ValidateEnums 

func (m *RegisterClientReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*RegisterClientReply) XXX_DiscardUnknown 

func (m *RegisterClientReply) XXX_DiscardUnknown()

func (*RegisterClientReply) XXX_Marshal 

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

func (*RegisterClientReply) XXX_Merge 

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

func (*RegisterClientReply) XXX_Size 

func (m *RegisterClientReply) XXX_Size() int

func (*RegisterClientReply) XXX_Unmarshal 

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

type RegisterClientRequest 

type RegisterClientRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// App Organization Name
	//
	// App developer organization name.
	OrgName string `protobuf:"bytes,2,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
	//
	// App Name
	//
	// Name of your application.
	AppName string `protobuf:"bytes,3,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	//
	// App Version
	//
	// Application version.
	AppVers string `protobuf:"bytes,4,opt,name=app_vers,json=appVers,proto3" json:"app_vers,omitempty"`
	//
	// Carrier Name
	//
	// _(hidden)_ Reserved for future use
	CarrierName string `protobuf:"bytes,5,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	//
	// Authentication Token
	//
	// _(optional)_ An authentication token supplied by the application.
	AuthToken string `protobuf:"bytes,6,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	//
	// Unique ID Type
	//
	// _(optional)_ Type of unique ID provided by the client.
	// If left blank, a new Unique ID type will be assigned in the RegisterClient Reply.
	UniqueIdType string `protobuf:"bytes,8,opt,name=unique_id_type,json=uniqueIdType,proto3" json:"unique_id_type,omitempty"`
	//
	// Unique ID
	//
	// _(optional)_ Unique identification of the client device or user. May be overridden by the server.
	// If left blank, a new Unique ID will be assigned in the RegisterClient Reply.
	UniqueId string `protobuf:"bytes,9,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	//
	// Tags
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RegisterClientRequest) ClearTagged 

func (s *RegisterClientRequest) ClearTagged(tags map[string]struct{})

func (*RegisterClientRequest) Clone 

func (m *RegisterClientRequest) Clone() *RegisterClientRequest

func (*RegisterClientRequest) CopyInFields 

func (m *RegisterClientRequest) CopyInFields(src *RegisterClientRequest) int

func (*RegisterClientRequest) DeepCopyIn 

func (m *RegisterClientRequest) DeepCopyIn(src *RegisterClientRequest)

func (*RegisterClientRequest) Descriptor 

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

func (*RegisterClientRequest) IsValidArgsForRegisterClient 

func (m *RegisterClientRequest) IsValidArgsForRegisterClient() error

func (*RegisterClientRequest) Marshal 

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

func (*RegisterClientRequest) MarshalTo 

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

func (*RegisterClientRequest) MarshalToSizedBuffer 

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

func (*RegisterClientRequest) ProtoMessage 

func (*RegisterClientRequest) ProtoMessage()

func (*RegisterClientRequest) Reset 

func (m *RegisterClientRequest) Reset()

func (*RegisterClientRequest) Size 

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

func (*RegisterClientRequest) String 

func (m *RegisterClientRequest) String() string

func (*RegisterClientRequest) Unmarshal 

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

func (*RegisterClientRequest) ValidateEnums 

func (m *RegisterClientRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*RegisterClientRequest) XXX_DiscardUnknown 

func (m *RegisterClientRequest) XXX_DiscardUnknown()

func (*RegisterClientRequest) XXX_Marshal 

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

func (*RegisterClientRequest) XXX_Merge 

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

func (*RegisterClientRequest) XXX_Size 

func (m *RegisterClientRequest) XXX_Size() int

func (*RegisterClientRequest) XXX_Unmarshal 

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

type ReplyStatus 

type ReplyStatus int32

ReplyStatus 

const (
	// Undefined status
	ReplyStatus_RS_UNDEFINED ReplyStatus = 0
	// Successful status
	ReplyStatus_RS_SUCCESS ReplyStatus = 1
	// Failure status
	ReplyStatus_RS_FAIL ReplyStatus = 2
)

func ParseReplyStatus 

func ParseReplyStatus(data interface{}) (ReplyStatus, error)

func (ReplyStatus) EnumDescriptor 

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

func (ReplyStatus) MarshalJSON 

func (e ReplyStatus) MarshalJSON() ([]byte, error)

func (ReplyStatus) MarshalYAML 

func (e ReplyStatus) MarshalYAML() (interface{}, error)

func (ReplyStatus) String 

func (x ReplyStatus) String() string

func (*ReplyStatus) UnmarshalJSON 

func (e *ReplyStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*ReplyStatus) UnmarshalYAML 

func (e *ReplyStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type Sample 

type Sample struct {
	// Latency value
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// Timestamp
	Timestamp *Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Sample

func (*Sample) ClearTagged 

func (s *Sample) ClearTagged(tags map[string]struct{})

func (*Sample) Clone 

func (m *Sample) Clone() *Sample

func (*Sample) CopyInFields 

func (m *Sample) CopyInFields(src *Sample) int

func (*Sample) DeepCopyIn 

func (m *Sample) DeepCopyIn(src *Sample)

func (*Sample) Descriptor 

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

func (*Sample) Marshal 

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

func (*Sample) MarshalTo 

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

func (*Sample) MarshalToSizedBuffer 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (m *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) ValidateEnums 

func (m *Sample) ValidateEnums() error

Helper method to check that enums have valid values

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

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

func (*Sample) XXX_Merge 

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

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

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

type ServerEdgeEvent 

type ServerEdgeEvent struct {
	EventType ServerEdgeEvent_ServerEventType `` /* 151-byte string literal not displayed */
	// Cloudlet state information if cloudlet state is not CLOUDLET_STATE_READY
	CloudletState CloudletState `` /* 145-byte string literal not displayed */
	// Cloudlet maintenance state information if maintenance state is not NORMAL_OPERATION
	MaintenanceState MaintenanceState `` /* 157-byte string literal not displayed */
	// AppInst health state information if health check is not HEALTH_CHECK_OK
	HealthCheck HealthCheck `` /* 137-byte string literal not displayed */
	// Summarized RTT Latency stats from samples provided from client if event_type is EVENT_LATENCY
	Statistics *Statistics `protobuf:"bytes,5,opt,name=statistics,proto3" json:"statistics,omitempty"`
	//
	// New and closer cloudlet if event_type is EVENT_CLOUDLET_UPDATE.
	// (EVENT_CLOUDLET_UPDATE occurs if the client is closer to a different cloudlet, or a new closer appinst is created, or a previously down appinst/cloudlet that is closest to the client is now operational)
	// Also sent on EVENT_CLOUDLET_STATE if another cloudlet is available
	// Also sent on EVENT_CLOUDLET_MAINTENANCE, if another cloudlet is available and maintenance_state == UNDER_MAINTENANCE
	// Also sent on EVENT_APPINST_HEALTH, if another cloudlet is available and health_check != HEALTH_CHECK_UNKNOWN
	NewCloudlet *FindCloudletReply `protobuf:"bytes,6,opt,name=new_cloudlet,json=newCloudlet,proto3" json:"new_cloudlet,omitempty"`
	// Error message if event_type is EVENT_ERROR
	ErrorMsg string `protobuf:"bytes,7,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Message from DME to SDK

func (*ServerEdgeEvent) AddNewCloudletPorts 

func (m *ServerEdgeEvent) AddNewCloudletPorts(vals ...*AppPort) int

func (*ServerEdgeEvent) ClearTagged 

func (s *ServerEdgeEvent) ClearTagged(tags map[string]struct{})

func (*ServerEdgeEvent) Clone 

func (m *ServerEdgeEvent) Clone() *ServerEdgeEvent

func (*ServerEdgeEvent) CopyInFields 

func (m *ServerEdgeEvent) CopyInFields(src *ServerEdgeEvent) int

func (*ServerEdgeEvent) DeepCopyIn 

func (m *ServerEdgeEvent) DeepCopyIn(src *ServerEdgeEvent)

func (*ServerEdgeEvent) Descriptor 

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

func (*ServerEdgeEvent) Marshal 

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

func (*ServerEdgeEvent) MarshalTo 

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

func (*ServerEdgeEvent) MarshalToSizedBuffer 

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

func (*ServerEdgeEvent) ProtoMessage 

func (*ServerEdgeEvent) ProtoMessage()

func (*ServerEdgeEvent) RemoveNewCloudletPorts 

func (m *ServerEdgeEvent) RemoveNewCloudletPorts(vals ...*AppPort) int

func (*ServerEdgeEvent) Reset 

func (m *ServerEdgeEvent) Reset()

func (*ServerEdgeEvent) Size 

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

func (*ServerEdgeEvent) String 

func (m *ServerEdgeEvent) String() string

func (*ServerEdgeEvent) Unmarshal 

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

func (*ServerEdgeEvent) ValidateEnums 

func (m *ServerEdgeEvent) ValidateEnums() error

Helper method to check that enums have valid values

func (*ServerEdgeEvent) XXX_DiscardUnknown 

func (m *ServerEdgeEvent) XXX_DiscardUnknown()

func (*ServerEdgeEvent) XXX_Marshal 

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

func (*ServerEdgeEvent) XXX_Merge 

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

func (*ServerEdgeEvent) XXX_Size 

func (m *ServerEdgeEvent) XXX_Size() int

func (*ServerEdgeEvent) XXX_Unmarshal 

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

type ServerEdgeEvent_ServerEventType 

type ServerEdgeEvent_ServerEventType int32
const (
	ServerEdgeEvent_EVENT_UNKNOWN              ServerEdgeEvent_ServerEventType = 0
	ServerEdgeEvent_EVENT_INIT_CONNECTION      ServerEdgeEvent_ServerEventType = 1
	ServerEdgeEvent_EVENT_LATENCY_REQUEST      ServerEdgeEvent_ServerEventType = 2
	ServerEdgeEvent_EVENT_LATENCY_PROCESSED    ServerEdgeEvent_ServerEventType = 3
	ServerEdgeEvent_EVENT_CLOUDLET_STATE       ServerEdgeEvent_ServerEventType = 4
	ServerEdgeEvent_EVENT_CLOUDLET_MAINTENANCE ServerEdgeEvent_ServerEventType = 5
	ServerEdgeEvent_EVENT_APPINST_HEALTH       ServerEdgeEvent_ServerEventType = 6
	ServerEdgeEvent_EVENT_CLOUDLET_UPDATE      ServerEdgeEvent_ServerEventType = 7
	ServerEdgeEvent_EVENT_ERROR                ServerEdgeEvent_ServerEventType = 8
)

func ParseServerEdgeEvent_ServerEventType 

func ParseServerEdgeEvent_ServerEventType(data interface{}) (ServerEdgeEvent_ServerEventType, error)

func (ServerEdgeEvent_ServerEventType) EnumDescriptor 

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

func (ServerEdgeEvent_ServerEventType) MarshalJSON 

func (e ServerEdgeEvent_ServerEventType) MarshalJSON() ([]byte, error)

func (ServerEdgeEvent_ServerEventType) MarshalYAML 

func (e ServerEdgeEvent_ServerEventType) MarshalYAML() (interface{}, error)

func (ServerEdgeEvent_ServerEventType) String 

func (x ServerEdgeEvent_ServerEventType) String() string

func (*ServerEdgeEvent_ServerEventType) UnmarshalJSON 

func (e *ServerEdgeEvent_ServerEventType) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*ServerEdgeEvent_ServerEventType) UnmarshalYAML 

func (e *ServerEdgeEvent_ServerEventType) UnmarshalYAML(unmarshal func(interface{}) error) error

type SessionClient 

type SessionClient interface {
	//
	// RegisterClient
	//
	// Registers the client with the closest Distributed Matching Engine (the
	// nearest edge location in the Operator network) and validates the
	// legitimacy of the mobile subscriber. All session information is encrypted.
	RegisterClient(ctx context.Context, in *RegisterClientRequest, opts ...grpc.CallOption) (*RegisterClientReply, error)
}

SessionClient is the client API for Session service.

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

func NewSessionClient 

func NewSessionClient(cc *grpc.ClientConn) SessionClient

type SessionServer 

type SessionServer interface {
	//
	// RegisterClient
	//
	// Registers the client with the closest Distributed Matching Engine (the
	// nearest edge location in the Operator network) and validates the
	// legitimacy of the mobile subscriber. All session information is encrypted.
	RegisterClient(context.Context, *RegisterClientRequest) (*RegisterClientReply, error)
}

SessionServer is the server API for Session service.

type Statistics 

type Statistics struct {
	// Average
	Avg float64 `protobuf:"fixed64,1,opt,name=avg,proto3" json:"avg,omitempty"`
	// Minimum
	Min float64 `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	// Maximum
	Max float64 `protobuf:"fixed64,3,opt,name=max,proto3" json:"max,omitempty"`
	// Square root of unbiased variance
	StdDev float64 `protobuf:"fixed64,4,opt,name=std_dev,json=stdDev,proto3" json:"std_dev,omitempty"`
	// Unbiased variance
	Variance float64 `protobuf:"fixed64,5,opt,name=variance,proto3" json:"variance,omitempty"`
	// Number of samples to create stats
	NumSamples uint64 `protobuf:"varint,6,opt,name=num_samples,json=numSamples,proto3" json:"num_samples,omitempty"`
	// Timestamp
	Timestamp            *Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Statistics

func (*Statistics) ClearTagged 

func (s *Statistics) ClearTagged(tags map[string]struct{})

func (*Statistics) Clone 

func (m *Statistics) Clone() *Statistics

func (*Statistics) CopyInFields 

func (m *Statistics) CopyInFields(src *Statistics) int

func (*Statistics) DeepCopyIn 

func (m *Statistics) DeepCopyIn(src *Statistics)

func (*Statistics) Descriptor 

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

func (*Statistics) Marshal 

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

func (*Statistics) MarshalTo 

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

func (*Statistics) MarshalToSizedBuffer 

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

func (*Statistics) ProtoMessage 

func (*Statistics) ProtoMessage()

func (*Statistics) Reset 

func (m *Statistics) Reset()

func (*Statistics) Size 

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

func (*Statistics) String 

func (m *Statistics) String() string

func (*Statistics) Unmarshal 

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

func (*Statistics) ValidateEnums 

func (m *Statistics) ValidateEnums() error

Helper method to check that enums have valid values

func (*Statistics) XXX_DiscardUnknown 

func (m *Statistics) XXX_DiscardUnknown()

func (*Statistics) XXX_Marshal 

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

func (*Statistics) XXX_Merge 

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

func (*Statistics) XXX_Size 

func (m *Statistics) XXX_Size() int

func (*Statistics) XXX_Unmarshal 

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

type Timestamp 

type Timestamp struct {
	// Time in seconds since epoch
	Seconds int64 `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"`
	// Added non-negative sub-second time in nanoseconds
	Nanos                int32    `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This is a simple Timestamp message type grpc-gateway converts google.protobuf.Timestamp into an RFC3339-type string which is a waste of a conversion, so we define our own

func ParseTimestamp 

func ParseTimestamp(str string) (Timestamp, error)

func TimeToTimestamp 

func TimeToTimestamp(t time.Time) Timestamp

func (*Timestamp) ClearTagged 

func (s *Timestamp) ClearTagged(tags map[string]struct{})

func (*Timestamp) Clone 

func (m *Timestamp) Clone() *Timestamp

func (*Timestamp) CopyInFields 

func (m *Timestamp) CopyInFields(src *Timestamp) int

func (*Timestamp) DeepCopyIn 

func (m *Timestamp) DeepCopyIn(src *Timestamp)

func (*Timestamp) Descriptor 

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

func (*Timestamp) Marshal 

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

func (Timestamp) MarshalJSON 

func (s Timestamp) MarshalJSON() ([]byte, error)

func (*Timestamp) MarshalTo 

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

func (*Timestamp) MarshalToSizedBuffer 

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

func (Timestamp) MarshalYAML 

func (s Timestamp) MarshalYAML() (interface{}, error)

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset 

func (m *Timestamp) Reset()

func (*Timestamp) Size 

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

func (*Timestamp) String 

func (m *Timestamp) String() string

func (*Timestamp) Unmarshal 

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

func (*Timestamp) UnmarshalJSON 

func (s *Timestamp) UnmarshalJSON(b []byte) error

func (*Timestamp) UnmarshalYAML 

func (s *Timestamp) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*Timestamp) ValidateEnums 

func (m *Timestamp) ValidateEnums() error

Helper method to check that enums have valid values

func (*Timestamp) XXX_DiscardUnknown 

func (m *Timestamp) XXX_DiscardUnknown()

func (*Timestamp) XXX_Marshal 

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

func (*Timestamp) XXX_Merge 

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

func (*Timestamp) XXX_Size 

func (m *Timestamp) XXX_Size() int

func (*Timestamp) XXX_Unmarshal 

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

type UnimplementedDynamicLocGroupApiServer 

type UnimplementedDynamicLocGroupApiServer struct {
}

UnimplementedDynamicLocGroupApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedDynamicLocGroupApiServer) AddUserToGroup 

func (*UnimplementedDynamicLocGroupApiServer) AddUserToGroup(ctx context.Context, req *DynamicLocGroupRequest) (*DynamicLocGroupReply, error)

func (*UnimplementedDynamicLocGroupApiServer) SendToGroup 

func (*UnimplementedDynamicLocGroupApiServer) SendToGroup(ctx context.Context, req *DlgMessage) (*DlgReply, error)

type UnimplementedLocationServer 

type UnimplementedLocationServer struct {
}

UnimplementedLocationServer can be embedded to have forward compatible implementations.

func (*UnimplementedLocationServer) GetLocation 

func (*UnimplementedLocationServer) GetLocation(ctx context.Context, req *GetLocationRequest) (*GetLocationReply, error)

func (*UnimplementedLocationServer) VerifyLocation 

func (*UnimplementedLocationServer) VerifyLocation(ctx context.Context, req *VerifyLocationRequest) (*VerifyLocationReply, error)

type UnimplementedMatchEngineApiServer 

type UnimplementedMatchEngineApiServer struct {
}

UnimplementedMatchEngineApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedMatchEngineApiServer) FindCloudlet 

func (*UnimplementedMatchEngineApiServer) FindCloudlet(ctx context.Context, req *FindCloudletRequest) (*FindCloudletReply, error)

func (*UnimplementedMatchEngineApiServer) GetAppInstList 

func (*UnimplementedMatchEngineApiServer) GetAppInstList(ctx context.Context, req *AppInstListRequest) (*AppInstListReply, error)

func (*UnimplementedMatchEngineApiServer) GetAppOfficialFqdn 

func (*UnimplementedMatchEngineApiServer) GetAppOfficialFqdn(ctx context.Context, req *AppOfficialFqdnRequest) (*AppOfficialFqdnReply, error)

func (*UnimplementedMatchEngineApiServer) StreamEdgeEvent 

func (*UnimplementedMatchEngineApiServer) StreamEdgeEvent(srv MatchEngineApi_StreamEdgeEventServer) error

type UnimplementedPlatformOSServer 

type UnimplementedPlatformOSServer struct {
}

UnimplementedPlatformOSServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlatformOSServer) GetFqdnList 

func (*UnimplementedPlatformOSServer) GetFqdnList(ctx context.Context, req *FqdnListRequest) (*FqdnListReply, error)

func (*UnimplementedPlatformOSServer) PlatformFindCloudlet 

func (*UnimplementedPlatformOSServer) PlatformFindCloudlet(ctx context.Context, req *PlatformFindCloudletRequest) (*FindCloudletReply, error)

type UnimplementedQosPositionKpiServer 

type UnimplementedQosPositionKpiServer struct {
}

UnimplementedQosPositionKpiServer can be embedded to have forward compatible implementations.

func (*UnimplementedQosPositionKpiServer) GetQosPositionKpi 

func (*UnimplementedQosPositionKpiServer) GetQosPositionKpi(req *QosPositionRequest, srv QosPositionKpi_GetQosPositionKpiServer) error

type UnimplementedQualityOfServiceServer 

type UnimplementedQualityOfServiceServer struct {
}

UnimplementedQualityOfServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQualityOfServiceServer) QosPrioritySessionCreate 

func (*UnimplementedQualityOfServiceServer) QosPrioritySessionCreate(ctx context.Context, req *QosPrioritySessionCreateRequest) (*QosPrioritySessionReply, error)

func (*UnimplementedQualityOfServiceServer) QosPrioritySessionDelete 

func (*UnimplementedQualityOfServiceServer) QosPrioritySessionDelete(ctx context.Context, req *QosPrioritySessionDeleteRequest) (*QosPrioritySessionDeleteReply, error)

type UnimplementedSessionServer 

type UnimplementedSessionServer struct {
}

UnimplementedSessionServer can be embedded to have forward compatible implementations.

func (*UnimplementedSessionServer) RegisterClient 

func (*UnimplementedSessionServer) RegisterClient(ctx context.Context, req *RegisterClientRequest) (*RegisterClientReply, error)

type VerifyLocationReply 

type VerifyLocationReply struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver               uint32                                `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	TowerStatus       VerifyLocationReply_TowerStatus       `` /* 157-byte string literal not displayed */
	GpsLocationStatus VerifyLocationReply_GPSLocationStatus `` /* 183-byte string literal not displayed */
	// location accuracy, the location is verified to
	// be within this number of kilometers.  Negative value
	// means no verification was performed
	GpsLocationAccuracyKm float64 `` /* 130-byte string literal not displayed */
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*VerifyLocationReply) ClearTagged 

func (s *VerifyLocationReply) ClearTagged(tags map[string]struct{})

func (*VerifyLocationReply) Clone 

func (m *VerifyLocationReply) Clone() *VerifyLocationReply

func (*VerifyLocationReply) CopyInFields 

func (m *VerifyLocationReply) CopyInFields(src *VerifyLocationReply) int

func (*VerifyLocationReply) DeepCopyIn 

func (m *VerifyLocationReply) DeepCopyIn(src *VerifyLocationReply)

func (*VerifyLocationReply) Descriptor 

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

func (*VerifyLocationReply) Marshal 

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

func (*VerifyLocationReply) MarshalTo 

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

func (*VerifyLocationReply) MarshalToSizedBuffer 

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

func (*VerifyLocationReply) ProtoMessage 

func (*VerifyLocationReply) ProtoMessage()

func (*VerifyLocationReply) Reset 

func (m *VerifyLocationReply) Reset()

func (*VerifyLocationReply) Size 

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

func (*VerifyLocationReply) String 

func (m *VerifyLocationReply) String() string

func (*VerifyLocationReply) Unmarshal 

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

func (*VerifyLocationReply) ValidateEnums 

func (m *VerifyLocationReply) ValidateEnums() error

Helper method to check that enums have valid values

func (*VerifyLocationReply) XXX_DiscardUnknown 

func (m *VerifyLocationReply) XXX_DiscardUnknown()

func (*VerifyLocationReply) XXX_Marshal 

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

func (*VerifyLocationReply) XXX_Merge 

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

func (*VerifyLocationReply) XXX_Size 

func (m *VerifyLocationReply) XXX_Size() int

func (*VerifyLocationReply) XXX_Unmarshal 

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

type VerifyLocationReply_GPSLocationStatus 

type VerifyLocationReply_GPSLocationStatus int32
const (
	VerifyLocationReply_LOC_UNKNOWN                  VerifyLocationReply_GPSLocationStatus = 0
	VerifyLocationReply_LOC_VERIFIED                 VerifyLocationReply_GPSLocationStatus = 1
	VerifyLocationReply_LOC_MISMATCH_SAME_COUNTRY    VerifyLocationReply_GPSLocationStatus = 2
	VerifyLocationReply_LOC_MISMATCH_OTHER_COUNTRY   VerifyLocationReply_GPSLocationStatus = 3
	VerifyLocationReply_LOC_ROAMING_COUNTRY_MATCH    VerifyLocationReply_GPSLocationStatus = 4
	VerifyLocationReply_LOC_ROAMING_COUNTRY_MISMATCH VerifyLocationReply_GPSLocationStatus = 5
	VerifyLocationReply_LOC_ERROR_UNAUTHORIZED       VerifyLocationReply_GPSLocationStatus = 6
	VerifyLocationReply_LOC_ERROR_OTHER              VerifyLocationReply_GPSLocationStatus = 7
)

func ParseVerifyLocationReply_GPSLocationStatus 

func ParseVerifyLocationReply_GPSLocationStatus(data interface{}) (VerifyLocationReply_GPSLocationStatus, error)

func (VerifyLocationReply_GPSLocationStatus) EnumDescriptor 

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

func (VerifyLocationReply_GPSLocationStatus) MarshalJSON 

func (e VerifyLocationReply_GPSLocationStatus) MarshalJSON() ([]byte, error)

func (VerifyLocationReply_GPSLocationStatus) MarshalYAML 

func (e VerifyLocationReply_GPSLocationStatus) MarshalYAML() (interface{}, error)

func (VerifyLocationReply_GPSLocationStatus) String 

func (x VerifyLocationReply_GPSLocationStatus) String() string

func (*VerifyLocationReply_GPSLocationStatus) UnmarshalJSON 

func (e *VerifyLocationReply_GPSLocationStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*VerifyLocationReply_GPSLocationStatus) UnmarshalYAML 

func (e *VerifyLocationReply_GPSLocationStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type VerifyLocationReply_TowerStatus 

type VerifyLocationReply_TowerStatus int32

Status of the reply 

const (
	VerifyLocationReply_TOWER_UNKNOWN                    VerifyLocationReply_TowerStatus = 0
	VerifyLocationReply_CONNECTED_TO_SPECIFIED_TOWER     VerifyLocationReply_TowerStatus = 1
	VerifyLocationReply_NOT_CONNECTED_TO_SPECIFIED_TOWER VerifyLocationReply_TowerStatus = 2
)

func ParseVerifyLocationReply_TowerStatus 

func ParseVerifyLocationReply_TowerStatus(data interface{}) (VerifyLocationReply_TowerStatus, error)

func (VerifyLocationReply_TowerStatus) EnumDescriptor 

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

func (VerifyLocationReply_TowerStatus) MarshalJSON 

func (e VerifyLocationReply_TowerStatus) MarshalJSON() ([]byte, error)

func (VerifyLocationReply_TowerStatus) MarshalYAML 

func (e VerifyLocationReply_TowerStatus) MarshalYAML() (interface{}, error)

func (VerifyLocationReply_TowerStatus) String 

func (x VerifyLocationReply_TowerStatus) String() string

func (*VerifyLocationReply_TowerStatus) UnmarshalJSON 

func (e *VerifyLocationReply_TowerStatus) UnmarshalJSON(b []byte) error

custom JSON encoding/decoding

func (*VerifyLocationReply_TowerStatus) UnmarshalYAML 

func (e *VerifyLocationReply_TowerStatus) UnmarshalYAML(unmarshal func(interface{}) error) error

type VerifyLocationRequest 

type VerifyLocationRequest struct {
	//
	// API version
	//
	// _(hidden)_ Reserved for future use
	Ver uint32 `protobuf:"varint,1,opt,name=ver,proto3" json:"ver,omitempty"`
	//
	// Session Cookie
	//
	// Session Cookie from RegisterClientRequest
	SessionCookie string `protobuf:"bytes,2,opt,name=session_cookie,json=sessionCookie,proto3" json:"session_cookie,omitempty"`
	//
	// Carrier Name
	//
	// Unique carrier identification (typically MCC + MNC)
	CarrierName string `protobuf:"bytes,3,opt,name=carrier_name,json=carrierName,proto3" json:"carrier_name,omitempty"`
	//
	// GPS Location
	//
	// The GPS location to verify
	GpsLocation *Loc `protobuf:"bytes,4,opt,name=gps_location,json=gpsLocation,proto3" json:"gps_location,omitempty"`
	//
	// Verify Location Token
	//
	// Must be retrieved from TokenServerURI
	VerifyLocToken string `protobuf:"bytes,5,opt,name=verify_loc_token,json=verifyLocToken,proto3" json:"verify_loc_token,omitempty"`
	//
	// Tags
	//
	// _(optional)_ Vendor specific data
	Tags                 map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*VerifyLocationRequest) ClearTagged 

func (s *VerifyLocationRequest) ClearTagged(tags map[string]struct{})

func (*VerifyLocationRequest) Clone 

func (m *VerifyLocationRequest) Clone() *VerifyLocationRequest

func (*VerifyLocationRequest) CopyInFields 

func (m *VerifyLocationRequest) CopyInFields(src *VerifyLocationRequest) int

func (*VerifyLocationRequest) DeepCopyIn 

func (m *VerifyLocationRequest) DeepCopyIn(src *VerifyLocationRequest)

func (*VerifyLocationRequest) Descriptor 

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

func (*VerifyLocationRequest) IsValidArgsForVerifyLocation 

func (m *VerifyLocationRequest) IsValidArgsForVerifyLocation() error

func (*VerifyLocationRequest) Marshal 

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

func (*VerifyLocationRequest) MarshalTo 

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

func (*VerifyLocationRequest) MarshalToSizedBuffer 

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

func (*VerifyLocationRequest) ProtoMessage 

func (*VerifyLocationRequest) ProtoMessage()

func (*VerifyLocationRequest) Reset 

func (m *VerifyLocationRequest) Reset()

func (*VerifyLocationRequest) Size 

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

func (*VerifyLocationRequest) String 

func (m *VerifyLocationRequest) String() string

func (*VerifyLocationRequest) Unmarshal 

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

func (*VerifyLocationRequest) ValidateEnums 

func (m *VerifyLocationRequest) ValidateEnums() error

Helper method to check that enums have valid values

func (*VerifyLocationRequest) XXX_DiscardUnknown 

func (m *VerifyLocationRequest) XXX_DiscardUnknown()

func (*VerifyLocationRequest) XXX_Marshal 

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

func (*VerifyLocationRequest) XXX_Merge 

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

func (*VerifyLocationRequest) XXX_Size 

func (m *VerifyLocationRequest) XXX_Size() int

func (*VerifyLocationRequest) XXX_Unmarshal 

func (m *VerifyLocationRequest) XXX_Unmarshal(b []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.