Versions in this module Expand all Collapse all v1 v1.1.1 Aug 18, 2020 Changes in this version + const MAGMA_ALT_NAME_TAG + var CertType_name = map[int32]string + var CertType_value = map[string]int32 + var ChallengeKey_KeyType_name = map[int32]string + var ChallengeKey_KeyType_value = map[string]int32 + var File_bootstrapper_proto protoreflect.FileDescriptor + var File_certifier_proto protoreflect.FileDescriptor + var File_common_proto protoreflect.FileDescriptor + var File_directoryd_proto protoreflect.FileDescriptor + var File_eventd_proto protoreflect.FileDescriptor + var File_identity_proto protoreflect.FileDescriptor + var File_magmad_proto protoreflect.FileDescriptor + var File_mconfig_proto protoreflect.FileDescriptor + var File_metricsd_proto protoreflect.FileDescriptor + var File_redis_proto protoreflect.FileDescriptor + var File_service303_proto protoreflect.FileDescriptor + var File_service_status_proto protoreflect.FileDescriptor + var File_state_proto protoreflect.FileDescriptor + var File_streamer_proto protoreflect.FileDescriptor + var File_sync_rpc_service_proto protoreflect.FileDescriptor + var File_tenants_proto protoreflect.FileDescriptor + var Identity_Wildcard_Type_name = map[int32]string + var Identity_Wildcard_Type_value = map[string]int32 + var LogLevel_name = map[int32]string + var LogLevel_value = map[string]int32 + var MetricLabelName_name = map[int32]string + var MetricLabelName_value = map[string]int32 + var MetricName_name = map[int32]string + var MetricName_value = map[string]int32 + var ReloadConfigResponse_ReloadConfigResult_name = map[int32]string + var ReloadConfigResponse_ReloadConfigResult_value = map[string]int32 + var ServiceExitStatus_ExitCode_name = map[int32]string + var ServiceExitStatus_ExitCode_value = map[string]int32 + var ServiceExitStatus_ServiceResult_name = map[int32]string + var ServiceExitStatus_ServiceResult_value = map[string]int32 + var ServiceInfo_ApplicationHealth_name = map[int32]string + var ServiceInfo_ApplicationHealth_value = map[string]int32 + var ServiceInfo_ServiceState_name = map[int32]string + var ServiceInfo_ServiceState_value = map[string]int32 + func CreateTestIdentityImplValue() isIdentity_Value + func Errorf(code codes.Code, format string, a ...interface{}) error + func FillIn(src interface{}, dest interface{}) int + func GetClientCertExpiration(ctx context.Context) int64 + func GetDecodedLabel(m *dto.Metric) []*dto.LabelPair + func GetDecodedName(m *dto.MetricFamily) string + func GetEnumNameIfPossible(toConvert string, protoEnumMapping map[int32]string) string + func GetHashToIdentity(ids []*Identity) map[string]*Identity + func GetHashableIdentitiesTable() map[string]string + func Marshal(msg proto.Message) ([]byte, error) + func MarshalIntern(msg proto.Message) ([]byte, error) + func MarshalJSON(msg proto.Message) ([]byte, error) + func MarshalMconfig(msg proto.Message) ([]byte, error) + func MarshalMconfigToString(msg proto.Message) (string, error) + func NewContextWithCertExpiration(ctx context.Context, certExp int64) context.Context + func NewGrpcValidationError(err error) error + func RegisterBootstrapperServer(s *grpc.Server, srv BootstrapperServer) + func RegisterDirectoryLookupServer(s *grpc.Server, srv DirectoryLookupServer) + func RegisterEventServiceServer(s *grpc.Server, srv EventServiceServer) + func RegisterGatewayDirectoryServiceServer(s *grpc.Server, srv GatewayDirectoryServiceServer) + func RegisterMagmadServer(s *grpc.Server, srv MagmadServer) + func RegisterMetricsControllerServer(s *grpc.Server, srv MetricsControllerServer) + func RegisterService303Server(s *grpc.Server, srv Service303Server) + func RegisterStateServiceServer(s *grpc.Server, srv StateServiceServer) + func RegisterStreamerServer(s *grpc.Server, srv StreamerServer) + func RegisterSyncRPCServiceServer(s *grpc.Server, srv SyncRPCServiceServer) + func RegisterTenantsServiceServer(s *grpc.Server, srv TenantsServiceServer) + func SafeInit(s interface{}) interface + func TestMarshal(msg proto.Message) string + func Unmarshal(bt []byte, msg proto.Message) error + func UnmarshalMconfig(bt []byte, msg proto.Message) error + type AccessGatewayID struct + Id string + func (*AccessGatewayID) Descriptor() ([]byte, []int) + func (*AccessGatewayID) ProtoMessage() + func (x *AccessGatewayID) GetId() string + func (x *AccessGatewayID) ProtoReflect() protoreflect.Message + func (x *AccessGatewayID) Reset() + func (x *AccessGatewayID) String() string + type AllDirectoryRecords struct + Records []*DirectoryRecord + func (*AllDirectoryRecords) Descriptor() ([]byte, []int) + func (*AllDirectoryRecords) ProtoMessage() + func (x *AllDirectoryRecords) GetRecords() []*DirectoryRecord + func (x *AllDirectoryRecords) ProtoReflect() protoreflect.Message + func (x *AllDirectoryRecords) Reset() + func (x *AllDirectoryRecords) String() string + type BootstrapperClient interface + GetChallenge func(ctx context.Context, in *AccessGatewayID, opts ...grpc.CallOption) (*Challenge, error) + RequestSign func(ctx context.Context, in *Response, opts ...grpc.CallOption) (*Certificate, error) + func NewBootstrapperClient(cc grpc.ClientConnInterface) BootstrapperClient + type BootstrapperServer interface + GetChallenge func(context.Context, *AccessGatewayID) (*Challenge, error) + RequestSign func(context.Context, *Response) (*Certificate, error) + type Bytes struct + Val []byte + func (*Bytes) Descriptor() ([]byte, []int) + func (*Bytes) ProtoMessage() + func (bm *Bytes) MarshalJSONPB(_ *jsonpb.Marshaler) ([]byte, error) + func (bm *Bytes) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error + func (x *Bytes) GetVal() []byte + func (x *Bytes) ProtoReflect() protoreflect.Message + func (x *Bytes) Reset() + func (x *Bytes) String() string + type CACert struct + Cert []byte + func (*CACert) Descriptor() ([]byte, []int) + func (*CACert) ProtoMessage() + func (x *CACert) GetCert() []byte + func (x *CACert) ProtoReflect() protoreflect.Message + func (x *CACert) Reset() + func (x *CACert) String() string + type CSR struct + CertType CertType + CsrDer []byte + Id *Identity + ValidTime *duration.Duration + func (*CSR) Descriptor() ([]byte, []int) + func (*CSR) ProtoMessage() + func (x *CSR) GetCertType() CertType + func (x *CSR) GetCsrDer() []byte + func (x *CSR) GetId() *Identity + func (x *CSR) GetValidTime() *duration.Duration + func (x *CSR) ProtoReflect() protoreflect.Message + func (x *CSR) Reset() + func (x *CSR) String() string + type CertType int32 + const CertType_DEFAULT + const CertType_VPN + func (CertType) Descriptor() protoreflect.EnumDescriptor + func (CertType) EnumDescriptor() ([]byte, []int) + func (CertType) Type() protoreflect.EnumType + func (x CertType) Enum() *CertType + func (x CertType) Number() protoreflect.EnumNumber + func (x CertType) String() string + type Certificate struct + CertDer []byte + NotAfter *timestamp.Timestamp + NotBefore *timestamp.Timestamp + Sn *Certificate_SN + func (*Certificate) Descriptor() ([]byte, []int) + func (*Certificate) ProtoMessage() + func (x *Certificate) GetCertDer() []byte + func (x *Certificate) GetNotAfter() *timestamp.Timestamp + func (x *Certificate) GetNotBefore() *timestamp.Timestamp + func (x *Certificate) GetSn() *Certificate_SN + func (x *Certificate) ProtoReflect() protoreflect.Message + func (x *Certificate) Reset() + func (x *Certificate) String() string + type Certificate_SN struct + Sn string + func (*Certificate_SN) Descriptor() ([]byte, []int) + func (*Certificate_SN) ProtoMessage() + func (x *Certificate_SN) GetSn() string + func (x *Certificate_SN) ProtoReflect() protoreflect.Message + func (x *Certificate_SN) Reset() + func (x *Certificate_SN) String() string + type Challenge struct + Challenge []byte + KeyType ChallengeKey_KeyType + func (*Challenge) Descriptor() ([]byte, []int) + func (*Challenge) ProtoMessage() + func (x *Challenge) GetChallenge() []byte + func (x *Challenge) GetKeyType() ChallengeKey_KeyType + func (x *Challenge) ProtoReflect() protoreflect.Message + func (x *Challenge) Reset() + func (x *Challenge) String() string + type ChallengeKey struct + Key []byte + KeyType ChallengeKey_KeyType + func (*ChallengeKey) Descriptor() ([]byte, []int) + func (*ChallengeKey) ProtoMessage() + func (x *ChallengeKey) GetKey() []byte + func (x *ChallengeKey) GetKeyType() ChallengeKey_KeyType + func (x *ChallengeKey) ProtoReflect() protoreflect.Message + func (x *ChallengeKey) Reset() + func (x *ChallengeKey) String() string + type ChallengeKey_KeyType int32 + const ChallengeKey_ECHO + const ChallengeKey_SOFTWARE_ECDSA_SHA256 + const ChallengeKey_SOFTWARE_RSA_SHA256 + func (ChallengeKey_KeyType) Descriptor() protoreflect.EnumDescriptor + func (ChallengeKey_KeyType) EnumDescriptor() ([]byte, []int) + func (ChallengeKey_KeyType) Type() protoreflect.EnumType + func (x ChallengeKey_KeyType) Enum() *ChallengeKey_KeyType + func (x ChallengeKey_KeyType) Number() protoreflect.EnumNumber + func (x ChallengeKey_KeyType) String() string + type DataUpdate struct + Key string + Value []byte + func (*DataUpdate) Descriptor() ([]byte, []int) + func (*DataUpdate) ProtoMessage() + func (x *DataUpdate) GetKey() string + func (x *DataUpdate) GetValue() []byte + func (x *DataUpdate) ProtoReflect() protoreflect.Message + func (x *DataUpdate) Reset() + func (x *DataUpdate) String() string + type DataUpdateBatch struct + Resync bool + Updates []*DataUpdate + func (*DataUpdateBatch) Descriptor() ([]byte, []int) + func (*DataUpdateBatch) ProtoMessage() + func (x *DataUpdateBatch) GetResync() bool + func (x *DataUpdateBatch) GetUpdates() []*DataUpdate + func (x *DataUpdateBatch) ProtoReflect() protoreflect.Message + func (x *DataUpdateBatch) Reset() + func (x *DataUpdateBatch) String() string + type DeleteRecordRequest struct + Id string + func (*DeleteRecordRequest) Descriptor() ([]byte, []int) + func (*DeleteRecordRequest) ProtoMessage() + func (x *DeleteRecordRequest) GetId() string + func (x *DeleteRecordRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRecordRequest) Reset() + func (x *DeleteRecordRequest) String() string + type DeleteStatesRequest struct + Ids []*StateID + NetworkID string + func (*DeleteStatesRequest) Descriptor() ([]byte, []int) + func (*DeleteStatesRequest) ProtoMessage() + func (x *DeleteStatesRequest) GetIds() []*StateID + func (x *DeleteStatesRequest) GetNetworkID() string + func (x *DeleteStatesRequest) ProtoReflect() protoreflect.Message + func (x *DeleteStatesRequest) Reset() + func (x *DeleteStatesRequest) String() string + type DirectoryField struct + Key string + Value string + func (*DirectoryField) Descriptor() ([]byte, []int) + func (*DirectoryField) ProtoMessage() + func (x *DirectoryField) GetKey() string + func (x *DirectoryField) GetValue() string + func (x *DirectoryField) ProtoReflect() protoreflect.Message + func (x *DirectoryField) Reset() + func (x *DirectoryField) String() string + type DirectoryLookupClient interface + GetHostnameForHWID func(ctx context.Context, in *GetHostnameForHWIDRequest, opts ...grpc.CallOption) (*GetHostnameForHWIDResponse, error) + GetIMSIForSessionID func(ctx context.Context, in *GetIMSIForSessionIDRequest, opts ...grpc.CallOption) (*GetIMSIForSessionIDResponse, error) + MapHWIDsToHostnames func(ctx context.Context, in *MapHWIDToHostnameRequest, opts ...grpc.CallOption) (*Void, error) + MapSessionIDsToIMSIs func(ctx context.Context, in *MapSessionIDToIMSIRequest, opts ...grpc.CallOption) (*Void, error) + func NewDirectoryLookupClient(cc grpc.ClientConnInterface) DirectoryLookupClient + type DirectoryLookupServer interface + GetHostnameForHWID func(context.Context, *GetHostnameForHWIDRequest) (*GetHostnameForHWIDResponse, error) + GetIMSIForSessionID func(context.Context, *GetIMSIForSessionIDRequest) (*GetIMSIForSessionIDResponse, error) + MapHWIDsToHostnames func(context.Context, *MapHWIDToHostnameRequest) (*Void, error) + MapSessionIDsToIMSIs func(context.Context, *MapSessionIDToIMSIRequest) (*Void, error) + type DirectoryRecord struct + Fields map[string]string + Id string + LocationHistory []string + func (*DirectoryRecord) Descriptor() ([]byte, []int) + func (*DirectoryRecord) ProtoMessage() + func (x *DirectoryRecord) GetFields() map[string]string + func (x *DirectoryRecord) GetId() string + func (x *DirectoryRecord) GetLocationHistory() []string + func (x *DirectoryRecord) ProtoReflect() protoreflect.Message + func (x *DirectoryRecord) Reset() + func (x *DirectoryRecord) String() string + type EnodebdStatus struct + EnodebConfigured *wrappers.BoolValue + EnodebConnected *wrappers.BoolValue + GpsConnected *wrappers.BoolValue + GpsLatitude *wrappers.FloatValue + GpsLongitude *wrappers.FloatValue + MmeConnected *wrappers.BoolValue + OpstateEnabled *wrappers.BoolValue + PtpConnected *wrappers.BoolValue + RfTxDesired *wrappers.BoolValue + RfTxOn *wrappers.BoolValue + func (*EnodebdStatus) Descriptor() ([]byte, []int) + func (*EnodebdStatus) ProtoMessage() + func (x *EnodebdStatus) GetEnodebConfigured() *wrappers.BoolValue + func (x *EnodebdStatus) GetEnodebConnected() *wrappers.BoolValue + func (x *EnodebdStatus) GetGpsConnected() *wrappers.BoolValue + func (x *EnodebdStatus) GetGpsLatitude() *wrappers.FloatValue + func (x *EnodebdStatus) GetGpsLongitude() *wrappers.FloatValue + func (x *EnodebdStatus) GetMmeConnected() *wrappers.BoolValue + func (x *EnodebdStatus) GetOpstateEnabled() *wrappers.BoolValue + func (x *EnodebdStatus) GetPtpConnected() *wrappers.BoolValue + func (x *EnodebdStatus) GetRfTxDesired() *wrappers.BoolValue + func (x *EnodebdStatus) GetRfTxOn() *wrappers.BoolValue + func (x *EnodebdStatus) ProtoReflect() protoreflect.Message + func (x *EnodebdStatus) Reset() + func (x *EnodebdStatus) String() string + type Event struct + EventType string + StreamName string + Tag string + Value string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (x *Event) GetEventType() string + func (x *Event) GetStreamName() string + func (x *Event) GetTag() string + func (x *Event) GetValue() string + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type EventServiceClient interface + LogEvent func(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Void, error) + func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient + type EventServiceServer interface + LogEvent func(context.Context, *Event) (*Void, error) + type GatewayConfigs struct + ConfigsByKey map[string]*any.Any + Metadata *GatewayConfigsMetadata + func (*GatewayConfigs) Descriptor() ([]byte, []int) + func (*GatewayConfigs) ProtoMessage() + func (cfg *GatewayConfigs) GetMconfigDigest() (string, error) + func (x *GatewayConfigs) GetConfigsByKey() map[string]*any.Any + func (x *GatewayConfigs) GetMetadata() *GatewayConfigsMetadata + func (x *GatewayConfigs) ProtoReflect() protoreflect.Message + func (x *GatewayConfigs) Reset() + func (x *GatewayConfigs) String() string + type GatewayConfigsDigest struct + Md5HexDigest string + func (*GatewayConfigsDigest) Descriptor() ([]byte, []int) + func (*GatewayConfigsDigest) ProtoMessage() + func (x *GatewayConfigsDigest) GetMd5HexDigest() string + func (x *GatewayConfigsDigest) ProtoReflect() protoreflect.Message + func (x *GatewayConfigsDigest) Reset() + func (x *GatewayConfigsDigest) String() string + type GatewayConfigsMetadata struct + CreatedAt uint64 + Digest *GatewayConfigsDigest + func (*GatewayConfigsMetadata) Descriptor() ([]byte, []int) + func (*GatewayConfigsMetadata) ProtoMessage() + func (x *GatewayConfigsMetadata) GetCreatedAt() uint64 + func (x *GatewayConfigsMetadata) GetDigest() *GatewayConfigsDigest + func (x *GatewayConfigsMetadata) ProtoReflect() protoreflect.Message + func (x *GatewayConfigsMetadata) Reset() + func (x *GatewayConfigsMetadata) String() string + type GatewayDirectoryServiceClient interface + DeleteRecord func(ctx context.Context, in *DeleteRecordRequest, opts ...grpc.CallOption) (*Void, error) + GetAllDirectoryRecords func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*AllDirectoryRecords, error) + GetDirectoryField func(ctx context.Context, in *GetDirectoryFieldRequest, opts ...grpc.CallOption) (*DirectoryField, error) + UpdateRecord func(ctx context.Context, in *UpdateRecordRequest, opts ...grpc.CallOption) (*Void, error) + func NewGatewayDirectoryServiceClient(cc grpc.ClientConnInterface) GatewayDirectoryServiceClient + type GatewayDirectoryServiceServer interface + DeleteRecord func(context.Context, *DeleteRecordRequest) (*Void, error) + GetAllDirectoryRecords func(context.Context, *Void) (*AllDirectoryRecords, error) + GetDirectoryField func(context.Context, *GetDirectoryFieldRequest) (*DirectoryField, error) + UpdateRecord func(context.Context, *UpdateRecordRequest) (*Void, error) + type GatewayRequest struct + Authority string + GwId string + Headers map[string]string + Path string + Payload []byte + func (*GatewayRequest) Descriptor() ([]byte, []int) + func (*GatewayRequest) ProtoMessage() + func (x *GatewayRequest) GetAuthority() string + func (x *GatewayRequest) GetGwId() string + func (x *GatewayRequest) GetHeaders() map[string]string + func (x *GatewayRequest) GetPath() string + func (x *GatewayRequest) GetPayload() []byte + func (x *GatewayRequest) ProtoReflect() protoreflect.Message + func (x *GatewayRequest) Reset() + func (x *GatewayRequest) String() string + type GatewayResponse struct + Err string + Headers map[string]string + KeepConnActive bool + Payload []byte + Status string + func (*GatewayResponse) Descriptor() ([]byte, []int) + func (*GatewayResponse) ProtoMessage() + func (x *GatewayResponse) GetErr() string + func (x *GatewayResponse) GetHeaders() map[string]string + func (x *GatewayResponse) GetKeepConnActive() bool + func (x *GatewayResponse) GetPayload() []byte + func (x *GatewayResponse) GetStatus() string + func (x *GatewayResponse) ProtoReflect() protoreflect.Message + func (x *GatewayResponse) Reset() + func (x *GatewayResponse) String() string + type GenericCommandParams struct + Command string + Params *_struct.Struct + func (*GenericCommandParams) Descriptor() ([]byte, []int) + func (*GenericCommandParams) ProtoMessage() + func (x *GenericCommandParams) GetCommand() string + func (x *GenericCommandParams) GetParams() *_struct.Struct + func (x *GenericCommandParams) ProtoReflect() protoreflect.Message + func (x *GenericCommandParams) Reset() + func (x *GenericCommandParams) String() string + type GenericCommandResponse struct + Response *_struct.Struct + func (*GenericCommandResponse) Descriptor() ([]byte, []int) + func (*GenericCommandResponse) ProtoMessage() + func (x *GenericCommandResponse) GetResponse() *_struct.Struct + func (x *GenericCommandResponse) ProtoReflect() protoreflect.Message + func (x *GenericCommandResponse) Reset() + func (x *GenericCommandResponse) String() string + type GetDirectoryFieldRequest struct + FieldKey string + Id string + func (*GetDirectoryFieldRequest) Descriptor() ([]byte, []int) + func (*GetDirectoryFieldRequest) ProtoMessage() + func (x *GetDirectoryFieldRequest) GetFieldKey() string + func (x *GetDirectoryFieldRequest) GetId() string + func (x *GetDirectoryFieldRequest) ProtoReflect() protoreflect.Message + func (x *GetDirectoryFieldRequest) Reset() + func (x *GetDirectoryFieldRequest) String() string + type GetGatewayIdResponse struct + GatewayId string + func (*GetGatewayIdResponse) Descriptor() ([]byte, []int) + func (*GetGatewayIdResponse) ProtoMessage() + func (x *GetGatewayIdResponse) GetGatewayId() string + func (x *GetGatewayIdResponse) ProtoReflect() protoreflect.Message + func (x *GetGatewayIdResponse) Reset() + func (x *GetGatewayIdResponse) String() string + type GetHostnameForHWIDRequest struct + Hwid string + func (*GetHostnameForHWIDRequest) Descriptor() ([]byte, []int) + func (*GetHostnameForHWIDRequest) ProtoMessage() + func (m *GetHostnameForHWIDRequest) Validate() error + func (x *GetHostnameForHWIDRequest) GetHwid() string + func (x *GetHostnameForHWIDRequest) ProtoReflect() protoreflect.Message + func (x *GetHostnameForHWIDRequest) Reset() + func (x *GetHostnameForHWIDRequest) String() string + type GetHostnameForHWIDResponse struct + Hostname string + func (*GetHostnameForHWIDResponse) Descriptor() ([]byte, []int) + func (*GetHostnameForHWIDResponse) ProtoMessage() + func (x *GetHostnameForHWIDResponse) GetHostname() string + func (x *GetHostnameForHWIDResponse) ProtoReflect() protoreflect.Message + func (x *GetHostnameForHWIDResponse) Reset() + func (x *GetHostnameForHWIDResponse) String() string + type GetIMSIForSessionIDRequest struct + NetworkID string + SessionID string + func (*GetIMSIForSessionIDRequest) Descriptor() ([]byte, []int) + func (*GetIMSIForSessionIDRequest) ProtoMessage() + func (m *GetIMSIForSessionIDRequest) Validate() error + func (x *GetIMSIForSessionIDRequest) GetNetworkID() string + func (x *GetIMSIForSessionIDRequest) GetSessionID() string + func (x *GetIMSIForSessionIDRequest) ProtoReflect() protoreflect.Message + func (x *GetIMSIForSessionIDRequest) Reset() + func (x *GetIMSIForSessionIDRequest) String() string + type GetIMSIForSessionIDResponse struct + Imsi string + func (*GetIMSIForSessionIDResponse) Descriptor() ([]byte, []int) + func (*GetIMSIForSessionIDResponse) ProtoMessage() + func (x *GetIMSIForSessionIDResponse) GetImsi() string + func (x *GetIMSIForSessionIDResponse) ProtoReflect() protoreflect.Message + func (x *GetIMSIForSessionIDResponse) Reset() + func (x *GetIMSIForSessionIDResponse) String() string + type GetOperationalStatesResponse struct + States []*State + func (*GetOperationalStatesResponse) Descriptor() ([]byte, []int) + func (*GetOperationalStatesResponse) ProtoMessage() + func (x *GetOperationalStatesResponse) GetStates() []*State + func (x *GetOperationalStatesResponse) ProtoReflect() protoreflect.Message + func (x *GetOperationalStatesResponse) Reset() + func (x *GetOperationalStatesResponse) String() string + type GetStatesRequest struct + IdFilter []string + IdPrefix string + Ids []*StateID + LoadValues bool + NetworkID string + TypeFilter []string + func (*GetStatesRequest) Descriptor() ([]byte, []int) + func (*GetStatesRequest) ProtoMessage() + func (x *GetStatesRequest) GetIdFilter() []string + func (x *GetStatesRequest) GetIdPrefix() string + func (x *GetStatesRequest) GetIds() []*StateID + func (x *GetStatesRequest) GetLoadValues() bool + func (x *GetStatesRequest) GetNetworkID() string + func (x *GetStatesRequest) GetTypeFilter() []string + func (x *GetStatesRequest) ProtoReflect() protoreflect.Message + func (x *GetStatesRequest) Reset() + func (x *GetStatesRequest) String() string + type GetStatesResponse struct + States []*State + func (*GetStatesResponse) Descriptor() ([]byte, []int) + func (*GetStatesResponse) ProtoMessage() + func (x *GetStatesResponse) GetStates() []*State + func (x *GetStatesResponse) ProtoReflect() protoreflect.Message + func (x *GetStatesResponse) Reset() + func (x *GetStatesResponse) String() string + type GetTenantRequest struct + Id int64 + func (*GetTenantRequest) Descriptor() ([]byte, []int) + func (*GetTenantRequest) ProtoMessage() + func (x *GetTenantRequest) GetId() int64 + func (x *GetTenantRequest) ProtoReflect() protoreflect.Message + func (x *GetTenantRequest) Reset() + func (x *GetTenantRequest) String() string + type IDAndError struct + DeviceID string + Error string + Type string + func (*IDAndError) Descriptor() ([]byte, []int) + func (*IDAndError) ProtoMessage() + func (x *IDAndError) GetDeviceID() string + func (x *IDAndError) GetError() string + func (x *IDAndError) GetType() string + func (x *IDAndError) ProtoReflect() protoreflect.Message + func (x *IDAndError) Reset() + func (x *IDAndError) String() string + type IDAndTenant struct + Id int64 + Tenant *Tenant + func (*IDAndTenant) Descriptor() ([]byte, []int) + func (*IDAndTenant) ProtoMessage() + func (x *IDAndTenant) GetId() int64 + func (x *IDAndTenant) GetTenant() *Tenant + func (x *IDAndTenant) ProtoReflect() protoreflect.Message + func (x *IDAndTenant) Reset() + func (x *IDAndTenant) String() string + type IDAndVersion struct + Id *StateID + Version uint64 + func (*IDAndVersion) Descriptor() ([]byte, []int) + func (*IDAndVersion) ProtoMessage() + func (x *IDAndVersion) GetId() *StateID + func (x *IDAndVersion) GetVersion() uint64 + func (x *IDAndVersion) ProtoReflect() protoreflect.Message + func (x *IDAndVersion) Reset() + func (x *IDAndVersion) String() string + type IDList struct + Ids []string + func (*IDList) Descriptor() ([]byte, []int) + func (*IDList) ProtoMessage() + func (x *IDList) GetIds() []string + func (x *IDList) ProtoReflect() protoreflect.Message + func (x *IDList) Reset() + func (x *IDList) String() string + type Identity struct + Value isIdentity_Value + func GetClientIdentity(ctx context.Context) *Identity + func NewGatewayIdentity(hwId, networkId, logicalId string) *Identity + func NewGatewayWildcardIdentity() *Identity + func NewNetworkIdentity(networkId string) *Identity + func NewNetworkWildcardIdentity() *Identity + func NewOperatorIdentity(opId string) *Identity + func NewOperatorWildcardIdentity() *Identity + func (*Identity) Descriptor() ([]byte, []int) + func (*Identity) ProtoMessage() + func (id *Identity) GetWildcardForIdentity() *Identity + func (id *Identity) HashString() string + func (id *Identity) NewContextWithIdentity(ctx context.Context) context.Context + func (id *Identity) SetGateway(gwId *Identity_Gateway) *Identity + func (id *Identity) SetNetwork(networkId string) *Identity + func (id *Identity) SetOperator(opId string) *Identity + func (id *Identity) ToCommonName() *string + func (id *Identity) TypeName() *string + func (m *Identity) GetValue() isIdentity_Value + func (wildcard *Identity) Match(entity *Identity) bool + func (x *Identity) GetGateway() *Identity_Gateway + func (x *Identity) GetNetwork() string + func (x *Identity) GetOperator() string + func (x *Identity) GetWildcard() *Identity_Wildcard + func (x *Identity) ProtoReflect() protoreflect.Message + func (x *Identity) Reset() + func (x *Identity) String() string + type Identity_Gateway struct + HardwareId string + LogicalId string + NetworkId string + func GetClientGateway(ctx context.Context) *Identity_Gateway + func GetGatewayIdentity(ctx context.Context) (*Identity_Gateway, error) + func (*Identity_Gateway) Descriptor() ([]byte, []int) + func (*Identity_Gateway) ProtoMessage() + func (gw *Identity_Gateway) Registered() bool + func (x *Identity_Gateway) GetHardwareId() string + func (x *Identity_Gateway) GetLogicalId() string + func (x *Identity_Gateway) GetNetworkId() string + func (x *Identity_Gateway) ProtoReflect() protoreflect.Message + func (x *Identity_Gateway) Reset() + func (x *Identity_Gateway) String() string + type Identity_Gateway_ struct + Gateway *Identity_Gateway + func (gw *Identity_Gateway_) ToCommonName() *string + type Identity_List struct + List []*Identity + func (*Identity_List) Descriptor() ([]byte, []int) + func (*Identity_List) ProtoMessage() + func (x *Identity_List) GetList() []*Identity + func (x *Identity_List) ProtoReflect() protoreflect.Message + func (x *Identity_List) Reset() + func (x *Identity_List) String() string + type Identity_Network struct + Network string + func (nid *Identity_Network) ToCommonName() *string + type Identity_Operator struct + Operator string + func (oper *Identity_Operator) ToCommonName() *string + type Identity_Wildcard struct + Type Identity_Wildcard_Type + func (*Identity_Wildcard) Descriptor() ([]byte, []int) + func (*Identity_Wildcard) ProtoMessage() + func (x *Identity_Wildcard) GetType() Identity_Wildcard_Type + func (x *Identity_Wildcard) ProtoReflect() protoreflect.Message + func (x *Identity_Wildcard) Reset() + func (x *Identity_Wildcard) String() string + type Identity_Wildcard_ struct + Wildcard *Identity_Wildcard + func (wc *Identity_Wildcard_) ToCommonName() *string + type Identity_Wildcard_Type int32 + const Identity_Wildcard_Gateway + const Identity_Wildcard_Network + const Identity_Wildcard_Operator + func (Identity_Wildcard_Type) Descriptor() protoreflect.EnumDescriptor + func (Identity_Wildcard_Type) EnumDescriptor() ([]byte, []int) + func (Identity_Wildcard_Type) Type() protoreflect.EnumType + func (x Identity_Wildcard_Type) Enum() *Identity_Wildcard_Type + func (x Identity_Wildcard_Type) Number() protoreflect.EnumNumber + func (x Identity_Wildcard_Type) String() string + type LabelPair struct + Name string + Value string + func (*LabelPair) Descriptor() ([]byte, []int) + func (*LabelPair) ProtoMessage() + func (x *LabelPair) GetName() string + func (x *LabelPair) GetValue() string + func (x *LabelPair) ProtoReflect() protoreflect.Message + func (x *LabelPair) Reset() + func (x *LabelPair) String() string + type LogLevel int32 + const LogLevel_DEBUG + const LogLevel_ERROR + const LogLevel_FATAL + const LogLevel_INFO + const LogLevel_WARNING + func (LogLevel) Descriptor() protoreflect.EnumDescriptor + func (LogLevel) EnumDescriptor() ([]byte, []int) + func (LogLevel) Type() protoreflect.EnumType + func (x LogLevel) Enum() *LogLevel + func (x LogLevel) Number() protoreflect.EnumNumber + func (x LogLevel) String() string + type LogLevelMessage struct + Level LogLevel + func (*LogLevelMessage) Descriptor() ([]byte, []int) + func (*LogLevelMessage) ProtoMessage() + func (x *LogLevelMessage) GetLevel() LogLevel + func (x *LogLevelMessage) ProtoReflect() protoreflect.Message + func (x *LogLevelMessage) Reset() + func (x *LogLevelMessage) String() string + type LogLine struct + Line string + func (*LogLine) Descriptor() ([]byte, []int) + func (*LogLine) ProtoMessage() + func (x *LogLine) GetLine() string + func (x *LogLine) ProtoReflect() protoreflect.Message + func (x *LogLine) Reset() + func (x *LogLine) String() string + type LogVerbosity struct + Verbosity int32 + func (*LogVerbosity) Descriptor() ([]byte, []int) + func (*LogVerbosity) ProtoMessage() + func (x *LogVerbosity) GetVerbosity() int32 + func (x *LogVerbosity) ProtoReflect() protoreflect.Message + func (x *LogVerbosity) Reset() + func (x *LogVerbosity) String() string + type MagmadClient interface + GenericCommand func(ctx context.Context, in *GenericCommandParams, opts ...grpc.CallOption) (*GenericCommandResponse, error) + GetConfigs func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GatewayConfigs, error) + GetGatewayId func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GetGatewayIdResponse, error) + Reboot func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) + RestartServices func(ctx context.Context, in *RestartServicesRequest, opts ...grpc.CallOption) (*Void, error) + RunNetworkTests func(ctx context.Context, in *NetworkTestRequest, opts ...grpc.CallOption) (*NetworkTestResponse, error) + SetConfigs func(ctx context.Context, in *GatewayConfigs, opts ...grpc.CallOption) (*Void, error) + StartServices func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) + StopServices func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) + TailLogs func(ctx context.Context, in *TailLogsRequest, opts ...grpc.CallOption) (Magmad_TailLogsClient, error) + func NewMagmadClient(cc grpc.ClientConnInterface) MagmadClient + type MagmadServer interface + GenericCommand func(context.Context, *GenericCommandParams) (*GenericCommandResponse, error) + GetConfigs func(context.Context, *Void) (*GatewayConfigs, error) + GetGatewayId func(context.Context, *Void) (*GetGatewayIdResponse, error) + Reboot func(context.Context, *Void) (*Void, error) + RestartServices func(context.Context, *RestartServicesRequest) (*Void, error) + RunNetworkTests func(context.Context, *NetworkTestRequest) (*NetworkTestResponse, error) + SetConfigs func(context.Context, *GatewayConfigs) (*Void, error) + StartServices func(context.Context, *Void) (*Void, error) + StopServices func(context.Context, *Void) (*Void, error) + TailLogs func(*TailLogsRequest, Magmad_TailLogsServer) error + type Magmad_TailLogsClient interface + Recv func() (*LogLine, error) + type Magmad_TailLogsServer interface + Send func(*LogLine) error + type MapHWIDToHostnameRequest struct + HwidToHostname map[string]string + func (*MapHWIDToHostnameRequest) Descriptor() ([]byte, []int) + func (*MapHWIDToHostnameRequest) ProtoMessage() + func (m *MapHWIDToHostnameRequest) Validate() error + func (x *MapHWIDToHostnameRequest) GetHwidToHostname() map[string]string + func (x *MapHWIDToHostnameRequest) ProtoReflect() protoreflect.Message + func (x *MapHWIDToHostnameRequest) Reset() + func (x *MapHWIDToHostnameRequest) String() string + type MapSessionIDToIMSIRequest struct + NetworkID string + SessionIDToIMSI map[string]string + func (*MapSessionIDToIMSIRequest) Descriptor() ([]byte, []int) + func (*MapSessionIDToIMSIRequest) ProtoMessage() + func (m *MapSessionIDToIMSIRequest) Validate() error + func (x *MapSessionIDToIMSIRequest) GetNetworkID() string + func (x *MapSessionIDToIMSIRequest) GetSessionIDToIMSI() map[string]string + func (x *MapSessionIDToIMSIRequest) ProtoReflect() protoreflect.Message + func (x *MapSessionIDToIMSIRequest) Reset() + func (x *MapSessionIDToIMSIRequest) String() string + type MconfigStreamRequest struct + Offset int64 + func (*MconfigStreamRequest) Descriptor() ([]byte, []int) + func (*MconfigStreamRequest) ProtoMessage() + func (x *MconfigStreamRequest) GetOffset() int64 + func (x *MconfigStreamRequest) ProtoReflect() protoreflect.Message + func (x *MconfigStreamRequest) Reset() + func (x *MconfigStreamRequest) String() string + type MetricLabelName int32 + const MetricLabelName_action + const MetricLabelName_cause + const MetricLabelName_error_code + const MetricLabelName_error_type + const MetricLabelName_host + const MetricLabelName_iface_name + const MetricLabelName_implementation + const MetricLabelName_imsi + const MetricLabelName_major + const MetricLabelName_metric + const MetricLabelName_minor + const MetricLabelName_patchlevel + const MetricLabelName_pdn_type + const MetricLabelName_result + const MetricLabelName_rule_id + const MetricLabelName_sensor + const MetricLabelName_service_name + const MetricLabelName_tau_type + const MetricLabelName_version + func (MetricLabelName) Descriptor() protoreflect.EnumDescriptor + func (MetricLabelName) EnumDescriptor() ([]byte, []int) + func (MetricLabelName) Type() protoreflect.EnumType + func (x MetricLabelName) Enum() *MetricLabelName + func (x MetricLabelName) Number() protoreflect.EnumNumber + func (x MetricLabelName) String() string + type MetricName int32 + const MetricName_arp_default_gw_mac_error + const MetricName_authentication_failure + const MetricName_bootstrap_exception + const MetricName_bytes_received + const MetricName_bytes_sent + const MetricName_checkin_status + const MetricName_cpu_percent + const MetricName_diameter_capabilities_exchange + const MetricName_diameter_disconnect + const MetricName_diameter_watchdog + const MetricName_disk_percent + const MetricName_dp_send_msg_error + const MetricName_duplicate_attach_request + const MetricName_emm_status_received + const MetricName_emm_status_sent + const MetricName_enb_sctp_shutdown_ue_clean_up_timer_expired + const MetricName_enforcement_rule_install_fail + const MetricName_enforcement_stats_rule_install_fail + const MetricName_enodeb_gps_connected + const MetricName_enodeb_mgmt_configured + const MetricName_enodeb_mgmt_connected + const MetricName_enodeb_mme_connected + const MetricName_enodeb_opstate_enabled + const MetricName_enodeb_ptp_connected + const MetricName_enodeb_reboot_timer_active + const MetricName_enodeb_reboots + const MetricName_enodeb_rf_tx_desired + const MetricName_enodeb_rf_tx_enabled + const MetricName_erab_estab_attempts + const MetricName_erab_estab_failures + const MetricName_erab_estab_successes + const MetricName_erab_release_requests + const MetricName_erab_release_requests_eutran_reas + const MetricName_erab_release_requests_fail_in_radio_proc + const MetricName_erab_release_requests_normal + const MetricName_erab_release_requests_oam_intervention + const MetricName_erab_release_requests_radio_radio_conn_lost + const MetricName_erab_release_requests_radio_resources_not_available + const MetricName_erab_release_requests_reduce_load + const MetricName_erab_release_requests_user_inactivity + const MetricName_gtpu_error_ind_received + const MetricName_implicit_detach_timer_expired + const MetricName_initial_context_setup_failure_received + const MetricName_initial_context_setup_request_timer_expired + const MetricName_ip_address_allocated + const MetricName_ip_address_released + const MetricName_ip_allocation_failure + const MetricName_ip_already_allocated + const MetricName_magmad_ping_rtt_ms + const MetricName_mem_available + const MetricName_mem_free + const MetricName_mem_total + const MetricName_mem_used + const MetricName_mme_new_association + const MetricName_mme_restarted + const MetricName_mme_spgw_create_session_req + const MetricName_mme_spgw_create_session_rsp + const MetricName_mme_spgw_delete_session_req + const MetricName_mme_spgw_delete_session_rsp + const MetricName_nas_attach_accept_timer_expired + const MetricName_nas_auth_rsp_timer_expired + const MetricName_nas_non_delivery_indication_received + const MetricName_nas_security_mode_command_timer_expired + const MetricName_network_iface_status + const MetricName_openflow_error_msg + const MetricName_pdcp_user_plane_bytes_dl + const MetricName_pdcp_user_plane_bytes_ul + const MetricName_process_cpu_seconds_total + const MetricName_process_max_fds + const MetricName_process_open_fds + const MetricName_process_resident_memory_bytes + const MetricName_process_start_time_seconds + const MetricName_process_uptime_seconds + const MetricName_process_virtual_memory_bytes + const MetricName_python_info + const MetricName_rrc_estab_attempts + const MetricName_rrc_estab_successes + const MetricName_rrc_reestab_attempts + const MetricName_rrc_reestab_attempts_ho_fail + const MetricName_rrc_reestab_attempts_other + const MetricName_rrc_reestab_attempts_reconf_fail + const MetricName_rrc_reestab_successes + const MetricName_s1_reset_from_enb + const MetricName_s1_setup + const MetricName_s1ap_error_ind_received + const MetricName_s6a_auth_failure + const MetricName_s6a_auth_info_response_timer_expired + const MetricName_s6a_auth_success + const MetricName_s6a_location_update + const MetricName_s6a_subscriberdb_connection_failure + const MetricName_sctp_reset + const MetricName_sctp_shutdown + const MetricName_security_mode_reject_received + const MetricName_service_errors + const MetricName_service_metrics_collected + const MetricName_service_request + const MetricName_service_restart_status + const MetricName_spgw_create_session + const MetricName_spgw_delete_session + const MetricName_streamer_responses + const MetricName_swap_memory_percent + const MetricName_temperature + const MetricName_tracking_area_update + const MetricName_ue_attach + const MetricName_ue_context_release_command_timer_expired + const MetricName_ue_context_release_request + const MetricName_ue_detach + const MetricName_ue_pdn_connection + const MetricName_unattended_upgrade_status + const MetricName_unexpected_service_restarts + const MetricName_unknown_pkt_direction + const MetricName_upgrader2_canary + const MetricName_upgrader2_downloaded + const MetricName_upgrader2_error + const MetricName_upgrader2_idle + const MetricName_upgrader2_prepared + const MetricName_upgrader2_stable + const MetricName_upgrader2_time_taken + const MetricName_virtual_memory_percent + func (MetricName) Descriptor() protoreflect.EnumDescriptor + func (MetricName) EnumDescriptor() ([]byte, []int) + func (MetricName) Type() protoreflect.EnumType + func (x MetricName) Enum() *MetricName + func (x MetricName) Number() protoreflect.EnumNumber + func (x MetricName) String() string + type MetricsContainer struct + Family []*_go.MetricFamily + GatewayId string + func (*MetricsContainer) Descriptor() ([]byte, []int) + func (*MetricsContainer) ProtoMessage() + func (x *MetricsContainer) GetFamily() []*_go.MetricFamily + func (x *MetricsContainer) GetGatewayId() string + func (x *MetricsContainer) ProtoReflect() protoreflect.Message + func (x *MetricsContainer) Reset() + func (x *MetricsContainer) String() string + type MetricsControllerClient interface + Collect func(ctx context.Context, in *MetricsContainer, opts ...grpc.CallOption) (*Void, error) + Push func(ctx context.Context, in *PushedMetricsContainer, opts ...grpc.CallOption) (*Void, error) + func NewMetricsControllerClient(cc grpc.ClientConnInterface) MetricsControllerClient + type MetricsControllerServer interface + Collect func(context.Context, *MetricsContainer) (*Void, error) + Push func(context.Context, *PushedMetricsContainer) (*Void, error) + type NetworkID struct + Id string + func (*NetworkID) Descriptor() ([]byte, []int) + func (*NetworkID) ProtoMessage() + func (x *NetworkID) GetId() string + func (x *NetworkID) ProtoReflect() protoreflect.Message + func (x *NetworkID) Reset() + func (x *NetworkID) String() string + type NetworkTestRequest struct + Pings []*PingParams + Traceroutes []*TracerouteParams + func (*NetworkTestRequest) Descriptor() ([]byte, []int) + func (*NetworkTestRequest) ProtoMessage() + func (x *NetworkTestRequest) GetPings() []*PingParams + func (x *NetworkTestRequest) GetTraceroutes() []*TracerouteParams + func (x *NetworkTestRequest) ProtoReflect() protoreflect.Message + func (x *NetworkTestRequest) Reset() + func (x *NetworkTestRequest) String() string + type NetworkTestResponse struct + Pings []*PingResult + Traceroutes []*TracerouteResult + func (*NetworkTestResponse) Descriptor() ([]byte, []int) + func (*NetworkTestResponse) ProtoMessage() + func (x *NetworkTestResponse) GetPings() []*PingResult + func (x *NetworkTestResponse) GetTraceroutes() []*TracerouteResult + func (x *NetworkTestResponse) ProtoReflect() protoreflect.Message + func (x *NetworkTestResponse) Reset() + func (x *NetworkTestResponse) String() string + type OffsetGatewayConfigs struct + Configs *GatewayConfigs + Offset int64 + func (*OffsetGatewayConfigs) Descriptor() ([]byte, []int) + func (*OffsetGatewayConfigs) ProtoMessage() + func (x *OffsetGatewayConfigs) GetConfigs() *GatewayConfigs + func (x *OffsetGatewayConfigs) GetOffset() int64 + func (x *OffsetGatewayConfigs) ProtoReflect() protoreflect.Message + func (x *OffsetGatewayConfigs) Reset() + func (x *OffsetGatewayConfigs) String() string + type PingParams struct + HostOrIp string + NumPackets int32 + func (*PingParams) Descriptor() ([]byte, []int) + func (*PingParams) ProtoMessage() + func (x *PingParams) GetHostOrIp() string + func (x *PingParams) GetNumPackets() int32 + func (x *PingParams) ProtoReflect() protoreflect.Message + func (x *PingParams) Reset() + func (x *PingParams) String() string + type PingResult struct + AvgResponseMs float32 + Error string + HostOrIp string + NumPackets int32 + PacketsReceived int32 + PacketsTransmitted int32 + func (*PingResult) Descriptor() ([]byte, []int) + func (*PingResult) ProtoMessage() + func (x *PingResult) GetAvgResponseMs() float32 + func (x *PingResult) GetError() string + func (x *PingResult) GetHostOrIp() string + func (x *PingResult) GetNumPackets() int32 + func (x *PingResult) GetPacketsReceived() int32 + func (x *PingResult) GetPacketsTransmitted() int32 + func (x *PingResult) ProtoReflect() protoreflect.Message + func (x *PingResult) Reset() + func (x *PingResult) String() string + type PushedMetric struct + Labels []*LabelPair + MetricName string + TimestampMS int64 + Value float64 + func (*PushedMetric) Descriptor() ([]byte, []int) + func (*PushedMetric) ProtoMessage() + func (x *PushedMetric) GetLabels() []*LabelPair + func (x *PushedMetric) GetMetricName() string + func (x *PushedMetric) GetTimestampMS() int64 + func (x *PushedMetric) GetValue() float64 + func (x *PushedMetric) ProtoReflect() protoreflect.Message + func (x *PushedMetric) Reset() + func (x *PushedMetric) String() string + type PushedMetricsContainer struct + Metrics []*PushedMetric + NetworkId string + func (*PushedMetricsContainer) Descriptor() ([]byte, []int) + func (*PushedMetricsContainer) ProtoMessage() + func (x *PushedMetricsContainer) GetMetrics() []*PushedMetric + func (x *PushedMetricsContainer) GetNetworkId() string + func (x *PushedMetricsContainer) ProtoReflect() protoreflect.Message + func (x *PushedMetricsContainer) Reset() + func (x *PushedMetricsContainer) String() string + type RedisState struct + IsGarbage bool + SerializedMsg []byte + Version uint64 + func (*RedisState) Descriptor() ([]byte, []int) + func (*RedisState) ProtoMessage() + func (x *RedisState) GetIsGarbage() bool + func (x *RedisState) GetSerializedMsg() []byte + func (x *RedisState) GetVersion() uint64 + func (x *RedisState) ProtoReflect() protoreflect.Message + func (x *RedisState) Reset() + func (x *RedisState) String() string + type ReloadConfigResponse struct + Result ReloadConfigResponse_ReloadConfigResult + func (*ReloadConfigResponse) Descriptor() ([]byte, []int) + func (*ReloadConfigResponse) ProtoMessage() + func (x *ReloadConfigResponse) GetResult() ReloadConfigResponse_ReloadConfigResult + func (x *ReloadConfigResponse) ProtoReflect() protoreflect.Message + func (x *ReloadConfigResponse) Reset() + func (x *ReloadConfigResponse) String() string + type ReloadConfigResponse_ReloadConfigResult int32 + const ReloadConfigResponse_RELOAD_FAILURE + const ReloadConfigResponse_RELOAD_SUCCESS + const ReloadConfigResponse_RELOAD_UNKNOWN + const ReloadConfigResponse_RELOAD_UNSUPPORTED + func (ReloadConfigResponse_ReloadConfigResult) Descriptor() protoreflect.EnumDescriptor + func (ReloadConfigResponse_ReloadConfigResult) EnumDescriptor() ([]byte, []int) + func (ReloadConfigResponse_ReloadConfigResult) Type() protoreflect.EnumType + func (x ReloadConfigResponse_ReloadConfigResult) Enum() *ReloadConfigResponse_ReloadConfigResult + func (x ReloadConfigResponse_ReloadConfigResult) Number() protoreflect.EnumNumber + func (x ReloadConfigResponse_ReloadConfigResult) String() string + type ReportStatesRequest struct + States []*State + func (*ReportStatesRequest) Descriptor() ([]byte, []int) + func (*ReportStatesRequest) ProtoMessage() + func (x *ReportStatesRequest) GetStates() []*State + func (x *ReportStatesRequest) ProtoReflect() protoreflect.Message + func (x *ReportStatesRequest) Reset() + func (x *ReportStatesRequest) String() string + type ReportStatesResponse struct + UnreportedStates []*IDAndError + func (*ReportStatesResponse) Descriptor() ([]byte, []int) + func (*ReportStatesResponse) ProtoMessage() + func (x *ReportStatesResponse) GetUnreportedStates() []*IDAndError + func (x *ReportStatesResponse) ProtoReflect() protoreflect.Message + func (x *ReportStatesResponse) Reset() + func (x *ReportStatesResponse) String() string + type Response struct + Challenge []byte + Csr *CSR + HwId *AccessGatewayID + Response isResponse_Response + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetResponse() isResponse_Response + func (x *Response) GetChallenge() []byte + func (x *Response) GetCsr() *CSR + func (x *Response) GetEcdsaResponse() *Response_ECDSA + func (x *Response) GetEchoResponse() *Response_Echo + func (x *Response) GetHwId() *AccessGatewayID + func (x *Response) GetRsaResponse() *Response_RSA + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type Response_ECDSA struct + R []byte + S []byte + func (*Response_ECDSA) Descriptor() ([]byte, []int) + func (*Response_ECDSA) ProtoMessage() + func (x *Response_ECDSA) GetR() []byte + func (x *Response_ECDSA) GetS() []byte + func (x *Response_ECDSA) ProtoReflect() protoreflect.Message + func (x *Response_ECDSA) Reset() + func (x *Response_ECDSA) String() string + type Response_EcdsaResponse struct + EcdsaResponse *Response_ECDSA + type Response_Echo struct + Response []byte + func (*Response_Echo) Descriptor() ([]byte, []int) + func (*Response_Echo) ProtoMessage() + func (x *Response_Echo) GetResponse() []byte + func (x *Response_Echo) ProtoReflect() protoreflect.Message + func (x *Response_Echo) Reset() + func (x *Response_Echo) String() string + type Response_EchoResponse struct + EchoResponse *Response_Echo + type Response_RSA struct + Signature []byte + func (*Response_RSA) Descriptor() ([]byte, []int) + func (*Response_RSA) ProtoMessage() + func (x *Response_RSA) GetSignature() []byte + func (x *Response_RSA) ProtoReflect() protoreflect.Message + func (x *Response_RSA) Reset() + func (x *Response_RSA) String() string + type Response_RsaResponse struct + RsaResponse *Response_RSA + type RestartServicesRequest struct + Services []string + func (*RestartServicesRequest) Descriptor() ([]byte, []int) + func (*RestartServicesRequest) ProtoMessage() + func (x *RestartServicesRequest) GetServices() []string + func (x *RestartServicesRequest) ProtoReflect() protoreflect.Message + func (x *RestartServicesRequest) Reset() + func (x *RestartServicesRequest) String() string + type Service303Client interface + GetMetrics func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*MetricsContainer, error) + GetOperationalStates func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GetOperationalStatesResponse, error) + GetServiceInfo func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ServiceInfo, error) + ReloadServiceConfig func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ReloadConfigResponse, error) + SetLogLevel func(ctx context.Context, in *LogLevelMessage, opts ...grpc.CallOption) (*Void, error) + SetLogVerbosity func(ctx context.Context, in *LogVerbosity, opts ...grpc.CallOption) (*Void, error) + StopService func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) + func NewService303Client(cc grpc.ClientConnInterface) Service303Client + type Service303Server interface + GetMetrics func(context.Context, *Void) (*MetricsContainer, error) + GetOperationalStates func(context.Context, *Void) (*GetOperationalStatesResponse, error) + GetServiceInfo func(context.Context, *Void) (*ServiceInfo, error) + ReloadServiceConfig func(context.Context, *Void) (*ReloadConfigResponse, error) + SetLogLevel func(context.Context, *LogLevelMessage) (*Void, error) + SetLogVerbosity func(context.Context, *LogVerbosity) (*Void, error) + StopService func(context.Context, *Void) (*Void, error) + type ServiceExitStatus struct + LatestExitCode ServiceExitStatus_ExitCode + LatestRc uint32 + LatestServiceResult ServiceExitStatus_ServiceResult + NumCleanExits uint32 + NumFailExits uint32 + func (*ServiceExitStatus) Descriptor() ([]byte, []int) + func (*ServiceExitStatus) ProtoMessage() + func (x *ServiceExitStatus) GetLatestExitCode() ServiceExitStatus_ExitCode + func (x *ServiceExitStatus) GetLatestRc() uint32 + func (x *ServiceExitStatus) GetLatestServiceResult() ServiceExitStatus_ServiceResult + func (x *ServiceExitStatus) GetNumCleanExits() uint32 + func (x *ServiceExitStatus) GetNumFailExits() uint32 + func (x *ServiceExitStatus) ProtoReflect() protoreflect.Message + func (x *ServiceExitStatus) Reset() + func (x *ServiceExitStatus) String() string + type ServiceExitStatus_ExitCode int32 + const ServiceExitStatus_DUMPED + const ServiceExitStatus_EXITED + const ServiceExitStatus_KILLED + const ServiceExitStatus_UNUSED_EXIT_CODE + func (ServiceExitStatus_ExitCode) Descriptor() protoreflect.EnumDescriptor + func (ServiceExitStatus_ExitCode) EnumDescriptor() ([]byte, []int) + func (ServiceExitStatus_ExitCode) Type() protoreflect.EnumType + func (x ServiceExitStatus_ExitCode) Enum() *ServiceExitStatus_ExitCode + func (x ServiceExitStatus_ExitCode) Number() protoreflect.EnumNumber + func (x ServiceExitStatus_ExitCode) String() string + type ServiceExitStatus_ServiceResult int32 + const ServiceExitStatus_CORE_DUMP + const ServiceExitStatus_EXIT_CODE + const ServiceExitStatus_PROTOCOL + const ServiceExitStatus_RESOURCES + const ServiceExitStatus_SIGNAL + const ServiceExitStatus_START_LIMIT_HIT + const ServiceExitStatus_SUCCESS + const ServiceExitStatus_TIMEOUT + const ServiceExitStatus_UNUSED + const ServiceExitStatus_WATCHDOG + func (ServiceExitStatus_ServiceResult) Descriptor() protoreflect.EnumDescriptor + func (ServiceExitStatus_ServiceResult) EnumDescriptor() ([]byte, []int) + func (ServiceExitStatus_ServiceResult) Type() protoreflect.EnumType + func (x ServiceExitStatus_ServiceResult) Enum() *ServiceExitStatus_ServiceResult + func (x ServiceExitStatus_ServiceResult) Number() protoreflect.EnumNumber + func (x ServiceExitStatus_ServiceResult) String() string + type ServiceInfo struct + Health ServiceInfo_ApplicationHealth + Name string + StartTimeSecs uint64 + State ServiceInfo_ServiceState + Status *ServiceStatus + Version string + func (*ServiceInfo) Descriptor() ([]byte, []int) + func (*ServiceInfo) ProtoMessage() + func (x *ServiceInfo) GetHealth() ServiceInfo_ApplicationHealth + func (x *ServiceInfo) GetName() string + func (x *ServiceInfo) GetStartTimeSecs() uint64 + func (x *ServiceInfo) GetState() ServiceInfo_ServiceState + func (x *ServiceInfo) GetStatus() *ServiceStatus + func (x *ServiceInfo) GetVersion() string + func (x *ServiceInfo) ProtoReflect() protoreflect.Message + func (x *ServiceInfo) Reset() + func (x *ServiceInfo) String() string + type ServiceInfo_ApplicationHealth int32 + const ServiceInfo_APP_HEALTHY + const ServiceInfo_APP_UNHEALTHY + const ServiceInfo_APP_UNKNOWN + func (ServiceInfo_ApplicationHealth) Descriptor() protoreflect.EnumDescriptor + func (ServiceInfo_ApplicationHealth) EnumDescriptor() ([]byte, []int) + func (ServiceInfo_ApplicationHealth) Type() protoreflect.EnumType + func (x ServiceInfo_ApplicationHealth) Enum() *ServiceInfo_ApplicationHealth + func (x ServiceInfo_ApplicationHealth) Number() protoreflect.EnumNumber + func (x ServiceInfo_ApplicationHealth) String() string + type ServiceInfo_ServiceState int32 + const ServiceInfo_ALIVE + const ServiceInfo_STARTING + const ServiceInfo_STOPPED + const ServiceInfo_STOPPING + const ServiceInfo_UNKNOWN + func (ServiceInfo_ServiceState) Descriptor() protoreflect.EnumDescriptor + func (ServiceInfo_ServiceState) EnumDescriptor() ([]byte, []int) + func (ServiceInfo_ServiceState) Type() protoreflect.EnumType + func (x ServiceInfo_ServiceState) Enum() *ServiceInfo_ServiceState + func (x ServiceInfo_ServiceState) Number() protoreflect.EnumNumber + func (x ServiceInfo_ServiceState) String() string + type ServiceStatus struct + Meta map[string]string + func (*ServiceStatus) Descriptor() ([]byte, []int) + func (*ServiceStatus) ProtoMessage() + func (x *ServiceStatus) GetMeta() map[string]string + func (x *ServiceStatus) ProtoReflect() protoreflect.Message + func (x *ServiceStatus) Reset() + func (x *ServiceStatus) String() string + type State struct + DeviceID string + Type string + Value []byte + Version uint64 + func (*State) Descriptor() ([]byte, []int) + func (*State) ProtoMessage() + func (x *State) GetDeviceID() string + func (x *State) GetType() string + func (x *State) GetValue() []byte + func (x *State) GetVersion() uint64 + func (x *State) ProtoReflect() protoreflect.Message + func (x *State) Reset() + func (x *State) String() string + type StateID struct + DeviceID string + Type string + func (*StateID) Descriptor() ([]byte, []int) + func (*StateID) ProtoMessage() + func (x *StateID) GetDeviceID() string + func (x *StateID) GetType() string + func (x *StateID) ProtoReflect() protoreflect.Message + func (x *StateID) Reset() + func (x *StateID) String() string + type StateServiceClient interface + DeleteStates func(ctx context.Context, in *DeleteStatesRequest, opts ...grpc.CallOption) (*Void, error) + GetStates func(ctx context.Context, in *GetStatesRequest, opts ...grpc.CallOption) (*GetStatesResponse, error) + ReportStates func(ctx context.Context, in *ReportStatesRequest, opts ...grpc.CallOption) (*ReportStatesResponse, error) + SyncStates func(ctx context.Context, in *SyncStatesRequest, opts ...grpc.CallOption) (*SyncStatesResponse, error) + func NewStateServiceClient(cc grpc.ClientConnInterface) StateServiceClient + type StateServiceServer interface + DeleteStates func(context.Context, *DeleteStatesRequest) (*Void, error) + GetStates func(context.Context, *GetStatesRequest) (*GetStatesResponse, error) + ReportStates func(context.Context, *ReportStatesRequest) (*ReportStatesResponse, error) + SyncStates func(context.Context, *SyncStatesRequest) (*SyncStatesResponse, error) + type StreamRequest struct + ExtraArgs *any.Any + GatewayId string + StreamName string + func (*StreamRequest) Descriptor() ([]byte, []int) + func (*StreamRequest) ProtoMessage() + func (x *StreamRequest) GetExtraArgs() *any.Any + func (x *StreamRequest) GetGatewayId() string + func (x *StreamRequest) GetStreamName() string + func (x *StreamRequest) ProtoReflect() protoreflect.Message + func (x *StreamRequest) Reset() + func (x *StreamRequest) String() string + type StreamerClient interface + GetUpdates func(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (Streamer_GetUpdatesClient, error) + func NewStreamerClient(cc grpc.ClientConnInterface) StreamerClient + type StreamerServer interface + GetUpdates func(*StreamRequest, Streamer_GetUpdatesServer) error + type Streamer_GetUpdatesClient interface + Recv func() (*DataUpdateBatch, error) + type Streamer_GetUpdatesServer interface + Send func(*DataUpdateBatch) error + type SyncRPCRequest struct + ConnClosed bool + HeartBeat bool + ReqBody *GatewayRequest + ReqId uint32 + func (*SyncRPCRequest) Descriptor() ([]byte, []int) + func (*SyncRPCRequest) ProtoMessage() + func (x *SyncRPCRequest) GetConnClosed() bool + func (x *SyncRPCRequest) GetHeartBeat() bool + func (x *SyncRPCRequest) GetReqBody() *GatewayRequest + func (x *SyncRPCRequest) GetReqId() uint32 + func (x *SyncRPCRequest) ProtoReflect() protoreflect.Message + func (x *SyncRPCRequest) Reset() + func (x *SyncRPCRequest) String() string + type SyncRPCResponse struct + HeartBeat bool + ReqId uint32 + RespBody *GatewayResponse + func (*SyncRPCResponse) Descriptor() ([]byte, []int) + func (*SyncRPCResponse) ProtoMessage() + func (x *SyncRPCResponse) GetHeartBeat() bool + func (x *SyncRPCResponse) GetReqId() uint32 + func (x *SyncRPCResponse) GetRespBody() *GatewayResponse + func (x *SyncRPCResponse) ProtoReflect() protoreflect.Message + func (x *SyncRPCResponse) Reset() + func (x *SyncRPCResponse) String() string + type SyncRPCServiceClient interface + EstablishSyncRPCStream func(ctx context.Context, opts ...grpc.CallOption) (SyncRPCService_EstablishSyncRPCStreamClient, error) + SyncRPC func(ctx context.Context, opts ...grpc.CallOption) (SyncRPCService_SyncRPCClient, error) + func NewSyncRPCServiceClient(cc grpc.ClientConnInterface) SyncRPCServiceClient + type SyncRPCServiceServer interface + EstablishSyncRPCStream func(SyncRPCService_EstablishSyncRPCStreamServer) error + SyncRPC func(SyncRPCService_SyncRPCServer) error + type SyncRPCService_EstablishSyncRPCStreamClient interface + Recv func() (*SyncRPCRequest, error) + Send func(*SyncRPCResponse) error + type SyncRPCService_EstablishSyncRPCStreamServer interface + Recv func() (*SyncRPCResponse, error) + Send func(*SyncRPCRequest) error + type SyncRPCService_SyncRPCClient interface + Recv func() (*SyncRPCRequest, error) + Send func(*SyncRPCResponse) error + type SyncRPCService_SyncRPCServer interface + Recv func() (*SyncRPCResponse, error) + Send func(*SyncRPCRequest) error + type SyncStatesRequest struct + States []*IDAndVersion + func (*SyncStatesRequest) Descriptor() ([]byte, []int) + func (*SyncStatesRequest) ProtoMessage() + func (x *SyncStatesRequest) GetStates() []*IDAndVersion + func (x *SyncStatesRequest) ProtoReflect() protoreflect.Message + func (x *SyncStatesRequest) Reset() + func (x *SyncStatesRequest) String() string + type SyncStatesResponse struct + UnsyncedStates []*IDAndVersion + func (*SyncStatesResponse) Descriptor() ([]byte, []int) + func (*SyncStatesResponse) ProtoMessage() + func (x *SyncStatesResponse) GetUnsyncedStates() []*IDAndVersion + func (x *SyncStatesResponse) ProtoReflect() protoreflect.Message + func (x *SyncStatesResponse) Reset() + func (x *SyncStatesResponse) String() string + type TailLogsRequest struct + Service string + func (*TailLogsRequest) Descriptor() ([]byte, []int) + func (*TailLogsRequest) ProtoMessage() + func (x *TailLogsRequest) GetService() string + func (x *TailLogsRequest) ProtoReflect() protoreflect.Message + func (x *TailLogsRequest) Reset() + func (x *TailLogsRequest) String() string + type Tenant struct + Name string + Networks []string + func (*Tenant) Descriptor() ([]byte, []int) + func (*Tenant) ProtoMessage() + func (x *Tenant) GetName() string + func (x *Tenant) GetNetworks() []string + func (x *Tenant) ProtoReflect() protoreflect.Message + func (x *Tenant) Reset() + func (x *Tenant) String() string + type TenantList struct + Tenants []*IDAndTenant + func (*TenantList) Descriptor() ([]byte, []int) + func (*TenantList) ProtoMessage() + func (x *TenantList) GetTenants() []*IDAndTenant + func (x *TenantList) ProtoReflect() protoreflect.Message + func (x *TenantList) Reset() + func (x *TenantList) String() string + type TenantsServiceClient interface + CreateTenant func(ctx context.Context, in *IDAndTenant, opts ...grpc.CallOption) (*Void, error) + DeleteTenant func(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*Void, error) + GetAllTenants func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*TenantList, error) + GetTenant func(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*Tenant, error) + SetTenant func(ctx context.Context, in *IDAndTenant, opts ...grpc.CallOption) (*Void, error) + func NewTenantsServiceClient(cc grpc.ClientConnInterface) TenantsServiceClient + type TenantsServiceServer interface + CreateTenant func(context.Context, *IDAndTenant) (*Void, error) + DeleteTenant func(context.Context, *GetTenantRequest) (*Void, error) + GetAllTenants func(context.Context, *Void) (*TenantList, error) + GetTenant func(context.Context, *GetTenantRequest) (*Tenant, error) + SetTenant func(context.Context, *IDAndTenant) (*Void, error) + type TracerouteHop struct + Idx int32 + Probes []*TracerouteProbe + func (*TracerouteHop) Descriptor() ([]byte, []int) + func (*TracerouteHop) ProtoMessage() + func (x *TracerouteHop) GetIdx() int32 + func (x *TracerouteHop) GetProbes() []*TracerouteProbe + func (x *TracerouteHop) ProtoReflect() protoreflect.Message + func (x *TracerouteHop) Reset() + func (x *TracerouteHop) String() string + type TracerouteParams struct + BytesPerPacket int32 + HostOrIp string + MaxHops int32 + func (*TracerouteParams) Descriptor() ([]byte, []int) + func (*TracerouteParams) ProtoMessage() + func (x *TracerouteParams) GetBytesPerPacket() int32 + func (x *TracerouteParams) GetHostOrIp() string + func (x *TracerouteParams) GetMaxHops() int32 + func (x *TracerouteParams) ProtoReflect() protoreflect.Message + func (x *TracerouteParams) Reset() + func (x *TracerouteParams) String() string + type TracerouteProbe struct + Hostname string + Ip string + RttMs float32 + func (*TracerouteProbe) Descriptor() ([]byte, []int) + func (*TracerouteProbe) ProtoMessage() + func (x *TracerouteProbe) GetHostname() string + func (x *TracerouteProbe) GetIp() string + func (x *TracerouteProbe) GetRttMs() float32 + func (x *TracerouteProbe) ProtoReflect() protoreflect.Message + func (x *TracerouteProbe) Reset() + func (x *TracerouteProbe) String() string + type TracerouteResult struct + Error string + Hops []*TracerouteHop + HostOrIp string + func (*TracerouteResult) Descriptor() ([]byte, []int) + func (*TracerouteResult) ProtoMessage() + func (x *TracerouteResult) GetError() string + func (x *TracerouteResult) GetHops() []*TracerouteHop + func (x *TracerouteResult) GetHostOrIp() string + func (x *TracerouteResult) ProtoReflect() protoreflect.Message + func (x *TracerouteResult) Reset() + func (x *TracerouteResult) String() string + type UnimplementedBootstrapperServer struct + func (*UnimplementedBootstrapperServer) GetChallenge(context.Context, *AccessGatewayID) (*Challenge, error) + func (*UnimplementedBootstrapperServer) RequestSign(context.Context, *Response) (*Certificate, error) + type UnimplementedDirectoryLookupServer struct + func (*UnimplementedDirectoryLookupServer) GetHostnameForHWID(context.Context, *GetHostnameForHWIDRequest) (*GetHostnameForHWIDResponse, error) + func (*UnimplementedDirectoryLookupServer) GetIMSIForSessionID(context.Context, *GetIMSIForSessionIDRequest) (*GetIMSIForSessionIDResponse, error) + func (*UnimplementedDirectoryLookupServer) MapHWIDsToHostnames(context.Context, *MapHWIDToHostnameRequest) (*Void, error) + func (*UnimplementedDirectoryLookupServer) MapSessionIDsToIMSIs(context.Context, *MapSessionIDToIMSIRequest) (*Void, error) + type UnimplementedEventServiceServer struct + func (*UnimplementedEventServiceServer) LogEvent(context.Context, *Event) (*Void, error) + type UnimplementedGatewayDirectoryServiceServer struct + func (*UnimplementedGatewayDirectoryServiceServer) DeleteRecord(context.Context, *DeleteRecordRequest) (*Void, error) + func (*UnimplementedGatewayDirectoryServiceServer) GetAllDirectoryRecords(context.Context, *Void) (*AllDirectoryRecords, error) + func (*UnimplementedGatewayDirectoryServiceServer) GetDirectoryField(context.Context, *GetDirectoryFieldRequest) (*DirectoryField, error) + func (*UnimplementedGatewayDirectoryServiceServer) UpdateRecord(context.Context, *UpdateRecordRequest) (*Void, error) + type UnimplementedMagmadServer struct + func (*UnimplementedMagmadServer) GenericCommand(context.Context, *GenericCommandParams) (*GenericCommandResponse, error) + func (*UnimplementedMagmadServer) GetConfigs(context.Context, *Void) (*GatewayConfigs, error) + func (*UnimplementedMagmadServer) GetGatewayId(context.Context, *Void) (*GetGatewayIdResponse, error) + func (*UnimplementedMagmadServer) Reboot(context.Context, *Void) (*Void, error) + func (*UnimplementedMagmadServer) RestartServices(context.Context, *RestartServicesRequest) (*Void, error) + func (*UnimplementedMagmadServer) RunNetworkTests(context.Context, *NetworkTestRequest) (*NetworkTestResponse, error) + func (*UnimplementedMagmadServer) SetConfigs(context.Context, *GatewayConfigs) (*Void, error) + func (*UnimplementedMagmadServer) StartServices(context.Context, *Void) (*Void, error) + func (*UnimplementedMagmadServer) StopServices(context.Context, *Void) (*Void, error) + func (*UnimplementedMagmadServer) TailLogs(*TailLogsRequest, Magmad_TailLogsServer) error + type UnimplementedMetricsControllerServer struct + func (*UnimplementedMetricsControllerServer) Collect(context.Context, *MetricsContainer) (*Void, error) + func (*UnimplementedMetricsControllerServer) Push(context.Context, *PushedMetricsContainer) (*Void, error) + type UnimplementedService303Server struct + func (*UnimplementedService303Server) GetMetrics(context.Context, *Void) (*MetricsContainer, error) + func (*UnimplementedService303Server) GetOperationalStates(context.Context, *Void) (*GetOperationalStatesResponse, error) + func (*UnimplementedService303Server) GetServiceInfo(context.Context, *Void) (*ServiceInfo, error) + func (*UnimplementedService303Server) ReloadServiceConfig(context.Context, *Void) (*ReloadConfigResponse, error) + func (*UnimplementedService303Server) SetLogLevel(context.Context, *LogLevelMessage) (*Void, error) + func (*UnimplementedService303Server) SetLogVerbosity(context.Context, *LogVerbosity) (*Void, error) + func (*UnimplementedService303Server) StopService(context.Context, *Void) (*Void, error) + type UnimplementedStateServiceServer struct + func (*UnimplementedStateServiceServer) DeleteStates(context.Context, *DeleteStatesRequest) (*Void, error) + func (*UnimplementedStateServiceServer) GetStates(context.Context, *GetStatesRequest) (*GetStatesResponse, error) + func (*UnimplementedStateServiceServer) ReportStates(context.Context, *ReportStatesRequest) (*ReportStatesResponse, error) + func (*UnimplementedStateServiceServer) SyncStates(context.Context, *SyncStatesRequest) (*SyncStatesResponse, error) + type UnimplementedStreamerServer struct + func (*UnimplementedStreamerServer) GetUpdates(*StreamRequest, Streamer_GetUpdatesServer) error + type UnimplementedSyncRPCServiceServer struct + func (*UnimplementedSyncRPCServiceServer) EstablishSyncRPCStream(SyncRPCService_EstablishSyncRPCStreamServer) error + func (*UnimplementedSyncRPCServiceServer) SyncRPC(SyncRPCService_SyncRPCServer) error + type UnimplementedTenantsServiceServer struct + func (*UnimplementedTenantsServiceServer) CreateTenant(context.Context, *IDAndTenant) (*Void, error) + func (*UnimplementedTenantsServiceServer) DeleteTenant(context.Context, *GetTenantRequest) (*Void, error) + func (*UnimplementedTenantsServiceServer) GetAllTenants(context.Context, *Void) (*TenantList, error) + func (*UnimplementedTenantsServiceServer) GetTenant(context.Context, *GetTenantRequest) (*Tenant, error) + func (*UnimplementedTenantsServiceServer) SetTenant(context.Context, *IDAndTenant) (*Void, error) + type UpdateRecordRequest struct + Fields map[string]string + Id string + Location string + func (*UpdateRecordRequest) Descriptor() ([]byte, []int) + func (*UpdateRecordRequest) ProtoMessage() + func (x *UpdateRecordRequest) GetFields() map[string]string + func (x *UpdateRecordRequest) GetId() string + func (x *UpdateRecordRequest) GetLocation() string + func (x *UpdateRecordRequest) ProtoReflect() protoreflect.Message + func (x *UpdateRecordRequest) Reset() + func (x *UpdateRecordRequest) String() string + type Void struct + func (*Void) Descriptor() ([]byte, []int) + func (*Void) ProtoMessage() + func (x *Void) ProtoReflect() protoreflect.Message + func (x *Void) Reset() + func (x *Void) String() string Other modules containing this package github.com/go-magma/magma
Go to main page