Documentation ¶
Index ¶
- Variables
- func RegisterSubscriberDBCloudServer(s grpc.ServiceRegistrar, srv SubscriberDBCloudServer)
- func RegisterSubscriberDBServer(s grpc.ServiceRegistrar, srv SubscriberDBServer)
- type AccessNetworkIdentifier
- func (AccessNetworkIdentifier) Descriptor() protoreflect.EnumDescriptor
- func (x AccessNetworkIdentifier) Enum() *AccessNetworkIdentifier
- func (AccessNetworkIdentifier) EnumDescriptor() ([]byte, []int)deprecated
- func (x AccessNetworkIdentifier) Number() protoreflect.EnumNumber
- func (x AccessNetworkIdentifier) String() string
- func (AccessNetworkIdentifier) Type() protoreflect.EnumType
- type CheckInSyncRequest
- func (*CheckInSyncRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckInSyncRequest) GetRootDigest() *orc8r.Digest
- func (*CheckInSyncRequest) ProtoMessage()
- func (x *CheckInSyncRequest) ProtoReflect() protoreflect.Message
- func (x *CheckInSyncRequest) Reset()
- func (x *CheckInSyncRequest) String() string
- type CheckInSyncResponse
- func (*CheckInSyncResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckInSyncResponse) GetInSync() bool
- func (*CheckInSyncResponse) ProtoMessage()
- func (x *CheckInSyncResponse) ProtoReflect() protoreflect.Message
- func (x *CheckInSyncResponse) Reset()
- func (x *CheckInSyncResponse) String() string
- type CoreNetworkType
- func (*CoreNetworkType) Descriptor() ([]byte, []int)deprecated
- func (x *CoreNetworkType) GetForbiddenNetworkTypes() []CoreNetworkType_CoreNetworkTypes
- func (*CoreNetworkType) ProtoMessage()
- func (x *CoreNetworkType) ProtoReflect() protoreflect.Message
- func (x *CoreNetworkType) Reset()
- func (x *CoreNetworkType) String() string
- type CoreNetworkType_CoreNetworkTypes
- func (CoreNetworkType_CoreNetworkTypes) Descriptor() protoreflect.EnumDescriptor
- func (x CoreNetworkType_CoreNetworkTypes) Enum() *CoreNetworkType_CoreNetworkTypes
- func (CoreNetworkType_CoreNetworkTypes) EnumDescriptor() ([]byte, []int)deprecated
- func (x CoreNetworkType_CoreNetworkTypes) Number() protoreflect.EnumNumber
- func (x CoreNetworkType_CoreNetworkTypes) String() string
- func (CoreNetworkType_CoreNetworkTypes) Type() protoreflect.EnumType
- type GSMSubscription
- func (*GSMSubscription) Descriptor() ([]byte, []int)deprecated
- func (x *GSMSubscription) GetAuthAlgo() GSMSubscription_GSMAuthAlgo
- func (x *GSMSubscription) GetAuthKey() []byte
- func (x *GSMSubscription) GetAuthTuples() [][]byte
- func (x *GSMSubscription) GetState() GSMSubscription_GSMSubscriptionState
- func (*GSMSubscription) ProtoMessage()
- func (x *GSMSubscription) ProtoReflect() protoreflect.Message
- func (x *GSMSubscription) Reset()
- func (x *GSMSubscription) String() string
- type GSMSubscription_GSMAuthAlgo
- func (GSMSubscription_GSMAuthAlgo) Descriptor() protoreflect.EnumDescriptor
- func (x GSMSubscription_GSMAuthAlgo) Enum() *GSMSubscription_GSMAuthAlgo
- func (GSMSubscription_GSMAuthAlgo) EnumDescriptor() ([]byte, []int)deprecated
- func (x GSMSubscription_GSMAuthAlgo) Number() protoreflect.EnumNumber
- func (x GSMSubscription_GSMAuthAlgo) String() string
- func (GSMSubscription_GSMAuthAlgo) Type() protoreflect.EnumType
- type GSMSubscription_GSMSubscriptionState
- func (GSMSubscription_GSMSubscriptionState) Descriptor() protoreflect.EnumDescriptor
- func (x GSMSubscription_GSMSubscriptionState) Enum() *GSMSubscription_GSMSubscriptionState
- func (GSMSubscription_GSMSubscriptionState) EnumDescriptor() ([]byte, []int)deprecated
- func (x GSMSubscription_GSMSubscriptionState) Number() protoreflect.EnumNumber
- func (x GSMSubscription_GSMSubscriptionState) String() string
- func (GSMSubscription_GSMSubscriptionState) Type() protoreflect.EnumType
- type LTESubscription
- func (*LTESubscription) Descriptor() ([]byte, []int)deprecated
- func (x *LTESubscription) GetAssignedBaseNames() []string
- func (x *LTESubscription) GetAssignedPolicies() []string
- func (x *LTESubscription) GetAuthAlgo() LTESubscription_LTEAuthAlgo
- func (x *LTESubscription) GetAuthKey() []byte
- func (x *LTESubscription) GetAuthOpc() []byte
- func (x *LTESubscription) GetState() LTESubscription_LTESubscriptionState
- func (*LTESubscription) ProtoMessage()
- func (x *LTESubscription) ProtoReflect() protoreflect.Message
- func (x *LTESubscription) Reset()
- func (x *LTESubscription) String() string
- type LTESubscription_LTEAuthAlgo
- func (LTESubscription_LTEAuthAlgo) Descriptor() protoreflect.EnumDescriptor
- func (x LTESubscription_LTEAuthAlgo) Enum() *LTESubscription_LTEAuthAlgo
- func (LTESubscription_LTEAuthAlgo) EnumDescriptor() ([]byte, []int)deprecated
- func (x LTESubscription_LTEAuthAlgo) Number() protoreflect.EnumNumber
- func (x LTESubscription_LTEAuthAlgo) String() string
- func (LTESubscription_LTEAuthAlgo) Type() protoreflect.EnumType
- type LTESubscription_LTESubscriptionState
- func (LTESubscription_LTESubscriptionState) Descriptor() protoreflect.EnumDescriptor
- func (x LTESubscription_LTESubscriptionState) Enum() *LTESubscription_LTESubscriptionState
- func (LTESubscription_LTESubscriptionState) EnumDescriptor() ([]byte, []int)deprecated
- func (x LTESubscription_LTESubscriptionState) Number() protoreflect.EnumNumber
- func (x LTESubscription_LTESubscriptionState) String() string
- func (LTESubscription_LTESubscriptionState) Type() protoreflect.EnumType
- type ListSubscribersRequest
- func (*ListSubscribersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscribersRequest) GetPageSize() uint32
- func (x *ListSubscribersRequest) GetPageToken() string
- func (*ListSubscribersRequest) ProtoMessage()
- func (x *ListSubscribersRequest) ProtoReflect() protoreflect.Message
- func (x *ListSubscribersRequest) Reset()
- func (x *ListSubscribersRequest) String() string
- type ListSubscribersResponse
- func (*ListSubscribersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscribersResponse) GetDigests() *orc8r.DigestTree
- func (x *ListSubscribersResponse) GetNextPageToken() string
- func (x *ListSubscribersResponse) GetSubscribers() []*SubscriberData
- func (*ListSubscribersResponse) ProtoMessage()
- func (x *ListSubscribersResponse) ProtoReflect() protoreflect.Message
- func (x *ListSubscribersResponse) Reset()
- func (x *ListSubscribersResponse) String() string
- type Non3GPPUserProfile
- func (*Non3GPPUserProfile) Descriptor() ([]byte, []int)deprecated
- func (x *Non3GPPUserProfile) GetAccessNetId() AccessNetworkIdentifier
- func (x *Non3GPPUserProfile) GetAmbr() *apn.AggregatedMaximumBitrate
- func (x *Non3GPPUserProfile) GetApnConfig() []*apn.APNConfiguration
- func (x *Non3GPPUserProfile) GetMsisdn() string
- func (x *Non3GPPUserProfile) GetNon_3GppIpAccess() Non3GPPUserProfile_Non3GPPIPAccess
- func (x *Non3GPPUserProfile) GetNon_3GppIpAccessApn() Non3GPPUserProfile_Non3GPPIPAccessAPN
- func (x *Non3GPPUserProfile) GetSubscriberApnConfig() []*SubscriberAPNConfig
- func (*Non3GPPUserProfile) ProtoMessage()
- func (x *Non3GPPUserProfile) ProtoReflect() protoreflect.Message
- func (x *Non3GPPUserProfile) Reset()
- func (x *Non3GPPUserProfile) String() string
- type Non3GPPUserProfile_Non3GPPIPAccess
- func (Non3GPPUserProfile_Non3GPPIPAccess) Descriptor() protoreflect.EnumDescriptor
- func (x Non3GPPUserProfile_Non3GPPIPAccess) Enum() *Non3GPPUserProfile_Non3GPPIPAccess
- func (Non3GPPUserProfile_Non3GPPIPAccess) EnumDescriptor() ([]byte, []int)deprecated
- func (x Non3GPPUserProfile_Non3GPPIPAccess) Number() protoreflect.EnumNumber
- func (x Non3GPPUserProfile_Non3GPPIPAccess) String() string
- func (Non3GPPUserProfile_Non3GPPIPAccess) Type() protoreflect.EnumType
- type Non3GPPUserProfile_Non3GPPIPAccessAPN
- func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Descriptor() protoreflect.EnumDescriptor
- func (x Non3GPPUserProfile_Non3GPPIPAccessAPN) Enum() *Non3GPPUserProfile_Non3GPPIPAccessAPN
- func (Non3GPPUserProfile_Non3GPPIPAccessAPN) EnumDescriptor() ([]byte, []int)deprecated
- func (x Non3GPPUserProfile_Non3GPPIPAccessAPN) Number() protoreflect.EnumNumber
- func (x Non3GPPUserProfile_Non3GPPIPAccessAPN) String() string
- func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Type() protoreflect.EnumType
- type SubscriberAPNConfig
- func (*SubscriberAPNConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriberAPNConfig) GetApnId() uint32
- func (x *SubscriberAPNConfig) GetAssignedStaticIp() string
- func (*SubscriberAPNConfig) ProtoMessage()
- func (x *SubscriberAPNConfig) ProtoReflect() protoreflect.Message
- func (x *SubscriberAPNConfig) Reset()
- func (x *SubscriberAPNConfig) String() string
- type SubscriberDBClient
- type SubscriberDBCloudClient
- type SubscriberDBCloudServer
- type SubscriberDBServer
- type SubscriberData
- func (*SubscriberData) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriberData) GetGsm() *GSMSubscription
- func (x *SubscriberData) GetLte() *LTESubscription
- func (x *SubscriberData) GetNetworkId() *orc8r.NetworkID
- func (x *SubscriberData) GetNon_3Gpp() *Non3GPPUserProfile
- func (x *SubscriberData) GetSid() *SubscriberID
- func (x *SubscriberData) GetState() *SubscriberState
- func (x *SubscriberData) GetSubNetwork() *CoreNetworkType
- func (x *SubscriberData) GetSubProfile() string
- func (*SubscriberData) ProtoMessage()
- func (x *SubscriberData) ProtoReflect() protoreflect.Message
- func (x *SubscriberData) Reset()
- func (x *SubscriberData) String() string
- type SubscriberID
- func (*SubscriberID) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriberID) GetId() string
- func (x *SubscriberID) GetType() SubscriberID_IDType
- func (*SubscriberID) ProtoMessage()
- func (x *SubscriberID) ProtoReflect() protoreflect.Message
- func (x *SubscriberID) Reset()
- func (x *SubscriberID) String() string
- type SubscriberIDSet
- type SubscriberID_IDType
- func (SubscriberID_IDType) Descriptor() protoreflect.EnumDescriptor
- func (x SubscriberID_IDType) Enum() *SubscriberID_IDType
- func (SubscriberID_IDType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscriberID_IDType) Number() protoreflect.EnumNumber
- func (x SubscriberID_IDType) String() string
- func (SubscriberID_IDType) Type() protoreflect.EnumType
- type SubscriberState
- func (*SubscriberState) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriberState) GetLteAuthNextSeq() uint64
- func (x *SubscriberState) GetTgppAaaServerName() string
- func (x *SubscriberState) GetTgppAaaServerRegistered() bool
- func (*SubscriberState) ProtoMessage()
- func (x *SubscriberState) ProtoReflect() protoreflect.Message
- func (x *SubscriberState) Reset()
- func (x *SubscriberState) String() string
- type SubscriberUpdate
- func (*SubscriberUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriberUpdate) GetData() *SubscriberData
- func (x *SubscriberUpdate) GetMask() *fieldmaskpb.FieldMask
- func (*SubscriberUpdate) ProtoMessage()
- func (x *SubscriberUpdate) ProtoReflect() protoreflect.Message
- func (x *SubscriberUpdate) Reset()
- func (x *SubscriberUpdate) String() string
- type SyncRequest
- type SyncResponse
- func (*SyncResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncResponse) GetChangeset() *orc8r.Changeset
- func (x *SyncResponse) GetDigests() *orc8r.DigestTree
- func (x *SyncResponse) GetResync() bool
- func (*SyncResponse) ProtoMessage()
- func (x *SyncResponse) ProtoReflect() protoreflect.Message
- func (x *SyncResponse) Reset()
- func (x *SyncResponse) String() string
- type UnimplementedSubscriberDBCloudServer
- func (UnimplementedSubscriberDBCloudServer) CheckInSync(context.Context, *CheckInSyncRequest) (*CheckInSyncResponse, error)
- func (UnimplementedSubscriberDBCloudServer) ListSubscribers(context.Context, *ListSubscribersRequest) (*ListSubscribersResponse, error)
- func (UnimplementedSubscriberDBCloudServer) Sync(context.Context, *SyncRequest) (*SyncResponse, error)
- type UnimplementedSubscriberDBServer
- func (UnimplementedSubscriberDBServer) AddSubscriber(context.Context, *SubscriberData) (*orc8r.Void, error)
- func (UnimplementedSubscriberDBServer) DeleteSubscriber(context.Context, *SubscriberID) (*orc8r.Void, error)
- func (UnimplementedSubscriberDBServer) GetSubscriberData(context.Context, *SubscriberID) (*SubscriberData, error)
- func (UnimplementedSubscriberDBServer) ListSubscribers(context.Context, *orc8r.Void) (*SubscriberIDSet, error)
- func (UnimplementedSubscriberDBServer) UpdateSubscriber(context.Context, *SubscriberUpdate) (*orc8r.Void, error)
- type UnsafeSubscriberDBCloudServer
- type UnsafeSubscriberDBServer
Constants ¶
This section is empty.
Variables ¶
var ( AccessNetworkIdentifier_name = map[int32]string{ 0: "HRPD", 1: "WIMAX", 2: "WLAN", 3: "ETHERNET", } AccessNetworkIdentifier_value = map[string]int32{ "HRPD": 0, "WIMAX": 1, "WLAN": 2, "ETHERNET": 3, } )
Enum value maps for AccessNetworkIdentifier.
var ( SubscriberID_IDType_name = map[int32]string{ 0: "IMSI", } SubscriberID_IDType_value = map[string]int32{ "IMSI": 0, } )
Enum value maps for SubscriberID_IDType.
var ( GSMSubscription_GSMSubscriptionState_name = map[int32]string{ 0: "INACTIVE", 1: "ACTIVE", } GSMSubscription_GSMSubscriptionState_value = map[string]int32{ "INACTIVE": 0, "ACTIVE": 1, } )
Enum value maps for GSMSubscription_GSMSubscriptionState.
var ( GSMSubscription_GSMAuthAlgo_name = map[int32]string{ 0: "PRECOMPUTED_AUTH_TUPLES", } GSMSubscription_GSMAuthAlgo_value = map[string]int32{ "PRECOMPUTED_AUTH_TUPLES": 0, } )
Enum value maps for GSMSubscription_GSMAuthAlgo.
var ( LTESubscription_LTESubscriptionState_name = map[int32]string{ 0: "INACTIVE", 1: "ACTIVE", } LTESubscription_LTESubscriptionState_value = map[string]int32{ "INACTIVE": 0, "ACTIVE": 1, } )
Enum value maps for LTESubscription_LTESubscriptionState.
var ( LTESubscription_LTEAuthAlgo_name = map[int32]string{ 0: "MILENAGE", } LTESubscription_LTEAuthAlgo_value = map[string]int32{ "MILENAGE": 0, } )
Enum value maps for LTESubscription_LTEAuthAlgo.
var ( Non3GPPUserProfile_Non3GPPIPAccess_name = map[int32]string{ 0: "NON_3GPP_SUBSCRIPTION_ALLOWED", 1: "NON_3GPP_SUBSCRIPTION_BARRED", } Non3GPPUserProfile_Non3GPPIPAccess_value = map[string]int32{ "NON_3GPP_SUBSCRIPTION_ALLOWED": 0, "NON_3GPP_SUBSCRIPTION_BARRED": 1, } )
Enum value maps for Non3GPPUserProfile_Non3GPPIPAccess.
var ( Non3GPPUserProfile_Non3GPPIPAccessAPN_name = map[int32]string{ 0: "NON_3GPP_APNS_ENABLE", 1: "NON_3GPP_APNS_DISABLE", } Non3GPPUserProfile_Non3GPPIPAccessAPN_value = map[string]int32{ "NON_3GPP_APNS_ENABLE": 0, "NON_3GPP_APNS_DISABLE": 1, } )
Enum value maps for Non3GPPUserProfile_Non3GPPIPAccessAPN.
var ( CoreNetworkType_CoreNetworkTypes_name = map[int32]string{ 0: "NT_EPC", 1: "NT_5GC", } CoreNetworkType_CoreNetworkTypes_value = map[string]int32{ "NT_EPC": 0, "NT_5GC": 1, } )
Enum value maps for CoreNetworkType_CoreNetworkTypes.
var File_subscriberdb_proto protoreflect.FileDescriptor
var SubscriberDBCloud_ServiceDesc = grpc.ServiceDesc{ ServiceName: "magma.lte.SubscriberDBCloud", HandlerType: (*SubscriberDBCloudServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CheckInSync", Handler: _SubscriberDBCloud_CheckInSync_Handler, }, { MethodName: "Sync", Handler: _SubscriberDBCloud_Sync_Handler, }, { MethodName: "ListSubscribers", Handler: _SubscriberDBCloud_ListSubscribers_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "subscriberdb.proto", }
SubscriberDBCloud_ServiceDesc is the grpc.ServiceDesc for SubscriberDBCloud service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SubscriberDB_ServiceDesc = grpc.ServiceDesc{ ServiceName: "magma.lte.SubscriberDB", HandlerType: (*SubscriberDBServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AddSubscriber", Handler: _SubscriberDB_AddSubscriber_Handler, }, { MethodName: "DeleteSubscriber", Handler: _SubscriberDB_DeleteSubscriber_Handler, }, { MethodName: "UpdateSubscriber", Handler: _SubscriberDB_UpdateSubscriber_Handler, }, { MethodName: "GetSubscriberData", Handler: _SubscriberDB_GetSubscriberData_Handler, }, { MethodName: "ListSubscribers", Handler: _SubscriberDB_ListSubscribers_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "subscriberdb.proto", }
SubscriberDB_ServiceDesc is the grpc.ServiceDesc for SubscriberDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSubscriberDBCloudServer ¶
func RegisterSubscriberDBCloudServer(s grpc.ServiceRegistrar, srv SubscriberDBCloudServer)
func RegisterSubscriberDBServer ¶
func RegisterSubscriberDBServer(s grpc.ServiceRegistrar, srv SubscriberDBServer)
Types ¶
type AccessNetworkIdentifier ¶
type AccessNetworkIdentifier int32
For details about values read 3GPP 24.302
const ( AccessNetworkIdentifier_HRPD AccessNetworkIdentifier = 0 AccessNetworkIdentifier_WIMAX AccessNetworkIdentifier = 1 AccessNetworkIdentifier_WLAN AccessNetworkIdentifier = 2 AccessNetworkIdentifier_ETHERNET AccessNetworkIdentifier = 3 )
func (AccessNetworkIdentifier) Descriptor ¶
func (AccessNetworkIdentifier) Descriptor() protoreflect.EnumDescriptor
func (AccessNetworkIdentifier) Enum ¶
func (x AccessNetworkIdentifier) Enum() *AccessNetworkIdentifier
func (AccessNetworkIdentifier) EnumDescriptor
deprecated
func (AccessNetworkIdentifier) EnumDescriptor() ([]byte, []int)
Deprecated: Use AccessNetworkIdentifier.Descriptor instead.
func (AccessNetworkIdentifier) Number ¶
func (x AccessNetworkIdentifier) Number() protoreflect.EnumNumber
func (AccessNetworkIdentifier) String ¶
func (x AccessNetworkIdentifier) String() string
func (AccessNetworkIdentifier) Type ¶
func (AccessNetworkIdentifier) Type() protoreflect.EnumType
type CheckInSyncRequest ¶
type CheckInSyncRequest struct { // root_digest is the deterministic digest of the full set of config // objects stored on the client side. RootDigest *orc8r.Digest `protobuf:"bytes,1,opt,name=root_digest,json=rootDigest,proto3" json:"root_digest,omitempty"` // contains filtered or unexported fields }
func (*CheckInSyncRequest) Descriptor
deprecated
func (*CheckInSyncRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckInSyncRequest.ProtoReflect.Descriptor instead.
func (*CheckInSyncRequest) GetRootDigest ¶
func (x *CheckInSyncRequest) GetRootDigest() *orc8r.Digest
func (*CheckInSyncRequest) ProtoMessage ¶
func (*CheckInSyncRequest) ProtoMessage()
func (*CheckInSyncRequest) ProtoReflect ¶
func (x *CheckInSyncRequest) ProtoReflect() protoreflect.Message
func (*CheckInSyncRequest) Reset ¶
func (x *CheckInSyncRequest) Reset()
func (*CheckInSyncRequest) String ¶
func (x *CheckInSyncRequest) String() string
type CheckInSyncResponse ¶
type CheckInSyncResponse struct { // in_sync is true if client's existing configs match those on the cloud. InSync bool `protobuf:"varint,1,opt,name=in_sync,json=inSync,proto3" json:"in_sync,omitempty"` // contains filtered or unexported fields }
func (*CheckInSyncResponse) Descriptor
deprecated
func (*CheckInSyncResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckInSyncResponse.ProtoReflect.Descriptor instead.
func (*CheckInSyncResponse) GetInSync ¶
func (x *CheckInSyncResponse) GetInSync() bool
func (*CheckInSyncResponse) ProtoMessage ¶
func (*CheckInSyncResponse) ProtoMessage()
func (*CheckInSyncResponse) ProtoReflect ¶
func (x *CheckInSyncResponse) ProtoReflect() protoreflect.Message
func (*CheckInSyncResponse) Reset ¶
func (x *CheckInSyncResponse) Reset()
func (*CheckInSyncResponse) String ¶
func (x *CheckInSyncResponse) String() string
type CoreNetworkType ¶
type CoreNetworkType struct { // Network Types to be restricted per subscriber. If not configured, Subscriber will have access to all Network Types by default. ForbiddenNetworkTypes []CoreNetworkType_CoreNetworkTypes `` /* 182-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CoreNetworkType) Descriptor
deprecated
func (*CoreNetworkType) Descriptor() ([]byte, []int)
Deprecated: Use CoreNetworkType.ProtoReflect.Descriptor instead.
func (*CoreNetworkType) GetForbiddenNetworkTypes ¶
func (x *CoreNetworkType) GetForbiddenNetworkTypes() []CoreNetworkType_CoreNetworkTypes
func (*CoreNetworkType) ProtoMessage ¶
func (*CoreNetworkType) ProtoMessage()
func (*CoreNetworkType) ProtoReflect ¶
func (x *CoreNetworkType) ProtoReflect() protoreflect.Message
func (*CoreNetworkType) Reset ¶
func (x *CoreNetworkType) Reset()
func (*CoreNetworkType) String ¶
func (x *CoreNetworkType) String() string
type CoreNetworkType_CoreNetworkTypes ¶
type CoreNetworkType_CoreNetworkTypes int32
const ( CoreNetworkType_NT_EPC CoreNetworkType_CoreNetworkTypes = 0 CoreNetworkType_NT_5GC CoreNetworkType_CoreNetworkTypes = 1 )
func (CoreNetworkType_CoreNetworkTypes) Descriptor ¶
func (CoreNetworkType_CoreNetworkTypes) Descriptor() protoreflect.EnumDescriptor
func (CoreNetworkType_CoreNetworkTypes) Enum ¶
func (x CoreNetworkType_CoreNetworkTypes) Enum() *CoreNetworkType_CoreNetworkTypes
func (CoreNetworkType_CoreNetworkTypes) EnumDescriptor
deprecated
func (CoreNetworkType_CoreNetworkTypes) EnumDescriptor() ([]byte, []int)
Deprecated: Use CoreNetworkType_CoreNetworkTypes.Descriptor instead.
func (CoreNetworkType_CoreNetworkTypes) Number ¶
func (x CoreNetworkType_CoreNetworkTypes) Number() protoreflect.EnumNumber
func (CoreNetworkType_CoreNetworkTypes) String ¶
func (x CoreNetworkType_CoreNetworkTypes) String() string
func (CoreNetworkType_CoreNetworkTypes) Type ¶
func (CoreNetworkType_CoreNetworkTypes) Type() protoreflect.EnumType
type GSMSubscription ¶
type GSMSubscription struct { State GSMSubscription_GSMSubscriptionState `protobuf:"varint,1,opt,name=state,proto3,enum=magma.lte.GSMSubscription_GSMSubscriptionState" json:"state,omitempty"` AuthAlgo GSMSubscription_GSMAuthAlgo `` /* 129-byte string literal not displayed */ // Authentication key (ki). Need for A3/A8 algos. This is not used // when the auth_algo is PRECOMPUTED_AUTH_TUPLES. AuthKey []byte `protobuf:"bytes,3,opt,name=auth_key,json=authKey,proto3" json:"auth_key,omitempty"` // Precomputed (rand, sres, kc) tuples. Used when the auth_algo is // PRECOMPUTED_AUTH_TUPLES. AuthTuples [][]byte `protobuf:"bytes,4,rep,name=auth_tuples,json=authTuples,proto3" json:"auth_tuples,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- GSM/LTE subscription info --------------------------------------------------------------------------
func (*GSMSubscription) Descriptor
deprecated
func (*GSMSubscription) Descriptor() ([]byte, []int)
Deprecated: Use GSMSubscription.ProtoReflect.Descriptor instead.
func (*GSMSubscription) GetAuthAlgo ¶
func (x *GSMSubscription) GetAuthAlgo() GSMSubscription_GSMAuthAlgo
func (*GSMSubscription) GetAuthKey ¶
func (x *GSMSubscription) GetAuthKey() []byte
func (*GSMSubscription) GetAuthTuples ¶
func (x *GSMSubscription) GetAuthTuples() [][]byte
func (*GSMSubscription) GetState ¶
func (x *GSMSubscription) GetState() GSMSubscription_GSMSubscriptionState
func (*GSMSubscription) ProtoMessage ¶
func (*GSMSubscription) ProtoMessage()
func (*GSMSubscription) ProtoReflect ¶
func (x *GSMSubscription) ProtoReflect() protoreflect.Message
func (*GSMSubscription) Reset ¶
func (x *GSMSubscription) Reset()
func (*GSMSubscription) String ¶
func (x *GSMSubscription) String() string
type GSMSubscription_GSMAuthAlgo ¶
type GSMSubscription_GSMAuthAlgo int32
const (
GSMSubscription_PRECOMPUTED_AUTH_TUPLES GSMSubscription_GSMAuthAlgo = 0 // default
)
func (GSMSubscription_GSMAuthAlgo) Descriptor ¶
func (GSMSubscription_GSMAuthAlgo) Descriptor() protoreflect.EnumDescriptor
func (GSMSubscription_GSMAuthAlgo) Enum ¶
func (x GSMSubscription_GSMAuthAlgo) Enum() *GSMSubscription_GSMAuthAlgo
func (GSMSubscription_GSMAuthAlgo) EnumDescriptor
deprecated
func (GSMSubscription_GSMAuthAlgo) EnumDescriptor() ([]byte, []int)
Deprecated: Use GSMSubscription_GSMAuthAlgo.Descriptor instead.
func (GSMSubscription_GSMAuthAlgo) Number ¶
func (x GSMSubscription_GSMAuthAlgo) Number() protoreflect.EnumNumber
func (GSMSubscription_GSMAuthAlgo) String ¶
func (x GSMSubscription_GSMAuthAlgo) String() string
func (GSMSubscription_GSMAuthAlgo) Type ¶
func (GSMSubscription_GSMAuthAlgo) Type() protoreflect.EnumType
type GSMSubscription_GSMSubscriptionState ¶
type GSMSubscription_GSMSubscriptionState int32
const ( GSMSubscription_INACTIVE GSMSubscription_GSMSubscriptionState = 0 GSMSubscription_ACTIVE GSMSubscription_GSMSubscriptionState = 1 )
func (GSMSubscription_GSMSubscriptionState) Descriptor ¶
func (GSMSubscription_GSMSubscriptionState) Descriptor() protoreflect.EnumDescriptor
func (GSMSubscription_GSMSubscriptionState) Enum ¶
func (x GSMSubscription_GSMSubscriptionState) Enum() *GSMSubscription_GSMSubscriptionState
func (GSMSubscription_GSMSubscriptionState) EnumDescriptor
deprecated
func (GSMSubscription_GSMSubscriptionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use GSMSubscription_GSMSubscriptionState.Descriptor instead.
func (GSMSubscription_GSMSubscriptionState) Number ¶
func (x GSMSubscription_GSMSubscriptionState) Number() protoreflect.EnumNumber
func (GSMSubscription_GSMSubscriptionState) String ¶
func (x GSMSubscription_GSMSubscriptionState) String() string
func (GSMSubscription_GSMSubscriptionState) Type ¶
func (GSMSubscription_GSMSubscriptionState) Type() protoreflect.EnumType
type LTESubscription ¶
type LTESubscription struct { State LTESubscription_LTESubscriptionState `protobuf:"varint,1,opt,name=state,proto3,enum=magma.lte.LTESubscription_LTESubscriptionState" json:"state,omitempty"` AuthAlgo LTESubscription_LTEAuthAlgo `` /* 129-byte string literal not displayed */ // Authentication key (k). AuthKey []byte `protobuf:"bytes,3,opt,name=auth_key,json=authKey,proto3" json:"auth_key,omitempty"` // Operator configuration field (Op) signed with authentication key (k) AuthOpc []byte `protobuf:"bytes,4,opt,name=auth_opc,json=authOpc,proto3" json:"auth_opc,omitempty"` AssignedBaseNames []string `protobuf:"bytes,10,rep,name=assigned_base_names,json=assignedBaseNames,proto3" json:"assigned_base_names,omitempty"` AssignedPolicies []string `protobuf:"bytes,11,rep,name=assigned_policies,json=assignedPolicies,proto3" json:"assigned_policies,omitempty"` // contains filtered or unexported fields }
func (*LTESubscription) Descriptor
deprecated
func (*LTESubscription) Descriptor() ([]byte, []int)
Deprecated: Use LTESubscription.ProtoReflect.Descriptor instead.
func (*LTESubscription) GetAssignedBaseNames ¶
func (x *LTESubscription) GetAssignedBaseNames() []string
func (*LTESubscription) GetAssignedPolicies ¶
func (x *LTESubscription) GetAssignedPolicies() []string
func (*LTESubscription) GetAuthAlgo ¶
func (x *LTESubscription) GetAuthAlgo() LTESubscription_LTEAuthAlgo
func (*LTESubscription) GetAuthKey ¶
func (x *LTESubscription) GetAuthKey() []byte
func (*LTESubscription) GetAuthOpc ¶
func (x *LTESubscription) GetAuthOpc() []byte
func (*LTESubscription) GetState ¶
func (x *LTESubscription) GetState() LTESubscription_LTESubscriptionState
func (*LTESubscription) ProtoMessage ¶
func (*LTESubscription) ProtoMessage()
func (*LTESubscription) ProtoReflect ¶
func (x *LTESubscription) ProtoReflect() protoreflect.Message
func (*LTESubscription) Reset ¶
func (x *LTESubscription) Reset()
func (*LTESubscription) String ¶
func (x *LTESubscription) String() string
type LTESubscription_LTEAuthAlgo ¶
type LTESubscription_LTEAuthAlgo int32
const (
LTESubscription_MILENAGE LTESubscription_LTEAuthAlgo = 0 // default
)
func (LTESubscription_LTEAuthAlgo) Descriptor ¶
func (LTESubscription_LTEAuthAlgo) Descriptor() protoreflect.EnumDescriptor
func (LTESubscription_LTEAuthAlgo) Enum ¶
func (x LTESubscription_LTEAuthAlgo) Enum() *LTESubscription_LTEAuthAlgo
func (LTESubscription_LTEAuthAlgo) EnumDescriptor
deprecated
func (LTESubscription_LTEAuthAlgo) EnumDescriptor() ([]byte, []int)
Deprecated: Use LTESubscription_LTEAuthAlgo.Descriptor instead.
func (LTESubscription_LTEAuthAlgo) Number ¶
func (x LTESubscription_LTEAuthAlgo) Number() protoreflect.EnumNumber
func (LTESubscription_LTEAuthAlgo) String ¶
func (x LTESubscription_LTEAuthAlgo) String() string
func (LTESubscription_LTEAuthAlgo) Type ¶
func (LTESubscription_LTEAuthAlgo) Type() protoreflect.EnumType
type LTESubscription_LTESubscriptionState ¶
type LTESubscription_LTESubscriptionState int32
const ( LTESubscription_INACTIVE LTESubscription_LTESubscriptionState = 0 LTESubscription_ACTIVE LTESubscription_LTESubscriptionState = 1 )
func (LTESubscription_LTESubscriptionState) Descriptor ¶
func (LTESubscription_LTESubscriptionState) Descriptor() protoreflect.EnumDescriptor
func (LTESubscription_LTESubscriptionState) Enum ¶
func (x LTESubscription_LTESubscriptionState) Enum() *LTESubscription_LTESubscriptionState
func (LTESubscription_LTESubscriptionState) EnumDescriptor
deprecated
func (LTESubscription_LTESubscriptionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use LTESubscription_LTESubscriptionState.Descriptor instead.
func (LTESubscription_LTESubscriptionState) Number ¶
func (x LTESubscription_LTESubscriptionState) Number() protoreflect.EnumNumber
func (LTESubscription_LTESubscriptionState) String ¶
func (x LTESubscription_LTESubscriptionState) String() string
func (LTESubscription_LTESubscriptionState) Type ¶
func (LTESubscription_LTESubscriptionState) Type() protoreflect.EnumType
type ListSubscribersRequest ¶
type ListSubscribersRequest struct { // page_size is the maximum number of entities returned per request. PageSize uint32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // page_token is a serialized entity page token for paginated loads. PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*ListSubscribersRequest) Descriptor
deprecated
func (*ListSubscribersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscribersRequest.ProtoReflect.Descriptor instead.
func (*ListSubscribersRequest) GetPageSize ¶
func (x *ListSubscribersRequest) GetPageSize() uint32
func (*ListSubscribersRequest) GetPageToken ¶
func (x *ListSubscribersRequest) GetPageToken() string
func (*ListSubscribersRequest) ProtoMessage ¶
func (*ListSubscribersRequest) ProtoMessage()
func (*ListSubscribersRequest) ProtoReflect ¶
func (x *ListSubscribersRequest) ProtoReflect() protoreflect.Message
func (*ListSubscribersRequest) Reset ¶
func (x *ListSubscribersRequest) Reset()
func (*ListSubscribersRequest) String ¶
func (x *ListSubscribersRequest) String() string
type ListSubscribersResponse ¶
type ListSubscribersResponse struct { Subscribers []*SubscriberData `protobuf:"bytes,1,rep,name=subscribers,proto3" json:"subscribers,omitempty"` // next_page_token is a serialized entity page token for subsequent paginated // loads. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // digests contains all digests for the network. Digests *orc8r.DigestTree `protobuf:"bytes,5,opt,name=digests,proto3" json:"digests,omitempty"` // contains filtered or unexported fields }
func (*ListSubscribersResponse) Descriptor
deprecated
func (*ListSubscribersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscribersResponse.ProtoReflect.Descriptor instead.
func (*ListSubscribersResponse) GetDigests ¶
func (x *ListSubscribersResponse) GetDigests() *orc8r.DigestTree
func (*ListSubscribersResponse) GetNextPageToken ¶
func (x *ListSubscribersResponse) GetNextPageToken() string
func (*ListSubscribersResponse) GetSubscribers ¶
func (x *ListSubscribersResponse) GetSubscribers() []*SubscriberData
func (*ListSubscribersResponse) ProtoMessage ¶
func (*ListSubscribersResponse) ProtoMessage()
func (*ListSubscribersResponse) ProtoReflect ¶
func (x *ListSubscribersResponse) ProtoReflect() protoreflect.Message
func (*ListSubscribersResponse) Reset ¶
func (x *ListSubscribersResponse) Reset()
func (*ListSubscribersResponse) String ¶
func (x *ListSubscribersResponse) String() string
type Non3GPPUserProfile ¶
type Non3GPPUserProfile struct { Msisdn string `protobuf:"bytes,1,opt,name=msisdn,proto3" json:"msisdn,omitempty"` Non_3GppIpAccess Non3GPPUserProfile_Non3GPPIPAccess `` /* 161-byte string literal not displayed */ Non_3GppIpAccessApn Non3GPPUserProfile_Non3GPPIPAccessAPN `` /* 175-byte string literal not displayed */ Ambr *apn.AggregatedMaximumBitrate `protobuf:"bytes,4,opt,name=ambr,proto3" json:"ambr,omitempty"` ApnConfig []*apn.APNConfiguration `protobuf:"bytes,5,rep,name=apn_config,json=apnConfig,proto3" json:"apn_config,omitempty"` AccessNetId AccessNetworkIdentifier `` /* 136-byte string literal not displayed */ // subscriber specific APN config SubscriberApnConfig []*SubscriberAPNConfig `protobuf:"bytes,7,rep,name=subscriber_apn_config,json=subscriberApnConfig,proto3" json:"subscriber_apn_config,omitempty"` // contains filtered or unexported fields }
func (*Non3GPPUserProfile) Descriptor
deprecated
func (*Non3GPPUserProfile) Descriptor() ([]byte, []int)
Deprecated: Use Non3GPPUserProfile.ProtoReflect.Descriptor instead.
func (*Non3GPPUserProfile) GetAccessNetId ¶
func (x *Non3GPPUserProfile) GetAccessNetId() AccessNetworkIdentifier
func (*Non3GPPUserProfile) GetAmbr ¶
func (x *Non3GPPUserProfile) GetAmbr() *apn.AggregatedMaximumBitrate
func (*Non3GPPUserProfile) GetApnConfig ¶
func (x *Non3GPPUserProfile) GetApnConfig() []*apn.APNConfiguration
func (*Non3GPPUserProfile) GetMsisdn ¶
func (x *Non3GPPUserProfile) GetMsisdn() string
func (*Non3GPPUserProfile) GetNon_3GppIpAccess ¶
func (x *Non3GPPUserProfile) GetNon_3GppIpAccess() Non3GPPUserProfile_Non3GPPIPAccess
func (*Non3GPPUserProfile) GetNon_3GppIpAccessApn ¶
func (x *Non3GPPUserProfile) GetNon_3GppIpAccessApn() Non3GPPUserProfile_Non3GPPIPAccessAPN
func (*Non3GPPUserProfile) GetSubscriberApnConfig ¶
func (x *Non3GPPUserProfile) GetSubscriberApnConfig() []*SubscriberAPNConfig
func (*Non3GPPUserProfile) ProtoMessage ¶
func (*Non3GPPUserProfile) ProtoMessage()
func (*Non3GPPUserProfile) ProtoReflect ¶
func (x *Non3GPPUserProfile) ProtoReflect() protoreflect.Message
func (*Non3GPPUserProfile) Reset ¶
func (x *Non3GPPUserProfile) Reset()
func (*Non3GPPUserProfile) String ¶
func (x *Non3GPPUserProfile) String() string
type Non3GPPUserProfile_Non3GPPIPAccess ¶
type Non3GPPUserProfile_Non3GPPIPAccess int32
const ( // Subscriber has non-3GPP subscription access to EPC network Non3GPPUserProfile_NON_3GPP_SUBSCRIPTION_ALLOWED Non3GPPUserProfile_Non3GPPIPAccess = 0 // Subscriber has no non-3GPP subscription access to EPC network Non3GPPUserProfile_NON_3GPP_SUBSCRIPTION_BARRED Non3GPPUserProfile_Non3GPPIPAccess = 1 )
func (Non3GPPUserProfile_Non3GPPIPAccess) Descriptor ¶
func (Non3GPPUserProfile_Non3GPPIPAccess) Descriptor() protoreflect.EnumDescriptor
func (Non3GPPUserProfile_Non3GPPIPAccess) Enum ¶
func (x Non3GPPUserProfile_Non3GPPIPAccess) Enum() *Non3GPPUserProfile_Non3GPPIPAccess
func (Non3GPPUserProfile_Non3GPPIPAccess) EnumDescriptor
deprecated
func (Non3GPPUserProfile_Non3GPPIPAccess) EnumDescriptor() ([]byte, []int)
Deprecated: Use Non3GPPUserProfile_Non3GPPIPAccess.Descriptor instead.
func (Non3GPPUserProfile_Non3GPPIPAccess) Number ¶
func (x Non3GPPUserProfile_Non3GPPIPAccess) Number() protoreflect.EnumNumber
func (Non3GPPUserProfile_Non3GPPIPAccess) String ¶
func (x Non3GPPUserProfile_Non3GPPIPAccess) String() string
func (Non3GPPUserProfile_Non3GPPIPAccess) Type ¶
func (Non3GPPUserProfile_Non3GPPIPAccess) Type() protoreflect.EnumType
type Non3GPPUserProfile_Non3GPPIPAccessAPN ¶
type Non3GPPUserProfile_Non3GPPIPAccessAPN int32
const ( // Enable all APNs for a subscriber Non3GPPUserProfile_NON_3GPP_APNS_ENABLE Non3GPPUserProfile_Non3GPPIPAccessAPN = 0 // Disable all APNs for a subscriber Non3GPPUserProfile_NON_3GPP_APNS_DISABLE Non3GPPUserProfile_Non3GPPIPAccessAPN = 1 )
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Descriptor ¶
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Descriptor() protoreflect.EnumDescriptor
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) EnumDescriptor
deprecated
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) EnumDescriptor() ([]byte, []int)
Deprecated: Use Non3GPPUserProfile_Non3GPPIPAccessAPN.Descriptor instead.
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Number ¶
func (x Non3GPPUserProfile_Non3GPPIPAccessAPN) Number() protoreflect.EnumNumber
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) String ¶
func (x Non3GPPUserProfile_Non3GPPIPAccessAPN) String() string
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Type ¶
func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Type() protoreflect.EnumType
type SubscriberAPNConfig ¶
type SubscriberAPNConfig struct { ApnId uint32 `protobuf:"varint,1,opt,name=apn_id,json=apnId,proto3" json:"apn_id,omitempty"` AssignedStaticIp string `protobuf:"bytes,2,opt,name=assigned_static_ip,json=assignedStaticIp,proto3" json:"assigned_static_ip,omitempty"` // contains filtered or unexported fields }
func (*SubscriberAPNConfig) Descriptor
deprecated
func (*SubscriberAPNConfig) Descriptor() ([]byte, []int)
Deprecated: Use SubscriberAPNConfig.ProtoReflect.Descriptor instead.
func (*SubscriberAPNConfig) GetApnId ¶
func (x *SubscriberAPNConfig) GetApnId() uint32
func (*SubscriberAPNConfig) GetAssignedStaticIp ¶
func (x *SubscriberAPNConfig) GetAssignedStaticIp() string
func (*SubscriberAPNConfig) ProtoMessage ¶
func (*SubscriberAPNConfig) ProtoMessage()
func (*SubscriberAPNConfig) ProtoReflect ¶
func (x *SubscriberAPNConfig) ProtoReflect() protoreflect.Message
func (*SubscriberAPNConfig) Reset ¶
func (x *SubscriberAPNConfig) Reset()
func (*SubscriberAPNConfig) String ¶
func (x *SubscriberAPNConfig) String() string
type SubscriberDBClient ¶
type SubscriberDBClient interface { // Adds a new subscriber to the store. // Throws ALREADY_EXISTS if the subscriber already exists. // AddSubscriber(ctx context.Context, in *SubscriberData, opts ...grpc.CallOption) (*orc8r.Void, error) // Deletes an existing subscriber. // If the subscriber is not already present, this request is ignored. // DeleteSubscriber(ctx context.Context, in *SubscriberID, opts ...grpc.CallOption) (*orc8r.Void, error) // Updates an existing subscriber. // Throws NOT_FOUND if the subscriber is missing. // UpdateSubscriber(ctx context.Context, in *SubscriberUpdate, opts ...grpc.CallOption) (*orc8r.Void, error) // Returns the SubscriberData for a subscriber. // Throws NOT_FOUND if the subscriber is missing. // GetSubscriberData(ctx context.Context, in *SubscriberID, opts ...grpc.CallOption) (*SubscriberData, error) // List the subscribers in the store. // ListSubscribers(ctx context.Context, in *orc8r.Void, opts ...grpc.CallOption) (*SubscriberIDSet, error) }
SubscriberDBClient is the client API for SubscriberDB service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSubscriberDBClient ¶
func NewSubscriberDBClient(cc grpc.ClientConnInterface) SubscriberDBClient
type SubscriberDBCloudClient ¶
type SubscriberDBCloudClient interface { // CheckSubscribersInSync checks whether the client subscribers flat digest // is up-to-date. CheckInSync(ctx context.Context, in *CheckInSyncRequest, opts ...grpc.CallOption) (*CheckInSyncResponse, error) // SyncSubscribers returns the changeset of subscribers between client and // cloud if the set is small; if the set is large, returns signal to resync. Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error) // ListSubscribers lists pages of subscribers stored. ListSubscribers(ctx context.Context, in *ListSubscribersRequest, opts ...grpc.CallOption) (*ListSubscribersResponse, error) }
SubscriberDBCloudClient is the client API for SubscriberDBCloud service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSubscriberDBCloudClient ¶
func NewSubscriberDBCloudClient(cc grpc.ClientConnInterface) SubscriberDBCloudClient
type SubscriberDBCloudServer ¶
type SubscriberDBCloudServer interface { // CheckSubscribersInSync checks whether the client subscribers flat digest // is up-to-date. CheckInSync(context.Context, *CheckInSyncRequest) (*CheckInSyncResponse, error) // SyncSubscribers returns the changeset of subscribers between client and // cloud if the set is small; if the set is large, returns signal to resync. Sync(context.Context, *SyncRequest) (*SyncResponse, error) // ListSubscribers lists pages of subscribers stored. ListSubscribers(context.Context, *ListSubscribersRequest) (*ListSubscribersResponse, error) // contains filtered or unexported methods }
SubscriberDBCloudServer is the server API for SubscriberDBCloud service. All implementations must embed UnimplementedSubscriberDBCloudServer for forward compatibility
type SubscriberDBServer ¶
type SubscriberDBServer interface { // Adds a new subscriber to the store. // Throws ALREADY_EXISTS if the subscriber already exists. // AddSubscriber(context.Context, *SubscriberData) (*orc8r.Void, error) // Deletes an existing subscriber. // If the subscriber is not already present, this request is ignored. // DeleteSubscriber(context.Context, *SubscriberID) (*orc8r.Void, error) // Updates an existing subscriber. // Throws NOT_FOUND if the subscriber is missing. // UpdateSubscriber(context.Context, *SubscriberUpdate) (*orc8r.Void, error) // Returns the SubscriberData for a subscriber. // Throws NOT_FOUND if the subscriber is missing. // GetSubscriberData(context.Context, *SubscriberID) (*SubscriberData, error) // List the subscribers in the store. // ListSubscribers(context.Context, *orc8r.Void) (*SubscriberIDSet, error) // contains filtered or unexported methods }
SubscriberDBServer is the server API for SubscriberDB service. All implementations must embed UnimplementedSubscriberDBServer for forward compatibility
type SubscriberData ¶
type SubscriberData struct { // Unique indentifier for the subscriber Sid *SubscriberID `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Gsm *GSMSubscription `protobuf:"bytes,2,opt,name=gsm,proto3" json:"gsm,omitempty"` Lte *LTESubscription `protobuf:"bytes,3,opt,name=lte,proto3" json:"lte,omitempty"` NetworkId *orc8r.NetworkID `protobuf:"bytes,4,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` State *SubscriberState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"` // Subscription profile SubProfile string `protobuf:"bytes,6,opt,name=sub_profile,json=subProfile,proto3" json:"sub_profile,omitempty"` Non_3Gpp *Non3GPPUserProfile `protobuf:"bytes,7,opt,name=non_3gpp,json=non3gpp,proto3" json:"non_3gpp,omitempty"` SubNetwork *CoreNetworkType `protobuf:"bytes,8,opt,name=sub_network,json=subNetwork,proto3" json:"sub_network,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- User subscription record. This record is serialized and stored in the DB. --------------------------------------------------------------------------
func (*SubscriberData) Descriptor
deprecated
func (*SubscriberData) Descriptor() ([]byte, []int)
Deprecated: Use SubscriberData.ProtoReflect.Descriptor instead.
func (*SubscriberData) GetGsm ¶
func (x *SubscriberData) GetGsm() *GSMSubscription
func (*SubscriberData) GetLte ¶
func (x *SubscriberData) GetLte() *LTESubscription
func (*SubscriberData) GetNetworkId ¶
func (x *SubscriberData) GetNetworkId() *orc8r.NetworkID
func (*SubscriberData) GetNon_3Gpp ¶
func (x *SubscriberData) GetNon_3Gpp() *Non3GPPUserProfile
func (*SubscriberData) GetSid ¶
func (x *SubscriberData) GetSid() *SubscriberID
func (*SubscriberData) GetState ¶
func (x *SubscriberData) GetState() *SubscriberState
func (*SubscriberData) GetSubNetwork ¶
func (x *SubscriberData) GetSubNetwork() *CoreNetworkType
func (*SubscriberData) GetSubProfile ¶
func (x *SubscriberData) GetSubProfile() string
func (*SubscriberData) ProtoMessage ¶
func (*SubscriberData) ProtoMessage()
func (*SubscriberData) ProtoReflect ¶
func (x *SubscriberData) ProtoReflect() protoreflect.Message
func (*SubscriberData) Reset ¶
func (x *SubscriberData) Reset()
func (*SubscriberData) String ¶
func (x *SubscriberData) String() string
type SubscriberID ¶
type SubscriberID struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type SubscriberID_IDType `protobuf:"varint,2,opt,name=type,proto3,enum=magma.lte.SubscriberID_IDType" json:"type,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- SubscriberID (or SID) uniquely identifies the subscriber across the system --------------------------------------------------------------------------
func (*SubscriberID) Descriptor
deprecated
func (*SubscriberID) Descriptor() ([]byte, []int)
Deprecated: Use SubscriberID.ProtoReflect.Descriptor instead.
func (*SubscriberID) GetId ¶
func (x *SubscriberID) GetId() string
func (*SubscriberID) GetType ¶
func (x *SubscriberID) GetType() SubscriberID_IDType
func (*SubscriberID) ProtoMessage ¶
func (*SubscriberID) ProtoMessage()
func (*SubscriberID) ProtoReflect ¶
func (x *SubscriberID) ProtoReflect() protoreflect.Message
func (*SubscriberID) Reset ¶
func (x *SubscriberID) Reset()
func (*SubscriberID) String ¶
func (x *SubscriberID) String() string
type SubscriberIDSet ¶
type SubscriberIDSet struct { Sids []*SubscriberID `protobuf:"bytes,1,rep,name=sids,proto3" json:"sids,omitempty"` // contains filtered or unexported fields }
func (*SubscriberIDSet) Descriptor
deprecated
func (*SubscriberIDSet) Descriptor() ([]byte, []int)
Deprecated: Use SubscriberIDSet.ProtoReflect.Descriptor instead.
func (*SubscriberIDSet) GetSids ¶
func (x *SubscriberIDSet) GetSids() []*SubscriberID
func (*SubscriberIDSet) ProtoMessage ¶
func (*SubscriberIDSet) ProtoMessage()
func (*SubscriberIDSet) ProtoReflect ¶
func (x *SubscriberIDSet) ProtoReflect() protoreflect.Message
func (*SubscriberIDSet) Reset ¶
func (x *SubscriberIDSet) Reset()
func (*SubscriberIDSet) String ¶
func (x *SubscriberIDSet) String() string
type SubscriberID_IDType ¶
type SubscriberID_IDType int32
const (
SubscriberID_IMSI SubscriberID_IDType = 0
)
func (SubscriberID_IDType) Descriptor ¶
func (SubscriberID_IDType) Descriptor() protoreflect.EnumDescriptor
func (SubscriberID_IDType) Enum ¶
func (x SubscriberID_IDType) Enum() *SubscriberID_IDType
func (SubscriberID_IDType) EnumDescriptor
deprecated
func (SubscriberID_IDType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscriberID_IDType.Descriptor instead.
func (SubscriberID_IDType) Number ¶
func (x SubscriberID_IDType) Number() protoreflect.EnumNumber
func (SubscriberID_IDType) String ¶
func (x SubscriberID_IDType) String() string
func (SubscriberID_IDType) Type ¶
func (SubscriberID_IDType) Type() protoreflect.EnumType
type SubscriberState ¶
type SubscriberState struct { // Next SEQ to be used for calculating the AUTN. LteAuthNextSeq uint64 `protobuf:"varint,1,opt,name=lte_auth_next_seq,json=lteAuthNextSeq,proto3" json:"lte_auth_next_seq,omitempty"` // The Diameter address of the 3GPP AAA Server which is serving the user. // An empty string indicates that no server is currently serving the user. TgppAaaServerName string `protobuf:"bytes,2,opt,name=tgpp_aaa_server_name,json=tgppAaaServerName,proto3" json:"tgpp_aaa_server_name,omitempty"` // Whether the subscribers User Status is REGISTERED or NOT_REGISTERED. TgppAaaServerRegistered bool `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SubscriberState) Descriptor
deprecated
func (*SubscriberState) Descriptor() ([]byte, []int)
Deprecated: Use SubscriberState.ProtoReflect.Descriptor instead.
func (*SubscriberState) GetLteAuthNextSeq ¶
func (x *SubscriberState) GetLteAuthNextSeq() uint64
func (*SubscriberState) GetTgppAaaServerName ¶
func (x *SubscriberState) GetTgppAaaServerName() string
func (*SubscriberState) GetTgppAaaServerRegistered ¶
func (x *SubscriberState) GetTgppAaaServerRegistered() bool
func (*SubscriberState) ProtoMessage ¶
func (*SubscriberState) ProtoMessage()
func (*SubscriberState) ProtoReflect ¶
func (x *SubscriberState) ProtoReflect() protoreflect.Message
func (*SubscriberState) Reset ¶
func (x *SubscriberState) Reset()
func (*SubscriberState) String ¶
func (x *SubscriberState) String() string
type SubscriberUpdate ¶
type SubscriberUpdate struct { // Updated subscription data Data *SubscriberData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Specifies the fields to be updated // The mask can be individual subscription elements (Eg: 'lte.auth_key') or // entire subset in the SubscriberData (Eg: 'lte' to update all lte.* fields) Mask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=mask,proto3" json:"mask,omitempty"` // contains filtered or unexported fields }
func (*SubscriberUpdate) Descriptor
deprecated
func (*SubscriberUpdate) Descriptor() ([]byte, []int)
Deprecated: Use SubscriberUpdate.ProtoReflect.Descriptor instead.
func (*SubscriberUpdate) GetData ¶
func (x *SubscriberUpdate) GetData() *SubscriberData
func (*SubscriberUpdate) GetMask ¶
func (x *SubscriberUpdate) GetMask() *fieldmaskpb.FieldMask
func (*SubscriberUpdate) ProtoMessage ¶
func (*SubscriberUpdate) ProtoMessage()
func (*SubscriberUpdate) ProtoReflect ¶
func (x *SubscriberUpdate) ProtoReflect() protoreflect.Message
func (*SubscriberUpdate) Reset ¶
func (x *SubscriberUpdate) Reset()
func (*SubscriberUpdate) String ¶
func (x *SubscriberUpdate) String() string
type SyncRequest ¶
type SyncRequest struct { // leaf_digests contains a list of digests for each client-side config object, // ordered by their IDs. LeafDigests []*orc8r.LeafDigest `protobuf:"bytes,1,rep,name=leaf_digests,json=leafDigests,proto3" json:"leaf_digests,omitempty"` // contains filtered or unexported fields }
func (*SyncRequest) Descriptor
deprecated
func (*SyncRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.
func (*SyncRequest) GetLeafDigests ¶
func (x *SyncRequest) GetLeafDigests() []*orc8r.LeafDigest
func (*SyncRequest) ProtoMessage ¶
func (*SyncRequest) ProtoMessage()
func (*SyncRequest) ProtoReflect ¶
func (x *SyncRequest) ProtoReflect() protoreflect.Message
func (*SyncRequest) Reset ¶
func (x *SyncRequest) Reset()
func (*SyncRequest) String ¶
func (x *SyncRequest) String() string
type SyncResponse ¶
type SyncResponse struct { // resync is true if the client-server data difference is too big and an // overall resync is needed. If true, all subscriber changesets will be empty. Resync bool `protobuf:"varint,1,opt,name=resync,proto3" json:"resync,omitempty"` // digests contains all digests for the network. Digests *orc8r.DigestTree `protobuf:"bytes,2,opt,name=digests,proto3" json:"digests,omitempty"` // changeset contains the client-server data difference. Changeset *orc8r.Changeset `protobuf:"bytes,3,opt,name=changeset,proto3" json:"changeset,omitempty"` // contains filtered or unexported fields }
func (*SyncResponse) Descriptor
deprecated
func (*SyncResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.
func (*SyncResponse) GetChangeset ¶
func (x *SyncResponse) GetChangeset() *orc8r.Changeset
func (*SyncResponse) GetDigests ¶
func (x *SyncResponse) GetDigests() *orc8r.DigestTree
func (*SyncResponse) GetResync ¶
func (x *SyncResponse) GetResync() bool
func (*SyncResponse) ProtoMessage ¶
func (*SyncResponse) ProtoMessage()
func (*SyncResponse) ProtoReflect ¶
func (x *SyncResponse) ProtoReflect() protoreflect.Message
func (*SyncResponse) Reset ¶
func (x *SyncResponse) Reset()
func (*SyncResponse) String ¶
func (x *SyncResponse) String() string
type UnimplementedSubscriberDBCloudServer ¶
type UnimplementedSubscriberDBCloudServer struct { }
UnimplementedSubscriberDBCloudServer must be embedded to have forward compatible implementations.
func (UnimplementedSubscriberDBCloudServer) CheckInSync ¶
func (UnimplementedSubscriberDBCloudServer) CheckInSync(context.Context, *CheckInSyncRequest) (*CheckInSyncResponse, error)
func (UnimplementedSubscriberDBCloudServer) ListSubscribers ¶
func (UnimplementedSubscriberDBCloudServer) ListSubscribers(context.Context, *ListSubscribersRequest) (*ListSubscribersResponse, error)
func (UnimplementedSubscriberDBCloudServer) Sync ¶
func (UnimplementedSubscriberDBCloudServer) Sync(context.Context, *SyncRequest) (*SyncResponse, error)
type UnimplementedSubscriberDBServer ¶
type UnimplementedSubscriberDBServer struct { }
UnimplementedSubscriberDBServer must be embedded to have forward compatible implementations.
func (UnimplementedSubscriberDBServer) AddSubscriber ¶
func (UnimplementedSubscriberDBServer) AddSubscriber(context.Context, *SubscriberData) (*orc8r.Void, error)
func (UnimplementedSubscriberDBServer) DeleteSubscriber ¶
func (UnimplementedSubscriberDBServer) DeleteSubscriber(context.Context, *SubscriberID) (*orc8r.Void, error)
func (UnimplementedSubscriberDBServer) GetSubscriberData ¶
func (UnimplementedSubscriberDBServer) GetSubscriberData(context.Context, *SubscriberID) (*SubscriberData, error)
func (UnimplementedSubscriberDBServer) ListSubscribers ¶
func (UnimplementedSubscriberDBServer) ListSubscribers(context.Context, *orc8r.Void) (*SubscriberIDSet, error)
func (UnimplementedSubscriberDBServer) UpdateSubscriber ¶
func (UnimplementedSubscriberDBServer) UpdateSubscriber(context.Context, *SubscriberUpdate) (*orc8r.Void, error)
type UnsafeSubscriberDBCloudServer ¶
type UnsafeSubscriberDBCloudServer interface {
// contains filtered or unexported methods
}
UnsafeSubscriberDBCloudServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscriberDBCloudServer will result in compilation errors.
type UnsafeSubscriberDBServer ¶
type UnsafeSubscriberDBServer interface {
// contains filtered or unexported methods
}
UnsafeSubscriberDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscriberDBServer will result in compilation errors.