subscriberdb

package
v0.0.0-...-341c48f Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2022 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
var (
	SubscriberID_IDType_name = map[int32]string{
		0: "IMSI",
	}
	SubscriberID_IDType_value = map[string]int32{
		"IMSI": 0,
	}
)

Enum value maps for SubscriberID_IDType.

View Source
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.

View Source
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.

View Source
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.

View Source
var (
	LTESubscription_LTEAuthAlgo_name = map[int32]string{
		0: "MILENAGE",
	}
	LTESubscription_LTEAuthAlgo_value = map[string]int32{
		"MILENAGE": 0,
	}
)

Enum value maps for LTESubscription_LTEAuthAlgo.

View Source
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.

View Source
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.

View Source
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.

View Source
var File_subscriberdb_proto protoreflect.FileDescriptor
View Source
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)

View Source
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) Enum

func (AccessNetworkIdentifier) EnumDescriptor deprecated

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

Deprecated: Use AccessNetworkIdentifier.Descriptor instead.

func (AccessNetworkIdentifier) Number

func (AccessNetworkIdentifier) String

func (x AccessNetworkIdentifier) String() string

func (AccessNetworkIdentifier) Type

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) Enum

func (CoreNetworkType_CoreNetworkTypes) EnumDescriptor deprecated

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

Deprecated: Use CoreNetworkType_CoreNetworkTypes.Descriptor instead.

func (CoreNetworkType_CoreNetworkTypes) Number

func (CoreNetworkType_CoreNetworkTypes) String

func (CoreNetworkType_CoreNetworkTypes) Type

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 (*GSMSubscription) GetAuthKey

func (x *GSMSubscription) GetAuthKey() []byte

func (*GSMSubscription) GetAuthTuples

func (x *GSMSubscription) GetAuthTuples() [][]byte

func (*GSMSubscription) GetState

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) Enum

func (GSMSubscription_GSMAuthAlgo) EnumDescriptor deprecated

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

Deprecated: Use GSMSubscription_GSMAuthAlgo.Descriptor instead.

func (GSMSubscription_GSMAuthAlgo) Number

func (GSMSubscription_GSMAuthAlgo) String

func (GSMSubscription_GSMAuthAlgo) Type

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) Enum

func (GSMSubscription_GSMSubscriptionState) EnumDescriptor deprecated

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

Deprecated: Use GSMSubscription_GSMSubscriptionState.Descriptor instead.

func (GSMSubscription_GSMSubscriptionState) Number

func (GSMSubscription_GSMSubscriptionState) String

func (GSMSubscription_GSMSubscriptionState) Type

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 (*LTESubscription) GetAuthKey

func (x *LTESubscription) GetAuthKey() []byte

func (*LTESubscription) GetAuthOpc

func (x *LTESubscription) GetAuthOpc() []byte

func (*LTESubscription) GetState

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) Enum

func (LTESubscription_LTEAuthAlgo) EnumDescriptor deprecated

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

Deprecated: Use LTESubscription_LTEAuthAlgo.Descriptor instead.

func (LTESubscription_LTEAuthAlgo) Number

func (LTESubscription_LTEAuthAlgo) String

func (LTESubscription_LTEAuthAlgo) Type

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) Enum

func (LTESubscription_LTESubscriptionState) EnumDescriptor deprecated

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

Deprecated: Use LTESubscription_LTESubscriptionState.Descriptor instead.

func (LTESubscription_LTESubscriptionState) Number

func (LTESubscription_LTESubscriptionState) String

func (LTESubscription_LTESubscriptionState) Type

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 (*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) Enum

func (Non3GPPUserProfile_Non3GPPIPAccess) EnumDescriptor deprecated

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

Deprecated: Use Non3GPPUserProfile_Non3GPPIPAccess.Descriptor instead.

func (Non3GPPUserProfile_Non3GPPIPAccess) Number

func (Non3GPPUserProfile_Non3GPPIPAccess) String

func (Non3GPPUserProfile_Non3GPPIPAccess) Type

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) Enum

func (Non3GPPUserProfile_Non3GPPIPAccessAPN) EnumDescriptor deprecated

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

Deprecated: Use Non3GPPUserProfile_Non3GPPIPAccessAPN.Descriptor instead.

func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Number

func (Non3GPPUserProfile_Non3GPPIPAccessAPN) String

func (Non3GPPUserProfile_Non3GPPIPAccessAPN) Type

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.

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.

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) Enum

func (SubscriberID_IDType) EnumDescriptor deprecated

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

Deprecated: Use SubscriberID_IDType.Descriptor instead.

func (SubscriberID_IDType) Number

func (SubscriberID_IDType) String

func (x SubscriberID_IDType) String() string

func (SubscriberID_IDType) Type

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) ListSubscribers

func (UnimplementedSubscriberDBCloudServer) Sync

type UnimplementedSubscriberDBServer

type UnimplementedSubscriberDBServer struct {
}

UnimplementedSubscriberDBServer must be embedded to have forward compatible implementations.

func (UnimplementedSubscriberDBServer) AddSubscriber

func (UnimplementedSubscriberDBServer) DeleteSubscriber

func (UnimplementedSubscriberDBServer) GetSubscriberData

func (UnimplementedSubscriberDBServer) ListSubscribers

func (UnimplementedSubscriberDBServer) UpdateSubscriber

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.

Jump to

Keyboard shortcuts

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