Documentation
¶
Overview ¶
Package mconfig is protoc generated GRPC package as well as helper functions such as FillIn
identity_helper provides Identity setter methods, missing in protobuf 3 while protoc generates oneof type getters, setters re missing
Package protos is protoc generated GRPC package ¶
Package protos is protoc generated GRPC package and related continence functions
Index ¶
- Constants
- Variables
- 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
- type AllDirectoryRecords
- func (*AllDirectoryRecords) Descriptor() ([]byte, []int)deprecated
- func (x *AllDirectoryRecords) GetRecords() []*DirectoryRecord
- func (*AllDirectoryRecords) ProtoMessage()
- func (x *AllDirectoryRecords) ProtoReflect() protoreflect.Message
- func (x *AllDirectoryRecords) Reset()
- func (x *AllDirectoryRecords) String() string
- type BootstrapperClient
- type BootstrapperServer
- type Bytes
- func (*Bytes) Descriptor() ([]byte, []int)deprecated
- func (x *Bytes) GetVal() []byte
- func (bm *Bytes) MarshalJSONPB(_ *jsonpb.Marshaler) ([]byte, error)
- func (*Bytes) ProtoMessage()
- func (x *Bytes) ProtoReflect() protoreflect.Message
- func (x *Bytes) Reset()
- func (x *Bytes) String() string
- func (bm *Bytes) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- type CACert
- type CSR
- func (*CSR) Descriptor() ([]byte, []int)deprecated
- func (x *CSR) GetCertType() CertType
- func (x *CSR) GetCsrDer() []byte
- func (x *CSR) GetId() *Identity
- func (x *CSR) GetValidTime() *duration.Duration
- func (*CSR) ProtoMessage()
- func (x *CSR) ProtoReflect() protoreflect.Message
- func (x *CSR) Reset()
- func (x *CSR) String() string
- type CertType
- type Certificate
- func (*Certificate) Descriptor() ([]byte, []int)deprecated
- func (x *Certificate) GetCertDer() []byte
- func (x *Certificate) GetNotAfter() *timestamp.Timestamp
- func (x *Certificate) GetNotBefore() *timestamp.Timestamp
- func (x *Certificate) GetSn() *Certificate_SN
- func (*Certificate) ProtoMessage()
- func (x *Certificate) ProtoReflect() protoreflect.Message
- func (x *Certificate) Reset()
- func (x *Certificate) String() string
- type Certificate_SN
- type Challenge
- func (*Challenge) Descriptor() ([]byte, []int)deprecated
- func (x *Challenge) GetChallenge() []byte
- func (x *Challenge) GetKeyType() ChallengeKey_KeyType
- func (*Challenge) ProtoMessage()
- func (x *Challenge) ProtoReflect() protoreflect.Message
- func (x *Challenge) Reset()
- func (x *Challenge) String() string
- type ChallengeKey
- func (*ChallengeKey) Descriptor() ([]byte, []int)deprecated
- func (x *ChallengeKey) GetKey() []byte
- func (x *ChallengeKey) GetKeyType() ChallengeKey_KeyType
- func (*ChallengeKey) ProtoMessage()
- func (x *ChallengeKey) ProtoReflect() protoreflect.Message
- func (x *ChallengeKey) Reset()
- func (x *ChallengeKey) String() string
- type ChallengeKey_KeyType
- func (ChallengeKey_KeyType) Descriptor() protoreflect.EnumDescriptor
- func (x ChallengeKey_KeyType) Enum() *ChallengeKey_KeyType
- func (ChallengeKey_KeyType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChallengeKey_KeyType) Number() protoreflect.EnumNumber
- func (x ChallengeKey_KeyType) String() string
- func (ChallengeKey_KeyType) Type() protoreflect.EnumType
- type DataUpdate
- type DataUpdateBatch
- func (*DataUpdateBatch) Descriptor() ([]byte, []int)deprecated
- func (x *DataUpdateBatch) GetResync() bool
- func (x *DataUpdateBatch) GetUpdates() []*DataUpdate
- func (*DataUpdateBatch) ProtoMessage()
- func (x *DataUpdateBatch) ProtoReflect() protoreflect.Message
- func (x *DataUpdateBatch) Reset()
- func (x *DataUpdateBatch) String() string
- type DeleteRecordRequest
- func (*DeleteRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRecordRequest) GetId() string
- func (*DeleteRecordRequest) ProtoMessage()
- func (x *DeleteRecordRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRecordRequest) Reset()
- func (x *DeleteRecordRequest) String() string
- type DeleteStatesRequest
- func (*DeleteStatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteStatesRequest) GetIds() []*StateID
- func (x *DeleteStatesRequest) GetNetworkID() string
- func (*DeleteStatesRequest) ProtoMessage()
- func (x *DeleteStatesRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteStatesRequest) Reset()
- func (x *DeleteStatesRequest) String() string
- type DirectoryField
- func (*DirectoryField) Descriptor() ([]byte, []int)deprecated
- func (x *DirectoryField) GetKey() string
- func (x *DirectoryField) GetValue() string
- func (*DirectoryField) ProtoMessage()
- func (x *DirectoryField) ProtoReflect() protoreflect.Message
- func (x *DirectoryField) Reset()
- func (x *DirectoryField) String() string
- type DirectoryLookupClient
- type DirectoryLookupServer
- type DirectoryRecord
- func (*DirectoryRecord) Descriptor() ([]byte, []int)deprecated
- func (x *DirectoryRecord) GetFields() map[string]string
- func (x *DirectoryRecord) GetId() string
- func (x *DirectoryRecord) GetLocationHistory() []string
- func (*DirectoryRecord) ProtoMessage()
- func (x *DirectoryRecord) ProtoReflect() protoreflect.Message
- func (x *DirectoryRecord) Reset()
- func (x *DirectoryRecord) String() string
- type EnodebdStatus
- func (*EnodebdStatus) Descriptor() ([]byte, []int)deprecated
- 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 (*EnodebdStatus) ProtoMessage()
- func (x *EnodebdStatus) ProtoReflect() protoreflect.Message
- func (x *EnodebdStatus) Reset()
- func (x *EnodebdStatus) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetEventType() string
- func (x *Event) GetStreamName() string
- func (x *Event) GetTag() string
- func (x *Event) GetValue() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventServiceClient
- type EventServiceServer
- type GatewayConfigs
- func (*GatewayConfigs) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayConfigs) GetConfigsByKey() map[string]*any.Any
- func (cfg *GatewayConfigs) GetMconfigDigest() (string, error)
- func (x *GatewayConfigs) GetMetadata() *GatewayConfigsMetadata
- func (*GatewayConfigs) ProtoMessage()
- func (x *GatewayConfigs) ProtoReflect() protoreflect.Message
- func (x *GatewayConfigs) Reset()
- func (x *GatewayConfigs) String() string
- type GatewayConfigsDigest
- func (*GatewayConfigsDigest) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayConfigsDigest) GetMd5HexDigest() string
- func (*GatewayConfigsDigest) ProtoMessage()
- func (x *GatewayConfigsDigest) ProtoReflect() protoreflect.Message
- func (x *GatewayConfigsDigest) Reset()
- func (x *GatewayConfigsDigest) String() string
- type GatewayConfigsMetadata
- func (*GatewayConfigsMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayConfigsMetadata) GetCreatedAt() uint64
- func (x *GatewayConfigsMetadata) GetDigest() *GatewayConfigsDigest
- func (*GatewayConfigsMetadata) ProtoMessage()
- func (x *GatewayConfigsMetadata) ProtoReflect() protoreflect.Message
- func (x *GatewayConfigsMetadata) Reset()
- func (x *GatewayConfigsMetadata) String() string
- type GatewayDirectoryServiceClient
- type GatewayDirectoryServiceServer
- type GatewayRequest
- func (*GatewayRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*GatewayRequest) ProtoMessage()
- func (x *GatewayRequest) ProtoReflect() protoreflect.Message
- func (x *GatewayRequest) Reset()
- func (x *GatewayRequest) String() string
- type GatewayResponse
- func (*GatewayResponse) Descriptor() ([]byte, []int)deprecated
- 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 (*GatewayResponse) ProtoMessage()
- func (x *GatewayResponse) ProtoReflect() protoreflect.Message
- func (x *GatewayResponse) Reset()
- func (x *GatewayResponse) String() string
- type GenericCommandParams
- func (*GenericCommandParams) Descriptor() ([]byte, []int)deprecated
- func (x *GenericCommandParams) GetCommand() string
- func (x *GenericCommandParams) GetParams() *_struct.Struct
- func (*GenericCommandParams) ProtoMessage()
- func (x *GenericCommandParams) ProtoReflect() protoreflect.Message
- func (x *GenericCommandParams) Reset()
- func (x *GenericCommandParams) String() string
- type GenericCommandResponse
- func (*GenericCommandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenericCommandResponse) GetResponse() *_struct.Struct
- func (*GenericCommandResponse) ProtoMessage()
- func (x *GenericCommandResponse) ProtoReflect() protoreflect.Message
- func (x *GenericCommandResponse) Reset()
- func (x *GenericCommandResponse) String() string
- type GetDirectoryFieldRequest
- func (*GetDirectoryFieldRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDirectoryFieldRequest) GetFieldKey() string
- func (x *GetDirectoryFieldRequest) GetId() string
- func (*GetDirectoryFieldRequest) ProtoMessage()
- func (x *GetDirectoryFieldRequest) ProtoReflect() protoreflect.Message
- func (x *GetDirectoryFieldRequest) Reset()
- func (x *GetDirectoryFieldRequest) String() string
- type GetGatewayIdResponse
- func (*GetGatewayIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetGatewayIdResponse) GetGatewayId() string
- func (*GetGatewayIdResponse) ProtoMessage()
- func (x *GetGatewayIdResponse) ProtoReflect() protoreflect.Message
- func (x *GetGatewayIdResponse) Reset()
- func (x *GetGatewayIdResponse) String() string
- type GetHostnameForHWIDRequest
- func (*GetHostnameForHWIDRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetHostnameForHWIDRequest) GetHwid() string
- func (*GetHostnameForHWIDRequest) ProtoMessage()
- func (x *GetHostnameForHWIDRequest) ProtoReflect() protoreflect.Message
- func (x *GetHostnameForHWIDRequest) Reset()
- func (x *GetHostnameForHWIDRequest) String() string
- func (m *GetHostnameForHWIDRequest) Validate() error
- type GetHostnameForHWIDResponse
- func (*GetHostnameForHWIDResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetHostnameForHWIDResponse) GetHostname() string
- func (*GetHostnameForHWIDResponse) ProtoMessage()
- func (x *GetHostnameForHWIDResponse) ProtoReflect() protoreflect.Message
- func (x *GetHostnameForHWIDResponse) Reset()
- func (x *GetHostnameForHWIDResponse) String() string
- type GetIMSIForSessionIDRequest
- func (*GetIMSIForSessionIDRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetIMSIForSessionIDRequest) GetNetworkID() string
- func (x *GetIMSIForSessionIDRequest) GetSessionID() string
- func (*GetIMSIForSessionIDRequest) ProtoMessage()
- func (x *GetIMSIForSessionIDRequest) ProtoReflect() protoreflect.Message
- func (x *GetIMSIForSessionIDRequest) Reset()
- func (x *GetIMSIForSessionIDRequest) String() string
- func (m *GetIMSIForSessionIDRequest) Validate() error
- type GetIMSIForSessionIDResponse
- func (*GetIMSIForSessionIDResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetIMSIForSessionIDResponse) GetImsi() string
- func (*GetIMSIForSessionIDResponse) ProtoMessage()
- func (x *GetIMSIForSessionIDResponse) ProtoReflect() protoreflect.Message
- func (x *GetIMSIForSessionIDResponse) Reset()
- func (x *GetIMSIForSessionIDResponse) String() string
- type GetOperationalStatesResponse
- func (*GetOperationalStatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOperationalStatesResponse) GetStates() []*State
- func (*GetOperationalStatesResponse) ProtoMessage()
- func (x *GetOperationalStatesResponse) ProtoReflect() protoreflect.Message
- func (x *GetOperationalStatesResponse) Reset()
- func (x *GetOperationalStatesResponse) String() string
- type GetStatesRequest
- func (*GetStatesRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*GetStatesRequest) ProtoMessage()
- func (x *GetStatesRequest) ProtoReflect() protoreflect.Message
- func (x *GetStatesRequest) Reset()
- func (x *GetStatesRequest) String() string
- type GetStatesResponse
- type GetTenantRequest
- type IDAndError
- func (*IDAndError) Descriptor() ([]byte, []int)deprecated
- func (x *IDAndError) GetDeviceID() string
- func (x *IDAndError) GetError() string
- func (x *IDAndError) GetType() string
- func (*IDAndError) ProtoMessage()
- func (x *IDAndError) ProtoReflect() protoreflect.Message
- func (x *IDAndError) Reset()
- func (x *IDAndError) String() string
- type IDAndTenant
- type IDAndVersion
- func (*IDAndVersion) Descriptor() ([]byte, []int)deprecated
- func (x *IDAndVersion) GetId() *StateID
- func (x *IDAndVersion) GetVersion() uint64
- func (*IDAndVersion) ProtoMessage()
- func (x *IDAndVersion) ProtoReflect() protoreflect.Message
- func (x *IDAndVersion) Reset()
- func (x *IDAndVersion) String() string
- type IDList
- type Identity
- 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)deprecated
- func (x *Identity) GetGateway() *Identity_Gateway
- func (x *Identity) GetNetwork() string
- func (x *Identity) GetOperator() string
- func (m *Identity) GetValue() isIdentity_Value
- func (x *Identity) GetWildcard() *Identity_Wildcard
- func (id *Identity) GetWildcardForIdentity() *Identity
- func (id *Identity) HashString() string
- func (wildcard *Identity) Match(entity *Identity) bool
- func (id *Identity) NewContextWithIdentity(ctx context.Context) context.Context
- func (*Identity) ProtoMessage()
- func (x *Identity) ProtoReflect() protoreflect.Message
- func (x *Identity) Reset()
- func (id *Identity) SetGateway(gwId *Identity_Gateway) *Identity
- func (id *Identity) SetNetwork(networkId string) *Identity
- func (id *Identity) SetOperator(opId string) *Identity
- func (x *Identity) String() string
- func (id *Identity) ToCommonName() *string
- func (id *Identity) TypeName() *string
- type Identity_Gateway
- func (*Identity_Gateway) Descriptor() ([]byte, []int)deprecated
- func (x *Identity_Gateway) GetHardwareId() string
- func (x *Identity_Gateway) GetLogicalId() string
- func (x *Identity_Gateway) GetNetworkId() string
- func (*Identity_Gateway) ProtoMessage()
- func (x *Identity_Gateway) ProtoReflect() protoreflect.Message
- func (gw *Identity_Gateway) Registered() bool
- func (x *Identity_Gateway) Reset()
- func (x *Identity_Gateway) String() string
- type Identity_Gateway_
- type Identity_List
- type Identity_Network
- type Identity_Operator
- type Identity_Wildcard
- func (*Identity_Wildcard) Descriptor() ([]byte, []int)deprecated
- func (x *Identity_Wildcard) GetType() Identity_Wildcard_Type
- func (*Identity_Wildcard) ProtoMessage()
- func (x *Identity_Wildcard) ProtoReflect() protoreflect.Message
- func (x *Identity_Wildcard) Reset()
- func (x *Identity_Wildcard) String() string
- type Identity_Wildcard_
- type Identity_Wildcard_Type
- func (Identity_Wildcard_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Identity_Wildcard_Type) Enum() *Identity_Wildcard_Type
- func (Identity_Wildcard_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Identity_Wildcard_Type) Number() protoreflect.EnumNumber
- func (x Identity_Wildcard_Type) String() string
- func (Identity_Wildcard_Type) Type() protoreflect.EnumType
- type LabelPair
- type LogLevel
- type LogLevelMessage
- type LogLine
- type LogVerbosity
- type MagmadClient
- type MagmadServer
- type Magmad_TailLogsClient
- type Magmad_TailLogsServer
- type MapHWIDToHostnameRequest
- func (*MapHWIDToHostnameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MapHWIDToHostnameRequest) GetHwidToHostname() map[string]string
- func (*MapHWIDToHostnameRequest) ProtoMessage()
- func (x *MapHWIDToHostnameRequest) ProtoReflect() protoreflect.Message
- func (x *MapHWIDToHostnameRequest) Reset()
- func (x *MapHWIDToHostnameRequest) String() string
- func (m *MapHWIDToHostnameRequest) Validate() error
- type MapSessionIDToIMSIRequest
- func (*MapSessionIDToIMSIRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MapSessionIDToIMSIRequest) GetNetworkID() string
- func (x *MapSessionIDToIMSIRequest) GetSessionIDToIMSI() map[string]string
- func (*MapSessionIDToIMSIRequest) ProtoMessage()
- func (x *MapSessionIDToIMSIRequest) ProtoReflect() protoreflect.Message
- func (x *MapSessionIDToIMSIRequest) Reset()
- func (x *MapSessionIDToIMSIRequest) String() string
- func (m *MapSessionIDToIMSIRequest) Validate() error
- type MconfigStreamRequest
- func (*MconfigStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MconfigStreamRequest) GetOffset() int64
- func (*MconfigStreamRequest) ProtoMessage()
- func (x *MconfigStreamRequest) ProtoReflect() protoreflect.Message
- func (x *MconfigStreamRequest) Reset()
- func (x *MconfigStreamRequest) String() string
- type MetricLabelName
- func (MetricLabelName) Descriptor() protoreflect.EnumDescriptor
- func (x MetricLabelName) Enum() *MetricLabelName
- func (MetricLabelName) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetricLabelName) Number() protoreflect.EnumNumber
- func (x MetricLabelName) String() string
- func (MetricLabelName) Type() protoreflect.EnumType
- type MetricName
- type MetricsContainer
- func (*MetricsContainer) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsContainer) GetFamily() []*_go.MetricFamily
- func (x *MetricsContainer) GetGatewayId() string
- func (*MetricsContainer) ProtoMessage()
- func (x *MetricsContainer) ProtoReflect() protoreflect.Message
- func (x *MetricsContainer) Reset()
- func (x *MetricsContainer) String() string
- type MetricsControllerClient
- type MetricsControllerServer
- type NetworkID
- type NetworkTestRequest
- func (*NetworkTestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkTestRequest) GetPings() []*PingParams
- func (x *NetworkTestRequest) GetTraceroutes() []*TracerouteParams
- func (*NetworkTestRequest) ProtoMessage()
- func (x *NetworkTestRequest) ProtoReflect() protoreflect.Message
- func (x *NetworkTestRequest) Reset()
- func (x *NetworkTestRequest) String() string
- type NetworkTestResponse
- func (*NetworkTestResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkTestResponse) GetPings() []*PingResult
- func (x *NetworkTestResponse) GetTraceroutes() []*TracerouteResult
- func (*NetworkTestResponse) ProtoMessage()
- func (x *NetworkTestResponse) ProtoReflect() protoreflect.Message
- func (x *NetworkTestResponse) Reset()
- func (x *NetworkTestResponse) String() string
- type OffsetGatewayConfigs
- func (*OffsetGatewayConfigs) Descriptor() ([]byte, []int)deprecated
- func (x *OffsetGatewayConfigs) GetConfigs() *GatewayConfigs
- func (x *OffsetGatewayConfigs) GetOffset() int64
- func (*OffsetGatewayConfigs) ProtoMessage()
- func (x *OffsetGatewayConfigs) ProtoReflect() protoreflect.Message
- func (x *OffsetGatewayConfigs) Reset()
- func (x *OffsetGatewayConfigs) String() string
- type PingParams
- type PingResult
- func (*PingResult) Descriptor() ([]byte, []int)deprecated
- 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 (*PingResult) ProtoMessage()
- func (x *PingResult) ProtoReflect() protoreflect.Message
- func (x *PingResult) Reset()
- func (x *PingResult) String() string
- type PushedMetric
- func (*PushedMetric) Descriptor() ([]byte, []int)deprecated
- func (x *PushedMetric) GetLabels() []*LabelPair
- func (x *PushedMetric) GetMetricName() string
- func (x *PushedMetric) GetTimestampMS() int64
- func (x *PushedMetric) GetValue() float64
- func (*PushedMetric) ProtoMessage()
- func (x *PushedMetric) ProtoReflect() protoreflect.Message
- func (x *PushedMetric) Reset()
- func (x *PushedMetric) String() string
- type PushedMetricsContainer
- func (*PushedMetricsContainer) Descriptor() ([]byte, []int)deprecated
- func (x *PushedMetricsContainer) GetMetrics() []*PushedMetric
- func (x *PushedMetricsContainer) GetNetworkId() string
- func (*PushedMetricsContainer) ProtoMessage()
- func (x *PushedMetricsContainer) ProtoReflect() protoreflect.Message
- func (x *PushedMetricsContainer) Reset()
- func (x *PushedMetricsContainer) String() string
- type RedisState
- func (*RedisState) Descriptor() ([]byte, []int)deprecated
- func (x *RedisState) GetIsGarbage() bool
- func (x *RedisState) GetSerializedMsg() []byte
- func (x *RedisState) GetVersion() uint64
- func (*RedisState) ProtoMessage()
- func (x *RedisState) ProtoReflect() protoreflect.Message
- func (x *RedisState) Reset()
- func (x *RedisState) String() string
- type ReloadConfigResponse
- func (*ReloadConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadConfigResponse) GetResult() ReloadConfigResponse_ReloadConfigResult
- func (*ReloadConfigResponse) ProtoMessage()
- func (x *ReloadConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ReloadConfigResponse) Reset()
- func (x *ReloadConfigResponse) String() string
- type ReloadConfigResponse_ReloadConfigResult
- func (ReloadConfigResponse_ReloadConfigResult) Descriptor() protoreflect.EnumDescriptor
- func (x ReloadConfigResponse_ReloadConfigResult) Enum() *ReloadConfigResponse_ReloadConfigResult
- func (ReloadConfigResponse_ReloadConfigResult) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReloadConfigResponse_ReloadConfigResult) Number() protoreflect.EnumNumber
- func (x ReloadConfigResponse_ReloadConfigResult) String() string
- func (ReloadConfigResponse_ReloadConfigResult) Type() protoreflect.EnumType
- type ReportStatesRequest
- func (*ReportStatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportStatesRequest) GetStates() []*State
- func (*ReportStatesRequest) ProtoMessage()
- func (x *ReportStatesRequest) ProtoReflect() protoreflect.Message
- func (x *ReportStatesRequest) Reset()
- func (x *ReportStatesRequest) String() string
- type ReportStatesResponse
- func (*ReportStatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReportStatesResponse) GetUnreportedStates() []*IDAndError
- func (*ReportStatesResponse) ProtoMessage()
- func (x *ReportStatesResponse) ProtoReflect() protoreflect.Message
- func (x *ReportStatesResponse) Reset()
- func (x *ReportStatesResponse) String() string
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- 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 (m *Response) GetResponse() isResponse_Response
- func (x *Response) GetRsaResponse() *Response_RSA
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type Response_ECDSA
- func (*Response_ECDSA) Descriptor() ([]byte, []int)deprecated
- func (x *Response_ECDSA) GetR() []byte
- func (x *Response_ECDSA) GetS() []byte
- func (*Response_ECDSA) ProtoMessage()
- func (x *Response_ECDSA) ProtoReflect() protoreflect.Message
- func (x *Response_ECDSA) Reset()
- func (x *Response_ECDSA) String() string
- type Response_EcdsaResponse
- type Response_Echo
- type Response_EchoResponse
- type Response_RSA
- type Response_RsaResponse
- type RestartServicesRequest
- func (*RestartServicesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestartServicesRequest) GetServices() []string
- func (*RestartServicesRequest) ProtoMessage()
- func (x *RestartServicesRequest) ProtoReflect() protoreflect.Message
- func (x *RestartServicesRequest) Reset()
- func (x *RestartServicesRequest) String() string
- type Service303Client
- type Service303Server
- type ServiceExitStatus
- func (*ServiceExitStatus) Descriptor() ([]byte, []int)deprecated
- 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 (*ServiceExitStatus) ProtoMessage()
- func (x *ServiceExitStatus) ProtoReflect() protoreflect.Message
- func (x *ServiceExitStatus) Reset()
- func (x *ServiceExitStatus) String() string
- type ServiceExitStatus_ExitCode
- func (ServiceExitStatus_ExitCode) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceExitStatus_ExitCode) Enum() *ServiceExitStatus_ExitCode
- func (ServiceExitStatus_ExitCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceExitStatus_ExitCode) Number() protoreflect.EnumNumber
- func (x ServiceExitStatus_ExitCode) String() string
- func (ServiceExitStatus_ExitCode) Type() protoreflect.EnumType
- type ServiceExitStatus_ServiceResult
- func (ServiceExitStatus_ServiceResult) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceExitStatus_ServiceResult) Enum() *ServiceExitStatus_ServiceResult
- func (ServiceExitStatus_ServiceResult) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceExitStatus_ServiceResult) Number() protoreflect.EnumNumber
- func (x ServiceExitStatus_ServiceResult) String() string
- func (ServiceExitStatus_ServiceResult) Type() protoreflect.EnumType
- type ServiceInfo
- func (*ServiceInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*ServiceInfo) ProtoMessage()
- func (x *ServiceInfo) ProtoReflect() protoreflect.Message
- func (x *ServiceInfo) Reset()
- func (x *ServiceInfo) String() string
- type ServiceInfo_ApplicationHealth
- func (ServiceInfo_ApplicationHealth) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceInfo_ApplicationHealth) Enum() *ServiceInfo_ApplicationHealth
- func (ServiceInfo_ApplicationHealth) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceInfo_ApplicationHealth) Number() protoreflect.EnumNumber
- func (x ServiceInfo_ApplicationHealth) String() string
- func (ServiceInfo_ApplicationHealth) Type() protoreflect.EnumType
- type ServiceInfo_ServiceState
- func (ServiceInfo_ServiceState) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceInfo_ServiceState) Enum() *ServiceInfo_ServiceState
- func (ServiceInfo_ServiceState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceInfo_ServiceState) Number() protoreflect.EnumNumber
- func (x ServiceInfo_ServiceState) String() string
- func (ServiceInfo_ServiceState) Type() protoreflect.EnumType
- type ServiceStatus
- type State
- func (*State) Descriptor() ([]byte, []int)deprecated
- func (x *State) GetDeviceID() string
- func (x *State) GetType() string
- func (x *State) GetValue() []byte
- func (x *State) GetVersion() uint64
- func (*State) ProtoMessage()
- func (x *State) ProtoReflect() protoreflect.Message
- func (x *State) Reset()
- func (x *State) String() string
- type StateID
- type StateServiceClient
- type StateServiceServer
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetExtraArgs() *any.Any
- func (x *StreamRequest) GetGatewayId() string
- func (x *StreamRequest) GetStreamName() string
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type StreamerClient
- type StreamerServer
- type Streamer_GetUpdatesClient
- type Streamer_GetUpdatesServer
- type SyncRPCRequest
- func (*SyncRPCRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncRPCRequest) GetConnClosed() bool
- func (x *SyncRPCRequest) GetHeartBeat() bool
- func (x *SyncRPCRequest) GetReqBody() *GatewayRequest
- func (x *SyncRPCRequest) GetReqId() uint32
- func (*SyncRPCRequest) ProtoMessage()
- func (x *SyncRPCRequest) ProtoReflect() protoreflect.Message
- func (x *SyncRPCRequest) Reset()
- func (x *SyncRPCRequest) String() string
- type SyncRPCResponse
- func (*SyncRPCResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncRPCResponse) GetHeartBeat() bool
- func (x *SyncRPCResponse) GetReqId() uint32
- func (x *SyncRPCResponse) GetRespBody() *GatewayResponse
- func (*SyncRPCResponse) ProtoMessage()
- func (x *SyncRPCResponse) ProtoReflect() protoreflect.Message
- func (x *SyncRPCResponse) Reset()
- func (x *SyncRPCResponse) String() string
- type SyncRPCServiceClient
- type SyncRPCServiceServer
- type SyncRPCService_EstablishSyncRPCStreamClient
- type SyncRPCService_EstablishSyncRPCStreamServer
- type SyncRPCService_SyncRPCClient
- type SyncRPCService_SyncRPCServer
- type SyncStatesRequest
- func (*SyncStatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncStatesRequest) GetStates() []*IDAndVersion
- func (*SyncStatesRequest) ProtoMessage()
- func (x *SyncStatesRequest) ProtoReflect() protoreflect.Message
- func (x *SyncStatesRequest) Reset()
- func (x *SyncStatesRequest) String() string
- type SyncStatesResponse
- func (*SyncStatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncStatesResponse) GetUnsyncedStates() []*IDAndVersion
- func (*SyncStatesResponse) ProtoMessage()
- func (x *SyncStatesResponse) ProtoReflect() protoreflect.Message
- func (x *SyncStatesResponse) Reset()
- func (x *SyncStatesResponse) String() string
- type TailLogsRequest
- type Tenant
- type TenantList
- type TenantsServiceClient
- type TenantsServiceServer
- type TracerouteHop
- func (*TracerouteHop) Descriptor() ([]byte, []int)deprecated
- func (x *TracerouteHop) GetIdx() int32
- func (x *TracerouteHop) GetProbes() []*TracerouteProbe
- func (*TracerouteHop) ProtoMessage()
- func (x *TracerouteHop) ProtoReflect() protoreflect.Message
- func (x *TracerouteHop) Reset()
- func (x *TracerouteHop) String() string
- type TracerouteParams
- func (*TracerouteParams) Descriptor() ([]byte, []int)deprecated
- func (x *TracerouteParams) GetBytesPerPacket() int32
- func (x *TracerouteParams) GetHostOrIp() string
- func (x *TracerouteParams) GetMaxHops() int32
- func (*TracerouteParams) ProtoMessage()
- func (x *TracerouteParams) ProtoReflect() protoreflect.Message
- func (x *TracerouteParams) Reset()
- func (x *TracerouteParams) String() string
- type TracerouteProbe
- func (*TracerouteProbe) Descriptor() ([]byte, []int)deprecated
- func (x *TracerouteProbe) GetHostname() string
- func (x *TracerouteProbe) GetIp() string
- func (x *TracerouteProbe) GetRttMs() float32
- func (*TracerouteProbe) ProtoMessage()
- func (x *TracerouteProbe) ProtoReflect() protoreflect.Message
- func (x *TracerouteProbe) Reset()
- func (x *TracerouteProbe) String() string
- type TracerouteResult
- func (*TracerouteResult) Descriptor() ([]byte, []int)deprecated
- func (x *TracerouteResult) GetError() string
- func (x *TracerouteResult) GetHops() []*TracerouteHop
- func (x *TracerouteResult) GetHostOrIp() string
- func (*TracerouteResult) ProtoMessage()
- func (x *TracerouteResult) ProtoReflect() protoreflect.Message
- func (x *TracerouteResult) Reset()
- func (x *TracerouteResult) String() string
- type UnimplementedBootstrapperServer
- type UnimplementedDirectoryLookupServer
- 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
- type UnimplementedGatewayDirectoryServiceServer
- 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
- 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
- type UnimplementedService303Server
- 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
- 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
- type UnimplementedSyncRPCServiceServer
- type UnimplementedTenantsServiceServer
- 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
- func (*UpdateRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRecordRequest) GetFields() map[string]string
- func (x *UpdateRecordRequest) GetId() string
- func (x *UpdateRecordRequest) GetLocation() string
- func (*UpdateRecordRequest) ProtoMessage()
- func (x *UpdateRecordRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRecordRequest) Reset()
- func (x *UpdateRecordRequest) String() string
- type Void
Constants ¶
const MAGMA_ALT_NAME_TAG string = "magma_alt_name"
Go Struct tag to specify an alternative name for field name matching
Variables ¶
var ( ChallengeKey_KeyType_name = map[int32]string{ 0: "ECHO", 1: "SOFTWARE_RSA_SHA256", 2: "SOFTWARE_ECDSA_SHA256", } ChallengeKey_KeyType_value = map[string]int32{ "ECHO": 0, "SOFTWARE_RSA_SHA256": 1, "SOFTWARE_ECDSA_SHA256": 2, } )
Enum value maps for ChallengeKey_KeyType.
var ( CertType_name = map[int32]string{ 0: "DEFAULT", 1: "VPN", } CertType_value = map[string]int32{ "DEFAULT": 0, "VPN": 1, } )
Enum value maps for CertType.
var ( LogLevel_name = map[int32]string{ 0: "DEBUG", 1: "INFO", 2: "WARNING", 3: "ERROR", 4: "FATAL", } LogLevel_value = map[string]int32{ "DEBUG": 0, "INFO": 1, "WARNING": 2, "ERROR": 3, "FATAL": 4, } )
Enum value maps for LogLevel.
var ( Identity_Wildcard_Type_name = map[int32]string{ 0: "Gateway", 1: "Operator", 2: "Network", } Identity_Wildcard_Type_value = map[string]int32{ "Gateway": 0, "Operator": 1, "Network": 2, } )
Enum value maps for Identity_Wildcard_Type.
var ( MetricName_name = map[int32]string{}/* 119 elements not displayed */ MetricName_value = map[string]int32{}/* 119 elements not displayed */ )
Enum value maps for MetricName.
var ( MetricLabelName_name = map[int32]string{ 0: "result", 1: "cause", 2: "tau_type", 3: "pdn_type", 4: "action", 5: "host", 6: "metric", 7: "patchlevel", 8: "minor", 9: "major", 10: "version", 11: "implementation", 12: "sensor", 13: "error_code", 14: "error_type", 15: "iface_name", 16: "service_name", 17: "rule_id", 18: "imsi", } MetricLabelName_value = map[string]int32{ "result": 0, "cause": 1, "tau_type": 2, "pdn_type": 3, "action": 4, "host": 5, "metric": 6, "patchlevel": 7, "minor": 8, "major": 9, "version": 10, "implementation": 11, "sensor": 12, "error_code": 13, "error_type": 14, "iface_name": 15, "service_name": 16, "rule_id": 17, "imsi": 18, } )
Enum value maps for MetricLabelName.
var ( ServiceInfo_ServiceState_name = map[int32]string{ 0: "UNKNOWN", 1: "STARTING", 2: "ALIVE", 3: "STOPPING", 4: "STOPPED", } ServiceInfo_ServiceState_value = map[string]int32{ "UNKNOWN": 0, "STARTING": 1, "ALIVE": 2, "STOPPING": 3, "STOPPED": 4, } )
Enum value maps for ServiceInfo_ServiceState.
var ( ServiceInfo_ApplicationHealth_name = map[int32]string{ 0: "APP_UNKNOWN", 1: "APP_UNHEALTHY", 2: "APP_HEALTHY", } ServiceInfo_ApplicationHealth_value = map[string]int32{ "APP_UNKNOWN": 0, "APP_UNHEALTHY": 1, "APP_HEALTHY": 2, } )
Enum value maps for ServiceInfo_ApplicationHealth.
var ( ReloadConfigResponse_ReloadConfigResult_name = map[int32]string{ 0: "RELOAD_UNKNOWN", 1: "RELOAD_SUCCESS", 2: "RELOAD_FAILURE", 3: "RELOAD_UNSUPPORTED", } ReloadConfigResponse_ReloadConfigResult_value = map[string]int32{ "RELOAD_UNKNOWN": 0, "RELOAD_SUCCESS": 1, "RELOAD_FAILURE": 2, "RELOAD_UNSUPPORTED": 3, } )
Enum value maps for ReloadConfigResponse_ReloadConfigResult.
var ( ServiceExitStatus_ServiceResult_name = map[int32]string{ 0: "UNUSED", 1: "SUCCESS", 2: "PROTOCOL", 3: "TIMEOUT", 4: "EXIT_CODE", 5: "SIGNAL", 6: "CORE_DUMP", 7: "WATCHDOG", 8: "START_LIMIT_HIT", 9: "RESOURCES", } ServiceExitStatus_ServiceResult_value = map[string]int32{ "UNUSED": 0, "SUCCESS": 1, "PROTOCOL": 2, "TIMEOUT": 3, "EXIT_CODE": 4, "SIGNAL": 5, "CORE_DUMP": 6, "WATCHDOG": 7, "START_LIMIT_HIT": 8, "RESOURCES": 9, } )
Enum value maps for ServiceExitStatus_ServiceResult.
var ( ServiceExitStatus_ExitCode_name = map[int32]string{ 0: "UNUSED_EXIT_CODE", 1: "EXITED", 2: "KILLED", 3: "DUMPED", } ServiceExitStatus_ExitCode_value = map[string]int32{ "UNUSED_EXIT_CODE": 0, "EXITED": 1, "KILLED": 2, "DUMPED": 3, } )
Enum value maps for ServiceExitStatus_ExitCode.
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
Functions ¶
func CreateTestIdentityImplValue ¶
func CreateTestIdentityImplValue() isIdentity_Value
func FillIn ¶
func FillIn(src interface{}, dest interface{}) int
FillIn assigns matching field values of src to dest A fields from src & dest are considered "matching" if they have identical names & Types FillIn will recursively inspect structures to find matching fields and return number of successfully set fields
func GetClientCertExpiration ¶
GetClientCertExpiration retreives from cxt & returns Unix time in seconds of client certificate expiration if present, 0 if not present
func GetDecodedLabel ¶
GetDecodedLabel tries to convert the metric label name/value enums to their enum names for display.
func GetDecodedName ¶
func GetDecodedName(m *dto.MetricFamily) string
GetDecodedName gets the enum name for the metric family from the enum value
func GetEnumNameIfPossible ¶
GetEnumNameIfPossible tries to convert a string enum value to the associated enum name. If toConvert doesn't match up with any mapping in protoEnumMapping then this function just returns the original toConvert string.
func GetHashToIdentity ¶
GetHashToIdentity converts the passed slice to a map, whose keys are the hash strings of each Identity proto.
func GetHashableIdentitiesTable ¶
GetHashableIdentitiesNumber returns a new table of type names, it's to be used only by unit tests and should not expose the original table
func MarshalMconfig ¶
MarshalMconfig is a special mconfig marshaler tolerant to unregistered Any types
func MarshalMconfigToString ¶
MarshalMconfigToString - same as MarshalMconfig but returns string
func NewContextWithCertExpiration ¶
NewContextWithCertExpiration returns a new Context that carries the given certificate expiration time
func NewGrpcValidationError ¶
func RegisterBootstrapperServer ¶
func RegisterBootstrapperServer(s *grpc.Server, srv BootstrapperServer)
func RegisterDirectoryLookupServer ¶
func RegisterDirectoryLookupServer(s *grpc.Server, srv DirectoryLookupServer)
func RegisterEventServiceServer ¶
func RegisterEventServiceServer(s *grpc.Server, srv EventServiceServer)
func RegisterGatewayDirectoryServiceServer ¶
func RegisterGatewayDirectoryServiceServer(s *grpc.Server, srv GatewayDirectoryServiceServer)
func RegisterMagmadServer ¶
func RegisterMagmadServer(s *grpc.Server, srv MagmadServer)
func RegisterMetricsControllerServer ¶
func RegisterMetricsControllerServer(s *grpc.Server, srv MetricsControllerServer)
func RegisterService303Server ¶
func RegisterService303Server(s *grpc.Server, srv Service303Server)
func RegisterStateServiceServer ¶
func RegisterStateServiceServer(s *grpc.Server, srv StateServiceServer)
func RegisterStreamerServer ¶
func RegisterStreamerServer(s *grpc.Server, srv StreamerServer)
func RegisterSyncRPCServiceServer ¶
func RegisterSyncRPCServiceServer(s *grpc.Server, srv SyncRPCServiceServer)
func RegisterTenantsServiceServer ¶
func RegisterTenantsServiceServer(s *grpc.Server, srv TenantsServiceServer)
func SafeInit ¶
func SafeInit(s interface{}) interface{}
SafeInit traverses given struct ptr and fills in all nil struct pointer, map & slice fields with defult initialized elements recursively
func TestMarshal ¶
Types ¶
type AccessGatewayID ¶
type AccessGatewayID struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- AccessGatewayID uniquely identifies an access gateway across the system Based on the usage context it could represent either hardware or logical AG ID. --------------------------------------------------------------------------
func (*AccessGatewayID) Descriptor
deprecated
func (*AccessGatewayID) Descriptor() ([]byte, []int)
Deprecated: Use AccessGatewayID.ProtoReflect.Descriptor instead.
func (*AccessGatewayID) GetId ¶
func (x *AccessGatewayID) GetId() string
func (*AccessGatewayID) ProtoMessage ¶
func (*AccessGatewayID) ProtoMessage()
func (*AccessGatewayID) ProtoReflect ¶
func (x *AccessGatewayID) ProtoReflect() protoreflect.Message
func (*AccessGatewayID) Reset ¶
func (x *AccessGatewayID) Reset()
func (*AccessGatewayID) String ¶
func (x *AccessGatewayID) String() string
type AllDirectoryRecords ¶
type AllDirectoryRecords struct { Records []*DirectoryRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*AllDirectoryRecords) Descriptor
deprecated
func (*AllDirectoryRecords) Descriptor() ([]byte, []int)
Deprecated: Use AllDirectoryRecords.ProtoReflect.Descriptor instead.
func (*AllDirectoryRecords) GetRecords ¶
func (x *AllDirectoryRecords) GetRecords() []*DirectoryRecord
func (*AllDirectoryRecords) ProtoMessage ¶
func (*AllDirectoryRecords) ProtoMessage()
func (*AllDirectoryRecords) ProtoReflect ¶
func (x *AllDirectoryRecords) ProtoReflect() protoreflect.Message
func (*AllDirectoryRecords) Reset ¶
func (x *AllDirectoryRecords) Reset()
func (*AllDirectoryRecords) String ¶
func (x *AllDirectoryRecords) String() string
type BootstrapperClient ¶
type BootstrapperClient interface { // get the challange for gateway specified in hw_id (AccessGatewayID) GetChallenge(ctx context.Context, in *AccessGatewayID, opts ...grpc.CallOption) (*Challenge, error) // send back response and csr for signing // Returns signed certificate. RequestSign(ctx context.Context, in *Response, opts ...grpc.CallOption) (*Certificate, error) }
BootstrapperClient is the client API for Bootstrapper service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBootstrapperClient ¶
func NewBootstrapperClient(cc grpc.ClientConnInterface) BootstrapperClient
type BootstrapperServer ¶
type BootstrapperServer interface { // get the challange for gateway specified in hw_id (AccessGatewayID) GetChallenge(context.Context, *AccessGatewayID) (*Challenge, error) // send back response and csr for signing // Returns signed certificate. RequestSign(context.Context, *Response) (*Certificate, error) }
BootstrapperServer is the server API for Bootstrapper service.
type Bytes ¶
type Bytes struct { Val []byte `protobuf:"bytes,1,opt,name=val,proto3" json:"val,omitempty"` // contains filtered or unexported fields }
------------------------------------------------------------------------------- Bytes is a special message type used to marshal & unmarshal unknown types as is -------------------------------------------------------------------------------
func (*Bytes) Descriptor
deprecated
func (*Bytes) MarshalJSONPB ¶
MarshalJSONPB implements JSONPBMarshaler interface for Bytes type
func (*Bytes) ProtoMessage ¶
func (*Bytes) ProtoMessage()
func (*Bytes) ProtoReflect ¶
func (x *Bytes) ProtoReflect() protoreflect.Message
func (*Bytes) UnmarshalJSONPB ¶
func (bm *Bytes) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
UnmarshalJSONPB implements JSONPBUnmarshaler interface for Bytes type
type CACert ¶
type CACert struct { Cert []byte `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"` // ca certificate in DER encoding // contains filtered or unexported fields }
func (*CACert) Descriptor
deprecated
func (*CACert) ProtoMessage ¶
func (*CACert) ProtoMessage()
func (*CACert) ProtoReflect ¶
func (x *CACert) ProtoReflect() protoreflect.Message
type CSR ¶
type CSR struct { Id *Identity `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ValidTime *duration.Duration `protobuf:"bytes,2,opt,name=valid_time,json=validTime,proto3" json:"valid_time,omitempty"` CsrDer []byte `protobuf:"bytes,3,opt,name=csr_der,json=csrDer,proto3" json:"csr_der,omitempty"` // certificate signing request in DER encoding CertType CertType `protobuf:"varint,4,opt,name=cert_type,json=certType,proto3,enum=magma.orc8r.CertType" json:"cert_type,omitempty"` // contains filtered or unexported fields }
func (*CSR) Descriptor
deprecated
func (*CSR) GetCertType ¶
func (*CSR) GetValidTime ¶
func (*CSR) ProtoMessage ¶
func (*CSR) ProtoMessage()
func (*CSR) ProtoReflect ¶
func (x *CSR) ProtoReflect() protoreflect.Message
type CertType ¶
type CertType int32
func (CertType) Descriptor ¶
func (CertType) Descriptor() protoreflect.EnumDescriptor
func (CertType) EnumDescriptor
deprecated
func (CertType) Number ¶
func (x CertType) Number() protoreflect.EnumNumber
func (CertType) Type ¶
func (CertType) Type() protoreflect.EnumType
type Certificate ¶
type Certificate struct { Sn *Certificate_SN `protobuf:"bytes,1,opt,name=sn,proto3" json:"sn,omitempty"` NotBefore *timestamp.Timestamp `protobuf:"bytes,2,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"` NotAfter *timestamp.Timestamp `protobuf:"bytes,3,opt,name=not_after,json=notAfter,proto3" json:"not_after,omitempty"` CertDer []byte `protobuf:"bytes,4,opt,name=cert_der,json=certDer,proto3" json:"cert_der,omitempty"` // signed certificate in DER encoding // contains filtered or unexported fields }
func (*Certificate) Descriptor
deprecated
func (*Certificate) Descriptor() ([]byte, []int)
Deprecated: Use Certificate.ProtoReflect.Descriptor instead.
func (*Certificate) GetCertDer ¶
func (x *Certificate) GetCertDer() []byte
func (*Certificate) GetNotAfter ¶
func (x *Certificate) GetNotAfter() *timestamp.Timestamp
func (*Certificate) GetNotBefore ¶
func (x *Certificate) GetNotBefore() *timestamp.Timestamp
func (*Certificate) GetSn ¶
func (x *Certificate) GetSn() *Certificate_SN
func (*Certificate) ProtoMessage ¶
func (*Certificate) ProtoMessage()
func (*Certificate) ProtoReflect ¶
func (x *Certificate) ProtoReflect() protoreflect.Message
func (*Certificate) Reset ¶
func (x *Certificate) Reset()
func (*Certificate) String ¶
func (x *Certificate) String() string
type Certificate_SN ¶
type Certificate_SN struct { Sn string `protobuf:"bytes,1,opt,name=sn,proto3" json:"sn,omitempty"` // contains filtered or unexported fields }
func (*Certificate_SN) Descriptor
deprecated
func (*Certificate_SN) Descriptor() ([]byte, []int)
Deprecated: Use Certificate_SN.ProtoReflect.Descriptor instead.
func (*Certificate_SN) GetSn ¶
func (x *Certificate_SN) GetSn() string
func (*Certificate_SN) ProtoMessage ¶
func (*Certificate_SN) ProtoMessage()
func (*Certificate_SN) ProtoReflect ¶
func (x *Certificate_SN) ProtoReflect() protoreflect.Message
func (*Certificate_SN) Reset ¶
func (x *Certificate_SN) Reset()
func (*Certificate_SN) String ¶
func (x *Certificate_SN) String() string
type Challenge ¶
type Challenge struct { KeyType ChallengeKey_KeyType `protobuf:"varint,1,opt,name=key_type,json=keyType,proto3,enum=magma.orc8r.ChallengeKey_KeyType" json:"key_type,omitempty"` Challenge []byte `protobuf:"bytes,2,opt,name=challenge,proto3" json:"challenge,omitempty"` // contains filtered or unexported fields }
func (*Challenge) Descriptor
deprecated
func (*Challenge) GetChallenge ¶
func (*Challenge) GetKeyType ¶
func (x *Challenge) GetKeyType() ChallengeKey_KeyType
func (*Challenge) ProtoMessage ¶
func (*Challenge) ProtoMessage()
func (*Challenge) ProtoReflect ¶
func (x *Challenge) ProtoReflect() protoreflect.Message
type ChallengeKey ¶
type ChallengeKey struct { KeyType ChallengeKey_KeyType `protobuf:"varint,1,opt,name=key_type,json=keyType,proto3,enum=magma.orc8r.ChallengeKey_KeyType" json:"key_type,omitempty"` // Public key encoded in DER format Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- Challenge key stores the key used for challenge-response during bootstrap. --------------------------------------------------------------------------
func (*ChallengeKey) Descriptor
deprecated
func (*ChallengeKey) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeKey.ProtoReflect.Descriptor instead.
func (*ChallengeKey) GetKey ¶
func (x *ChallengeKey) GetKey() []byte
func (*ChallengeKey) GetKeyType ¶
func (x *ChallengeKey) GetKeyType() ChallengeKey_KeyType
func (*ChallengeKey) ProtoMessage ¶
func (*ChallengeKey) ProtoMessage()
func (*ChallengeKey) ProtoReflect ¶
func (x *ChallengeKey) ProtoReflect() protoreflect.Message
func (*ChallengeKey) Reset ¶
func (x *ChallengeKey) Reset()
func (*ChallengeKey) String ¶
func (x *ChallengeKey) String() string
type ChallengeKey_KeyType ¶
type ChallengeKey_KeyType int32
const ( ChallengeKey_ECHO ChallengeKey_KeyType = 0 ChallengeKey_SOFTWARE_RSA_SHA256 ChallengeKey_KeyType = 1 ChallengeKey_SOFTWARE_ECDSA_SHA256 ChallengeKey_KeyType = 2 )
func (ChallengeKey_KeyType) Descriptor ¶
func (ChallengeKey_KeyType) Descriptor() protoreflect.EnumDescriptor
func (ChallengeKey_KeyType) Enum ¶
func (x ChallengeKey_KeyType) Enum() *ChallengeKey_KeyType
func (ChallengeKey_KeyType) EnumDescriptor
deprecated
func (ChallengeKey_KeyType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChallengeKey_KeyType.Descriptor instead.
func (ChallengeKey_KeyType) Number ¶
func (x ChallengeKey_KeyType) Number() protoreflect.EnumNumber
func (ChallengeKey_KeyType) String ¶
func (x ChallengeKey_KeyType) String() string
func (ChallengeKey_KeyType) Type ¶
func (ChallengeKey_KeyType) Type() protoreflect.EnumType
type DataUpdate ¶
type DataUpdate struct { // key is the unique key for each item Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // value can be file contents, protobuf serialized message, etc. // For key deletions, the value field would be absent. Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*DataUpdate) Descriptor
deprecated
func (*DataUpdate) Descriptor() ([]byte, []int)
Deprecated: Use DataUpdate.ProtoReflect.Descriptor instead.
func (*DataUpdate) GetKey ¶
func (x *DataUpdate) GetKey() string
func (*DataUpdate) GetValue ¶
func (x *DataUpdate) GetValue() []byte
func (*DataUpdate) ProtoMessage ¶
func (*DataUpdate) ProtoMessage()
func (*DataUpdate) ProtoReflect ¶
func (x *DataUpdate) ProtoReflect() protoreflect.Message
func (*DataUpdate) Reset ¶
func (x *DataUpdate) Reset()
func (*DataUpdate) String ¶
func (x *DataUpdate) String() string
type DataUpdateBatch ¶
type DataUpdateBatch struct { // updates to config values Updates []*DataUpdate `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"` // resync is true iff the updates would be a snapshot of all the contents // in the cloud. Resync bool `protobuf:"varint,2,opt,name=resync,proto3" json:"resync,omitempty"` // contains filtered or unexported fields }
func (*DataUpdateBatch) Descriptor
deprecated
func (*DataUpdateBatch) Descriptor() ([]byte, []int)
Deprecated: Use DataUpdateBatch.ProtoReflect.Descriptor instead.
func (*DataUpdateBatch) GetResync ¶
func (x *DataUpdateBatch) GetResync() bool
func (*DataUpdateBatch) GetUpdates ¶
func (x *DataUpdateBatch) GetUpdates() []*DataUpdate
func (*DataUpdateBatch) ProtoMessage ¶
func (*DataUpdateBatch) ProtoMessage()
func (*DataUpdateBatch) ProtoReflect ¶
func (x *DataUpdateBatch) ProtoReflect() protoreflect.Message
func (*DataUpdateBatch) Reset ¶
func (x *DataUpdateBatch) Reset()
func (*DataUpdateBatch) String ¶
func (x *DataUpdateBatch) String() string
type DeleteRecordRequest ¶
type DeleteRecordRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DeleteRecordRequest) Descriptor
deprecated
func (*DeleteRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRecordRequest.ProtoReflect.Descriptor instead.
func (*DeleteRecordRequest) GetId ¶
func (x *DeleteRecordRequest) GetId() string
func (*DeleteRecordRequest) ProtoMessage ¶
func (*DeleteRecordRequest) ProtoMessage()
func (*DeleteRecordRequest) ProtoReflect ¶
func (x *DeleteRecordRequest) ProtoReflect() protoreflect.Message
func (*DeleteRecordRequest) Reset ¶
func (x *DeleteRecordRequest) Reset()
func (*DeleteRecordRequest) String ¶
func (x *DeleteRecordRequest) String() string
type DeleteStatesRequest ¶
type DeleteStatesRequest struct { NetworkID string `protobuf:"bytes,1,opt,name=networkID,proto3" json:"networkID,omitempty"` Ids []*StateID `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteStatesRequest) Descriptor
deprecated
func (*DeleteStatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteStatesRequest.ProtoReflect.Descriptor instead.
func (*DeleteStatesRequest) GetIds ¶
func (x *DeleteStatesRequest) GetIds() []*StateID
func (*DeleteStatesRequest) GetNetworkID ¶
func (x *DeleteStatesRequest) GetNetworkID() string
func (*DeleteStatesRequest) ProtoMessage ¶
func (*DeleteStatesRequest) ProtoMessage()
func (*DeleteStatesRequest) ProtoReflect ¶
func (x *DeleteStatesRequest) ProtoReflect() protoreflect.Message
func (*DeleteStatesRequest) Reset ¶
func (x *DeleteStatesRequest) Reset()
func (*DeleteStatesRequest) String ¶
func (x *DeleteStatesRequest) String() string
type DirectoryField ¶
type DirectoryField struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*DirectoryField) Descriptor
deprecated
func (*DirectoryField) Descriptor() ([]byte, []int)
Deprecated: Use DirectoryField.ProtoReflect.Descriptor instead.
func (*DirectoryField) GetKey ¶
func (x *DirectoryField) GetKey() string
func (*DirectoryField) GetValue ¶
func (x *DirectoryField) GetValue() string
func (*DirectoryField) ProtoMessage ¶
func (*DirectoryField) ProtoMessage()
func (*DirectoryField) ProtoReflect ¶
func (x *DirectoryField) ProtoReflect() protoreflect.Message
func (*DirectoryField) Reset ¶
func (x *DirectoryField) Reset()
func (*DirectoryField) String ¶
func (x *DirectoryField) String() string
type DirectoryLookupClient ¶
type DirectoryLookupClient interface { // GetHostnameForHWID returns the hostname mapped to by hardware ID. GetHostnameForHWID(ctx context.Context, in *GetHostnameForHWIDRequest, opts ...grpc.CallOption) (*GetHostnameForHWIDResponse, error) // MapHWIDsToHostnames maps {hwid -> hostname}. MapHWIDsToHostnames(ctx context.Context, in *MapHWIDToHostnameRequest, opts ...grpc.CallOption) (*Void, error) // GetIMSIForSessionID returns the IMSI mapped to by session ID. GetIMSIForSessionID(ctx context.Context, in *GetIMSIForSessionIDRequest, opts ...grpc.CallOption) (*GetIMSIForSessionIDResponse, error) // MapSessionIDsToIMSIs maps {session ID -> IMSI}. MapSessionIDsToIMSIs(ctx context.Context, in *MapSessionIDToIMSIRequest, opts ...grpc.CallOption) (*Void, error) }
DirectoryLookupClient is the client API for DirectoryLookup service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDirectoryLookupClient ¶
func NewDirectoryLookupClient(cc grpc.ClientConnInterface) DirectoryLookupClient
type DirectoryLookupServer ¶
type DirectoryLookupServer interface { // GetHostnameForHWID returns the hostname mapped to by hardware ID. GetHostnameForHWID(context.Context, *GetHostnameForHWIDRequest) (*GetHostnameForHWIDResponse, error) // MapHWIDsToHostnames maps {hwid -> hostname}. MapHWIDsToHostnames(context.Context, *MapHWIDToHostnameRequest) (*Void, error) // GetIMSIForSessionID returns the IMSI mapped to by session ID. GetIMSIForSessionID(context.Context, *GetIMSIForSessionIDRequest) (*GetIMSIForSessionIDResponse, error) // MapSessionIDsToIMSIs maps {session ID -> IMSI}. MapSessionIDsToIMSIs(context.Context, *MapSessionIDToIMSIRequest) (*Void, error) }
DirectoryLookupServer is the server API for DirectoryLookup service.
type DirectoryRecord ¶
type DirectoryRecord struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` LocationHistory []string `protobuf:"bytes,2,rep,name=location_history,json=locationHistory,proto3" json:"location_history,omitempty"` Fields map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DirectoryRecord) Descriptor
deprecated
func (*DirectoryRecord) Descriptor() ([]byte, []int)
Deprecated: Use DirectoryRecord.ProtoReflect.Descriptor instead.
func (*DirectoryRecord) GetFields ¶
func (x *DirectoryRecord) GetFields() map[string]string
func (*DirectoryRecord) GetId ¶
func (x *DirectoryRecord) GetId() string
func (*DirectoryRecord) GetLocationHistory ¶
func (x *DirectoryRecord) GetLocationHistory() []string
func (*DirectoryRecord) ProtoMessage ¶
func (*DirectoryRecord) ProtoMessage()
func (*DirectoryRecord) ProtoReflect ¶
func (x *DirectoryRecord) ProtoReflect() protoreflect.Message
func (*DirectoryRecord) Reset ¶
func (x *DirectoryRecord) Reset()
func (*DirectoryRecord) String ¶
func (x *DirectoryRecord) String() string
type EnodebdStatus ¶
type EnodebdStatus struct { // For bools, parameter is not set if result can't be determined EnodebConnected *wrappers.BoolValue `protobuf:"bytes,1,opt,name=enodeb_connected,json=enodebConnected,proto3" json:"enodeb_connected,omitempty"` OpstateEnabled *wrappers.BoolValue `protobuf:"bytes,2,opt,name=opstate_enabled,json=opstateEnabled,proto3" json:"opstate_enabled,omitempty"` RfTxOn *wrappers.BoolValue `protobuf:"bytes,3,opt,name=rf_tx_on,json=rfTxOn,proto3" json:"rf_tx_on,omitempty"` GpsConnected *wrappers.BoolValue `protobuf:"bytes,4,opt,name=gps_connected,json=gpsConnected,proto3" json:"gps_connected,omitempty"` PtpConnected *wrappers.BoolValue `protobuf:"bytes,5,opt,name=ptp_connected,json=ptpConnected,proto3" json:"ptp_connected,omitempty"` MmeConnected *wrappers.BoolValue `protobuf:"bytes,6,opt,name=mme_connected,json=mmeConnected,proto3" json:"mme_connected,omitempty"` EnodebConfigured *wrappers.BoolValue `protobuf:"bytes,7,opt,name=enodeb_configured,json=enodebConfigured,proto3" json:"enodeb_configured,omitempty"` GpsLatitude *wrappers.FloatValue `protobuf:"bytes,8,opt,name=gps_latitude,json=gpsLatitude,proto3" json:"gps_latitude,omitempty"` GpsLongitude *wrappers.FloatValue `protobuf:"bytes,9,opt,name=gps_longitude,json=gpsLongitude,proto3" json:"gps_longitude,omitempty"` RfTxDesired *wrappers.BoolValue `protobuf:"bytes,10,opt,name=rf_tx_desired,json=rfTxDesired,proto3" json:"rf_tx_desired,omitempty"` // contains filtered or unexported fields }
func (*EnodebdStatus) Descriptor
deprecated
func (*EnodebdStatus) Descriptor() ([]byte, []int)
Deprecated: Use EnodebdStatus.ProtoReflect.Descriptor instead.
func (*EnodebdStatus) GetEnodebConfigured ¶
func (x *EnodebdStatus) GetEnodebConfigured() *wrappers.BoolValue
func (*EnodebdStatus) GetEnodebConnected ¶
func (x *EnodebdStatus) GetEnodebConnected() *wrappers.BoolValue
func (*EnodebdStatus) GetGpsConnected ¶
func (x *EnodebdStatus) GetGpsConnected() *wrappers.BoolValue
func (*EnodebdStatus) GetGpsLatitude ¶
func (x *EnodebdStatus) GetGpsLatitude() *wrappers.FloatValue
func (*EnodebdStatus) GetGpsLongitude ¶
func (x *EnodebdStatus) GetGpsLongitude() *wrappers.FloatValue
func (*EnodebdStatus) GetMmeConnected ¶
func (x *EnodebdStatus) GetMmeConnected() *wrappers.BoolValue
func (*EnodebdStatus) GetOpstateEnabled ¶
func (x *EnodebdStatus) GetOpstateEnabled() *wrappers.BoolValue
func (*EnodebdStatus) GetPtpConnected ¶
func (x *EnodebdStatus) GetPtpConnected() *wrappers.BoolValue
func (*EnodebdStatus) GetRfTxDesired ¶
func (x *EnodebdStatus) GetRfTxDesired() *wrappers.BoolValue
func (*EnodebdStatus) GetRfTxOn ¶
func (x *EnodebdStatus) GetRfTxOn() *wrappers.BoolValue
func (*EnodebdStatus) ProtoMessage ¶
func (*EnodebdStatus) ProtoMessage()
func (*EnodebdStatus) ProtoReflect ¶
func (x *EnodebdStatus) ProtoReflect() protoreflect.Message
func (*EnodebdStatus) Reset ¶
func (x *EnodebdStatus) Reset()
func (*EnodebdStatus) String ¶
func (x *EnodebdStatus) String() string
type Event ¶
type Event struct { // A user-specified string to categorize events StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"` // Denotes the way an event should be deserialized. // This should correspond to an event type in swagger_eventd.v1.yml EventType string `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` // A user-specified non-unique identifier for events Tag string `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"` // The event log serialized as JSON Value string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- An Event encapsulates all information regarding an event and it's metadata. --------------------------------------------------------------------------
func (*Event) Descriptor
deprecated
func (*Event) GetEventType ¶
func (*Event) GetStreamName ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventServiceClient ¶
type EventServiceClient interface { // Logs an event to FluentBit. LogEvent(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Void, error) }
EventServiceClient is the client API for EventService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEventServiceClient ¶
func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient
type EventServiceServer ¶
type EventServiceServer interface { // Logs an event to FluentBit. LogEvent(context.Context, *Event) (*Void, error) }
EventServiceServer is the server API for EventService service.
type GatewayConfigs ¶
type GatewayConfigs struct { ConfigsByKey map[string]*any.Any `` /* 188-byte string literal not displayed */ Metadata *GatewayConfigsMetadata `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- GatewayConfigs structure is a container for all Access Gateway's (AG) Cloud Managed Configs (CMC). Each and every field of GatewayConfigs represents one AG service config -------------------------------------------------------------------------- NOTE: a service config field name (control_proxy, enodebd, etc.) must match
the corresponding gateway service's name exactly
func (*GatewayConfigs) Descriptor
deprecated
func (*GatewayConfigs) Descriptor() ([]byte, []int)
Deprecated: Use GatewayConfigs.ProtoReflect.Descriptor instead.
func (*GatewayConfigs) GetConfigsByKey ¶
func (x *GatewayConfigs) GetConfigsByKey() map[string]*any.Any
func (*GatewayConfigs) GetMconfigDigest ¶
func (cfg *GatewayConfigs) GetMconfigDigest() (string, error)
GetMconfigDigest generates a representative hash of the configs (sans metadata).
func (*GatewayConfigs) GetMetadata ¶
func (x *GatewayConfigs) GetMetadata() *GatewayConfigsMetadata
func (*GatewayConfigs) ProtoMessage ¶
func (*GatewayConfigs) ProtoMessage()
func (*GatewayConfigs) ProtoReflect ¶
func (x *GatewayConfigs) ProtoReflect() protoreflect.Message
func (*GatewayConfigs) Reset ¶
func (x *GatewayConfigs) Reset()
func (*GatewayConfigs) String ¶
func (x *GatewayConfigs) String() string
type GatewayConfigsDigest ¶
type GatewayConfigsDigest struct { // Hexadecimal MD5 hash of the UTF-8-encoded stringified full mconfigs Md5HexDigest string `protobuf:"bytes,1,opt,name=md5_hex_digest,json=md5HexDigest,proto3" json:"md5_hex_digest,omitempty"` // contains filtered or unexported fields }
Deterministic hash of a serialized GatewayConfigs proto
func (*GatewayConfigsDigest) Descriptor
deprecated
func (*GatewayConfigsDigest) Descriptor() ([]byte, []int)
Deprecated: Use GatewayConfigsDigest.ProtoReflect.Descriptor instead.
func (*GatewayConfigsDigest) GetMd5HexDigest ¶
func (x *GatewayConfigsDigest) GetMd5HexDigest() string
func (*GatewayConfigsDigest) ProtoMessage ¶
func (*GatewayConfigsDigest) ProtoMessage()
func (*GatewayConfigsDigest) ProtoReflect ¶
func (x *GatewayConfigsDigest) ProtoReflect() protoreflect.Message
func (*GatewayConfigsDigest) Reset ¶
func (x *GatewayConfigsDigest) Reset()
func (*GatewayConfigsDigest) String ¶
func (x *GatewayConfigsDigest) String() string
type GatewayConfigsMetadata ¶
type GatewayConfigsMetadata struct { // Unix timestamp of Cloud at the time of config generation. CreatedAt uint64 `protobuf:"varint,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` Digest *GatewayConfigsDigest `protobuf:"bytes,12,opt,name=digest,proto3" json:"digest,omitempty"` // contains filtered or unexported fields }
Metadata about the configs.
func (*GatewayConfigsMetadata) Descriptor
deprecated
func (*GatewayConfigsMetadata) Descriptor() ([]byte, []int)
Deprecated: Use GatewayConfigsMetadata.ProtoReflect.Descriptor instead.
func (*GatewayConfigsMetadata) GetCreatedAt ¶
func (x *GatewayConfigsMetadata) GetCreatedAt() uint64
func (*GatewayConfigsMetadata) GetDigest ¶
func (x *GatewayConfigsMetadata) GetDigest() *GatewayConfigsDigest
func (*GatewayConfigsMetadata) ProtoMessage ¶
func (*GatewayConfigsMetadata) ProtoMessage()
func (*GatewayConfigsMetadata) ProtoReflect ¶
func (x *GatewayConfigsMetadata) ProtoReflect() protoreflect.Message
func (*GatewayConfigsMetadata) Reset ¶
func (x *GatewayConfigsMetadata) Reset()
func (*GatewayConfigsMetadata) String ¶
func (x *GatewayConfigsMetadata) String() string
type GatewayDirectoryServiceClient ¶
type GatewayDirectoryServiceClient interface { // Update the directory record of an object in the directory service UpdateRecord(ctx context.Context, in *UpdateRecordRequest, opts ...grpc.CallOption) (*Void, error) // Delete directory record of an object from the directory service // Throws UNKNOWN if object ID does not exist DeleteRecord(ctx context.Context, in *DeleteRecordRequest, opts ...grpc.CallOption) (*Void, error) // Get directory field for a given id and key GetDirectoryField(ctx context.Context, in *GetDirectoryFieldRequest, opts ...grpc.CallOption) (*DirectoryField, error) // Get all directory records GetAllDirectoryRecords(ctx context.Context, in *Void, opts ...grpc.CallOption) (*AllDirectoryRecords, error) }
GatewayDirectoryServiceClient is the client API for GatewayDirectoryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGatewayDirectoryServiceClient ¶
func NewGatewayDirectoryServiceClient(cc grpc.ClientConnInterface) GatewayDirectoryServiceClient
type GatewayDirectoryServiceServer ¶
type GatewayDirectoryServiceServer interface { // Update the directory record of an object in the directory service UpdateRecord(context.Context, *UpdateRecordRequest) (*Void, error) // Delete directory record of an object from the directory service // Throws UNKNOWN if object ID does not exist DeleteRecord(context.Context, *DeleteRecordRequest) (*Void, error) // Get directory field for a given id and key GetDirectoryField(context.Context, *GetDirectoryFieldRequest) (*DirectoryField, error) // Get all directory records GetAllDirectoryRecords(context.Context, *Void) (*AllDirectoryRecords, error) }
GatewayDirectoryServiceServer is the server API for GatewayDirectoryService service.
type GatewayRequest ¶
type GatewayRequest struct { GwId string `protobuf:"bytes,1,opt,name=gwId,proto3" json:"gwId,omitempty"` // sync_rpc_service leverages the fact that grpc is built on top of http/2. // As pseudo header :method will always be POST, and :scheme will always be http, // they are excluded from the message definition. grpc uses pseudo header :authority // and :path to route the rpc calls to the corresponding services Authority string `protobuf:"bytes,2,opt,name=authority,proto3" json:"authority,omitempty"` Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` // non-pseudo headers Headers map[string]string `` /* 155-byte string literal not displayed */ Payload []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
func (*GatewayRequest) Descriptor
deprecated
func (*GatewayRequest) Descriptor() ([]byte, []int)
Deprecated: Use GatewayRequest.ProtoReflect.Descriptor instead.
func (*GatewayRequest) GetAuthority ¶
func (x *GatewayRequest) GetAuthority() string
func (*GatewayRequest) GetGwId ¶
func (x *GatewayRequest) GetGwId() string
func (*GatewayRequest) GetHeaders ¶
func (x *GatewayRequest) GetHeaders() map[string]string
func (*GatewayRequest) GetPath ¶
func (x *GatewayRequest) GetPath() string
func (*GatewayRequest) GetPayload ¶
func (x *GatewayRequest) GetPayload() []byte
func (*GatewayRequest) ProtoMessage ¶
func (*GatewayRequest) ProtoMessage()
func (*GatewayRequest) ProtoReflect ¶
func (x *GatewayRequest) ProtoReflect() protoreflect.Message
func (*GatewayRequest) Reset ¶
func (x *GatewayRequest) Reset()
func (*GatewayRequest) String ¶
func (x *GatewayRequest) String() string
type GatewayResponse ¶
type GatewayResponse struct { // pseudo header :status Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // non-pseudo headers Headers map[string]string `` /* 155-byte string literal not displayed */ // response body Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // err message to return to the caller, if any Err string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"` // keepConnActive is used to tell the client that the connection is still active, even if no response has // been received for a while KeepConnActive bool `protobuf:"varint,5,opt,name=keepConnActive,proto3" json:"keepConnActive,omitempty"` // contains filtered or unexported fields }
func (*GatewayResponse) Descriptor
deprecated
func (*GatewayResponse) Descriptor() ([]byte, []int)
Deprecated: Use GatewayResponse.ProtoReflect.Descriptor instead.
func (*GatewayResponse) GetErr ¶
func (x *GatewayResponse) GetErr() string
func (*GatewayResponse) GetHeaders ¶
func (x *GatewayResponse) GetHeaders() map[string]string
func (*GatewayResponse) GetKeepConnActive ¶
func (x *GatewayResponse) GetKeepConnActive() bool
func (*GatewayResponse) GetPayload ¶
func (x *GatewayResponse) GetPayload() []byte
func (*GatewayResponse) GetStatus ¶
func (x *GatewayResponse) GetStatus() string
func (*GatewayResponse) ProtoMessage ¶
func (*GatewayResponse) ProtoMessage()
func (*GatewayResponse) ProtoReflect ¶
func (x *GatewayResponse) ProtoReflect() protoreflect.Message
func (*GatewayResponse) Reset ¶
func (x *GatewayResponse) Reset()
func (*GatewayResponse) String ¶
func (x *GatewayResponse) String() string
type GenericCommandParams ¶
type GenericCommandParams struct { Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"` Params *_struct.Struct `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"` // contains filtered or unexported fields }
func (*GenericCommandParams) Descriptor
deprecated
func (*GenericCommandParams) Descriptor() ([]byte, []int)
Deprecated: Use GenericCommandParams.ProtoReflect.Descriptor instead.
func (*GenericCommandParams) GetCommand ¶
func (x *GenericCommandParams) GetCommand() string
func (*GenericCommandParams) GetParams ¶
func (x *GenericCommandParams) GetParams() *_struct.Struct
func (*GenericCommandParams) ProtoMessage ¶
func (*GenericCommandParams) ProtoMessage()
func (*GenericCommandParams) ProtoReflect ¶
func (x *GenericCommandParams) ProtoReflect() protoreflect.Message
func (*GenericCommandParams) Reset ¶
func (x *GenericCommandParams) Reset()
func (*GenericCommandParams) String ¶
func (x *GenericCommandParams) String() string
type GenericCommandResponse ¶
type GenericCommandResponse struct { Response *_struct.Struct `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
func (*GenericCommandResponse) Descriptor
deprecated
func (*GenericCommandResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenericCommandResponse.ProtoReflect.Descriptor instead.
func (*GenericCommandResponse) GetResponse ¶
func (x *GenericCommandResponse) GetResponse() *_struct.Struct
func (*GenericCommandResponse) ProtoMessage ¶
func (*GenericCommandResponse) ProtoMessage()
func (*GenericCommandResponse) ProtoReflect ¶
func (x *GenericCommandResponse) ProtoReflect() protoreflect.Message
func (*GenericCommandResponse) Reset ¶
func (x *GenericCommandResponse) Reset()
func (*GenericCommandResponse) String ¶
func (x *GenericCommandResponse) String() string
type GetDirectoryFieldRequest ¶
type GetDirectoryFieldRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` FieldKey string `protobuf:"bytes,2,opt,name=field_key,json=fieldKey,proto3" json:"field_key,omitempty"` // contains filtered or unexported fields }
func (*GetDirectoryFieldRequest) Descriptor
deprecated
func (*GetDirectoryFieldRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDirectoryFieldRequest.ProtoReflect.Descriptor instead.
func (*GetDirectoryFieldRequest) GetFieldKey ¶
func (x *GetDirectoryFieldRequest) GetFieldKey() string
func (*GetDirectoryFieldRequest) GetId ¶
func (x *GetDirectoryFieldRequest) GetId() string
func (*GetDirectoryFieldRequest) ProtoMessage ¶
func (*GetDirectoryFieldRequest) ProtoMessage()
func (*GetDirectoryFieldRequest) ProtoReflect ¶
func (x *GetDirectoryFieldRequest) ProtoReflect() protoreflect.Message
func (*GetDirectoryFieldRequest) Reset ¶
func (x *GetDirectoryFieldRequest) Reset()
func (*GetDirectoryFieldRequest) String ¶
func (x *GetDirectoryFieldRequest) String() string
type GetGatewayIdResponse ¶
type GetGatewayIdResponse struct { GatewayId string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"` // contains filtered or unexported fields }
func (*GetGatewayIdResponse) Descriptor
deprecated
func (*GetGatewayIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetGatewayIdResponse.ProtoReflect.Descriptor instead.
func (*GetGatewayIdResponse) GetGatewayId ¶
func (x *GetGatewayIdResponse) GetGatewayId() string
func (*GetGatewayIdResponse) ProtoMessage ¶
func (*GetGatewayIdResponse) ProtoMessage()
func (*GetGatewayIdResponse) ProtoReflect ¶
func (x *GetGatewayIdResponse) ProtoReflect() protoreflect.Message
func (*GetGatewayIdResponse) Reset ¶
func (x *GetGatewayIdResponse) Reset()
func (*GetGatewayIdResponse) String ¶
func (x *GetGatewayIdResponse) String() string
type GetHostnameForHWIDRequest ¶
type GetHostnameForHWIDRequest struct { Hwid string `protobuf:"bytes,1,opt,name=hwid,proto3" json:"hwid,omitempty"` // contains filtered or unexported fields }
func (*GetHostnameForHWIDRequest) Descriptor
deprecated
func (*GetHostnameForHWIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHostnameForHWIDRequest.ProtoReflect.Descriptor instead.
func (*GetHostnameForHWIDRequest) GetHwid ¶
func (x *GetHostnameForHWIDRequest) GetHwid() string
func (*GetHostnameForHWIDRequest) ProtoMessage ¶
func (*GetHostnameForHWIDRequest) ProtoMessage()
func (*GetHostnameForHWIDRequest) ProtoReflect ¶
func (x *GetHostnameForHWIDRequest) ProtoReflect() protoreflect.Message
func (*GetHostnameForHWIDRequest) Reset ¶
func (x *GetHostnameForHWIDRequest) Reset()
func (*GetHostnameForHWIDRequest) String ¶
func (x *GetHostnameForHWIDRequest) String() string
func (*GetHostnameForHWIDRequest) Validate ¶
func (m *GetHostnameForHWIDRequest) Validate() error
type GetHostnameForHWIDResponse ¶
type GetHostnameForHWIDResponse struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // contains filtered or unexported fields }
func (*GetHostnameForHWIDResponse) Descriptor
deprecated
func (*GetHostnameForHWIDResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetHostnameForHWIDResponse.ProtoReflect.Descriptor instead.
func (*GetHostnameForHWIDResponse) GetHostname ¶
func (x *GetHostnameForHWIDResponse) GetHostname() string
func (*GetHostnameForHWIDResponse) ProtoMessage ¶
func (*GetHostnameForHWIDResponse) ProtoMessage()
func (*GetHostnameForHWIDResponse) ProtoReflect ¶
func (x *GetHostnameForHWIDResponse) ProtoReflect() protoreflect.Message
func (*GetHostnameForHWIDResponse) Reset ¶
func (x *GetHostnameForHWIDResponse) Reset()
func (*GetHostnameForHWIDResponse) String ¶
func (x *GetHostnameForHWIDResponse) String() string
type GetIMSIForSessionIDRequest ¶
type GetIMSIForSessionIDRequest struct { NetworkID string `protobuf:"bytes,1,opt,name=networkID,proto3" json:"networkID,omitempty"` SessionID string `protobuf:"bytes,2,opt,name=sessionID,proto3" json:"sessionID,omitempty"` // contains filtered or unexported fields }
func (*GetIMSIForSessionIDRequest) Descriptor
deprecated
func (*GetIMSIForSessionIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetIMSIForSessionIDRequest.ProtoReflect.Descriptor instead.
func (*GetIMSIForSessionIDRequest) GetNetworkID ¶
func (x *GetIMSIForSessionIDRequest) GetNetworkID() string
func (*GetIMSIForSessionIDRequest) GetSessionID ¶
func (x *GetIMSIForSessionIDRequest) GetSessionID() string
func (*GetIMSIForSessionIDRequest) ProtoMessage ¶
func (*GetIMSIForSessionIDRequest) ProtoMessage()
func (*GetIMSIForSessionIDRequest) ProtoReflect ¶
func (x *GetIMSIForSessionIDRequest) ProtoReflect() protoreflect.Message
func (*GetIMSIForSessionIDRequest) Reset ¶
func (x *GetIMSIForSessionIDRequest) Reset()
func (*GetIMSIForSessionIDRequest) String ¶
func (x *GetIMSIForSessionIDRequest) String() string
func (*GetIMSIForSessionIDRequest) Validate ¶
func (m *GetIMSIForSessionIDRequest) Validate() error
type GetIMSIForSessionIDResponse ¶
type GetIMSIForSessionIDResponse struct { Imsi string `protobuf:"bytes,1,opt,name=imsi,proto3" json:"imsi,omitempty"` // contains filtered or unexported fields }
func (*GetIMSIForSessionIDResponse) Descriptor
deprecated
func (*GetIMSIForSessionIDResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetIMSIForSessionIDResponse.ProtoReflect.Descriptor instead.
func (*GetIMSIForSessionIDResponse) GetImsi ¶
func (x *GetIMSIForSessionIDResponse) GetImsi() string
func (*GetIMSIForSessionIDResponse) ProtoMessage ¶
func (*GetIMSIForSessionIDResponse) ProtoMessage()
func (*GetIMSIForSessionIDResponse) ProtoReflect ¶
func (x *GetIMSIForSessionIDResponse) ProtoReflect() protoreflect.Message
func (*GetIMSIForSessionIDResponse) Reset ¶
func (x *GetIMSIForSessionIDResponse) Reset()
func (*GetIMSIForSessionIDResponse) String ¶
func (x *GetIMSIForSessionIDResponse) String() string
type GetOperationalStatesResponse ¶
type GetOperationalStatesResponse struct { States []*State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"` // contains filtered or unexported fields }
func (*GetOperationalStatesResponse) Descriptor
deprecated
func (*GetOperationalStatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetOperationalStatesResponse.ProtoReflect.Descriptor instead.
func (*GetOperationalStatesResponse) GetStates ¶
func (x *GetOperationalStatesResponse) GetStates() []*State
func (*GetOperationalStatesResponse) ProtoMessage ¶
func (*GetOperationalStatesResponse) ProtoMessage()
func (*GetOperationalStatesResponse) ProtoReflect ¶
func (x *GetOperationalStatesResponse) ProtoReflect() protoreflect.Message
func (*GetOperationalStatesResponse) Reset ¶
func (x *GetOperationalStatesResponse) Reset()
func (*GetOperationalStatesResponse) String ¶
func (x *GetOperationalStatesResponse) String() string
type GetStatesRequest ¶
type GetStatesRequest struct { // networkID of the network containing desired state. NetworkID string `protobuf:"bytes,1,opt,name=networkID,proto3" json:"networkID,omitempty"` // ids for which to return corresponding state. Ids []*StateID `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"` // typeFilter is an OR of all types specified. // The service will return all states matching any of the specified types. TypeFilter []string `protobuf:"bytes,10,rep,name=typeFilter,proto3" json:"typeFilter,omitempty"` // idFilter is an OR of all device IDs specified. // The service will return all states matching any of the specified IDs. IdFilter []string `protobuf:"bytes,11,rep,name=idFilter,proto3" json:"idFilter,omitempty"` // loadValues specifies whether state values should be loaded in // addition to metadata. LoadValues bool `protobuf:"varint,12,opt,name=loadValues,proto3" json:"loadValues,omitempty"` // If non-empty, the value of id_prefix will be used to do a prefix-match // on the keys of queried states. This argument supersedes any value for // idFilter. IdPrefix string `protobuf:"bytes,13,opt,name=id_prefix,json=idPrefix,proto3" json:"id_prefix,omitempty"` // contains filtered or unexported fields }
GetStatesRequest functions in two modes
- ids is non-empty -- normal Get
- ids empty -- Search with filters and load criteria
func (*GetStatesRequest) Descriptor
deprecated
func (*GetStatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatesRequest.ProtoReflect.Descriptor instead.
func (*GetStatesRequest) GetIdFilter ¶
func (x *GetStatesRequest) GetIdFilter() []string
func (*GetStatesRequest) GetIdPrefix ¶
func (x *GetStatesRequest) GetIdPrefix() string
func (*GetStatesRequest) GetIds ¶
func (x *GetStatesRequest) GetIds() []*StateID
func (*GetStatesRequest) GetLoadValues ¶
func (x *GetStatesRequest) GetLoadValues() bool
func (*GetStatesRequest) GetNetworkID ¶
func (x *GetStatesRequest) GetNetworkID() string
func (*GetStatesRequest) GetTypeFilter ¶
func (x *GetStatesRequest) GetTypeFilter() []string
func (*GetStatesRequest) ProtoMessage ¶
func (*GetStatesRequest) ProtoMessage()
func (*GetStatesRequest) ProtoReflect ¶
func (x *GetStatesRequest) ProtoReflect() protoreflect.Message
func (*GetStatesRequest) Reset ¶
func (x *GetStatesRequest) Reset()
func (*GetStatesRequest) String ¶
func (x *GetStatesRequest) String() string
type GetStatesResponse ¶
type GetStatesResponse struct { States []*State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"` // contains filtered or unexported fields }
func (*GetStatesResponse) Descriptor
deprecated
func (*GetStatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatesResponse.ProtoReflect.Descriptor instead.
func (*GetStatesResponse) GetStates ¶
func (x *GetStatesResponse) GetStates() []*State
func (*GetStatesResponse) ProtoMessage ¶
func (*GetStatesResponse) ProtoMessage()
func (*GetStatesResponse) ProtoReflect ¶
func (x *GetStatesResponse) ProtoReflect() protoreflect.Message
func (*GetStatesResponse) Reset ¶
func (x *GetStatesResponse) Reset()
func (*GetStatesResponse) String ¶
func (x *GetStatesResponse) String() string
type GetTenantRequest ¶
type GetTenantRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetTenantRequest) Descriptor
deprecated
func (*GetTenantRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTenantRequest.ProtoReflect.Descriptor instead.
func (*GetTenantRequest) GetId ¶
func (x *GetTenantRequest) GetId() int64
func (*GetTenantRequest) ProtoMessage ¶
func (*GetTenantRequest) ProtoMessage()
func (*GetTenantRequest) ProtoReflect ¶
func (x *GetTenantRequest) ProtoReflect() protoreflect.Message
func (*GetTenantRequest) Reset ¶
func (x *GetTenantRequest) Reset()
func (*GetTenantRequest) String ¶
func (x *GetTenantRequest) String() string
type IDAndError ¶
type IDAndError struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` DeviceID string `protobuf:"bytes,2,opt,name=deviceID,proto3" json:"deviceID,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*IDAndError) Descriptor
deprecated
func (*IDAndError) Descriptor() ([]byte, []int)
Deprecated: Use IDAndError.ProtoReflect.Descriptor instead.
func (*IDAndError) GetDeviceID ¶
func (x *IDAndError) GetDeviceID() string
func (*IDAndError) GetError ¶
func (x *IDAndError) GetError() string
func (*IDAndError) GetType ¶
func (x *IDAndError) GetType() string
func (*IDAndError) ProtoMessage ¶
func (*IDAndError) ProtoMessage()
func (*IDAndError) ProtoReflect ¶
func (x *IDAndError) ProtoReflect() protoreflect.Message
func (*IDAndError) Reset ¶
func (x *IDAndError) Reset()
func (*IDAndError) String ¶
func (x *IDAndError) String() string
type IDAndTenant ¶
type IDAndTenant struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Tenant *Tenant `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"` // contains filtered or unexported fields }
func (*IDAndTenant) Descriptor
deprecated
func (*IDAndTenant) Descriptor() ([]byte, []int)
Deprecated: Use IDAndTenant.ProtoReflect.Descriptor instead.
func (*IDAndTenant) GetId ¶
func (x *IDAndTenant) GetId() int64
func (*IDAndTenant) GetTenant ¶
func (x *IDAndTenant) GetTenant() *Tenant
func (*IDAndTenant) ProtoMessage ¶
func (*IDAndTenant) ProtoMessage()
func (*IDAndTenant) ProtoReflect ¶
func (x *IDAndTenant) ProtoReflect() protoreflect.Message
func (*IDAndTenant) Reset ¶
func (x *IDAndTenant) Reset()
func (*IDAndTenant) String ¶
func (x *IDAndTenant) String() string
type IDAndVersion ¶
type IDAndVersion struct { Id *StateID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*IDAndVersion) Descriptor
deprecated
func (*IDAndVersion) Descriptor() ([]byte, []int)
Deprecated: Use IDAndVersion.ProtoReflect.Descriptor instead.
func (*IDAndVersion) GetId ¶
func (x *IDAndVersion) GetId() *StateID
func (*IDAndVersion) GetVersion ¶
func (x *IDAndVersion) GetVersion() uint64
func (*IDAndVersion) ProtoMessage ¶
func (*IDAndVersion) ProtoMessage()
func (*IDAndVersion) ProtoReflect ¶
func (x *IDAndVersion) ProtoReflect() protoreflect.Message
func (*IDAndVersion) Reset ¶
func (x *IDAndVersion) Reset()
func (*IDAndVersion) String ¶
func (x *IDAndVersion) String() string
type IDList ¶
type IDList struct { Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- IDList is a generic definition of an array of IDs (network, gateway, etc.) --------------------------------------------------------------------------
func (*IDList) Descriptor
deprecated
func (*IDList) ProtoMessage ¶
func (*IDList) ProtoMessage()
func (*IDList) ProtoReflect ¶
func (x *IDList) ProtoReflect() protoreflect.Message
type Identity ¶
type Identity struct { // NOTE: Every Value type below should have corresponding entry in // identityTypeNameTable in magma/protos/identity_helper.go // // Types that are assignable to Value: // *Identity_Gateway_ // *Identity_Operator // *Identity_Network // *Identity_Wildcard_ Value isIdentity_Value `protobuf_oneof:"Value"` // contains filtered or unexported fields }
func GetClientIdentity ¶
GetClientIdentity returns Identity of the RPC caller retrieved from GRPC/HTTP Context (if present) where it's set by the middleware or Obsidian
NOTE: nil Identity is equivalent to missing Identity for all intents and purposes
func NewGatewayIdentity ¶
NewGatewayIdentity returns Gateway identity corresponding to given hardware network & logical gateway IDs
func NewGatewayWildcardIdentity ¶
func NewGatewayWildcardIdentity() *Identity
NewGatewayWildcardIdentity returns Gateway wildcard Identity
func NewNetworkIdentity ¶
NewNetworkIdentity returns Network identity corresponding to given networkId
func NewNetworkWildcardIdentity ¶
func NewNetworkWildcardIdentity() *Identity
NewNetworkWildcardIdentity returns Network Wildcard Identity
func NewOperatorIdentity ¶
NewOperatorIdentity returns Operator identity corresponding to given opId
func NewOperatorWildcardIdentity ¶
func NewOperatorWildcardIdentity() *Identity
NewOperatorWildcardIdentity returns Operator wildcard Identity
func (*Identity) Descriptor
deprecated
func (*Identity) GetGateway ¶
func (x *Identity) GetGateway() *Identity_Gateway
func (*Identity) GetNetwork ¶
func (*Identity) GetOperator ¶
func (*Identity) GetWildcard ¶
func (x *Identity) GetWildcard() *Identity_Wildcard
func (*Identity) GetWildcardForIdentity ¶
func (*Identity) HashString ¶
HashString returns a unique string suitable to be used as a map/hash key uniquely identifying an Identity For instance, a network Identity's hash string would look like: "Id_Network_MyNetworkId" where 'MyNetworkId' is a registered network ID
func (*Identity) Match ¶
A helper to verify if a given entity matches the wildcard pattern For now only match all (*) is supported
func (*Identity) NewContextWithIdentity ¶
NewContextWithIdentity returns a new Context that carries the given Identity Since nil Identity is equivalent to no Identity, no new CTX will be created if the passed id is nil and the passed ctx will be returned unmodified
func (*Identity) ProtoMessage ¶
func (*Identity) ProtoMessage()
func (*Identity) ProtoReflect ¶
func (x *Identity) ProtoReflect() protoreflect.Message
func (*Identity) SetGateway ¶
func (id *Identity) SetGateway(gwId *Identity_Gateway) *Identity
SetGateway sets Identity to be given gateway identity (gwid) and returns the receiver (Identity pointer)
func (*Identity) SetNetwork ¶
SetNetwork sets Identity to be given network identity (networkId) and returns the receiver (Identity pointer)
func (*Identity) SetOperator ¶
SetOperator sets Identity to be given operator identity (opid) and returns the receiver (Identity pointer)
func (*Identity) ToCommonName ¶
ToCommonName receiver assumes that each Identity implementation would provide its own ToCommonName and return a string to be used in cert Subject Common Name ToCommonName returns string pointer, nil will be returned if underlying Identity provider is missing (nil)
type Identity_Gateway ¶
type Identity_Gateway struct { HardwareId string `protobuf:"bytes,1,opt,name=hardware_id,json=hardwareId,proto3" json:"hardware_id,omitempty"` // unique hardware ID of a gateway encoded in CN of GW certificate NetworkId string `protobuf:"bytes,2,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` LogicalId string `protobuf:"bytes,3,opt,name=logical_id,json=logicalId,proto3" json:"logical_id,omitempty"` // contains filtered or unexported fields }
func GetClientGateway ¶
func GetClientGateway(ctx context.Context) *Identity_Gateway
GetClientGateway returns Identity of the Gateway caller retrieved from GRPC/HTTP Context (if present) where it's set by the middleware For use by all Gateway facing cloud services.
Example: func (srv *MeteringdRecordsServer) UpdateFlows( ctx context.Context, tbl *protos.FlowTable) (*protos.Void, error) { gw := protos.GetClientGateway(ctx) if gw == nil || !gw.Registered() { return &protos.Void{}, status.Errorf( codes.PermissionDenied, "Gateway not registered") } ...
func GetGatewayIdentity ¶
func GetGatewayIdentity(ctx context.Context) (*Identity_Gateway, error)
GetGatewayIdentity returns the identity of the Gateway caller. Returns an error if the gateway is not registered.
func (*Identity_Gateway) Descriptor
deprecated
func (*Identity_Gateway) Descriptor() ([]byte, []int)
Deprecated: Use Identity_Gateway.ProtoReflect.Descriptor instead.
func (*Identity_Gateway) GetHardwareId ¶
func (x *Identity_Gateway) GetHardwareId() string
func (*Identity_Gateway) GetLogicalId ¶
func (x *Identity_Gateway) GetLogicalId() string
func (*Identity_Gateway) GetNetworkId ¶
func (x *Identity_Gateway) GetNetworkId() string
func (*Identity_Gateway) ProtoMessage ¶
func (*Identity_Gateway) ProtoMessage()
func (*Identity_Gateway) ProtoReflect ¶
func (x *Identity_Gateway) ProtoReflect() protoreflect.Message
func (*Identity_Gateway) Registered ¶
func (gw *Identity_Gateway) Registered() bool
Registered check for Gateway Identity
func (*Identity_Gateway) Reset ¶
func (x *Identity_Gateway) Reset()
func (*Identity_Gateway) String ¶
func (x *Identity_Gateway) String() string
type Identity_Gateway_ ¶
type Identity_Gateway_ struct {
Gateway *Identity_Gateway `protobuf:"bytes,1,opt,name=gateway,proto3,oneof"`
}
func (*Identity_Gateway_) ToCommonName ¶
func (gw *Identity_Gateway_) ToCommonName() *string
ToCommonName receiver for Gateway Identity
type Identity_List ¶
type Identity_List struct { List []*Identity `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` // contains filtered or unexported fields }
Identities list wrapper
func (*Identity_List) Descriptor
deprecated
func (*Identity_List) Descriptor() ([]byte, []int)
Deprecated: Use Identity_List.ProtoReflect.Descriptor instead.
func (*Identity_List) GetList ¶
func (x *Identity_List) GetList() []*Identity
func (*Identity_List) ProtoMessage ¶
func (*Identity_List) ProtoMessage()
func (*Identity_List) ProtoReflect ¶
func (x *Identity_List) ProtoReflect() protoreflect.Message
func (*Identity_List) Reset ¶
func (x *Identity_List) Reset()
func (*Identity_List) String ¶
func (x *Identity_List) String() string
type Identity_Network ¶
type Identity_Network struct {
Network string `protobuf:"bytes,3,opt,name=network,proto3,oneof"` // unique network ID, used by REST access control
}
func (*Identity_Network) ToCommonName ¶
func (nid *Identity_Network) ToCommonName() *string
ToCommonName receiver for Network Identity
type Identity_Operator ¶
type Identity_Operator struct {
Operator string `protobuf:"bytes,2,opt,name=operator,proto3,oneof"` // unique operator ID (user name), encoded in CN of operator certificate
}
func (*Identity_Operator) ToCommonName ¶
func (oper *Identity_Operator) ToCommonName() *string
ToCommonName receiver for Operator Identity
type Identity_Wildcard ¶
type Identity_Wildcard struct { Type Identity_Wildcard_Type `protobuf:"varint,1,opt,name=type,proto3,enum=magma.orc8r.Identity_Wildcard_Type" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Identity_Wildcard) Descriptor
deprecated
func (*Identity_Wildcard) Descriptor() ([]byte, []int)
Deprecated: Use Identity_Wildcard.ProtoReflect.Descriptor instead.
func (*Identity_Wildcard) GetType ¶
func (x *Identity_Wildcard) GetType() Identity_Wildcard_Type
func (*Identity_Wildcard) ProtoMessage ¶
func (*Identity_Wildcard) ProtoMessage()
func (*Identity_Wildcard) ProtoReflect ¶
func (x *Identity_Wildcard) ProtoReflect() protoreflect.Message
func (*Identity_Wildcard) Reset ¶
func (x *Identity_Wildcard) Reset()
func (*Identity_Wildcard) String ¶
func (x *Identity_Wildcard) String() string
type Identity_Wildcard_ ¶
type Identity_Wildcard_ struct {
Wildcard *Identity_Wildcard `protobuf:"bytes,11,opt,name=wildcard,proto3,oneof"`
}
func (*Identity_Wildcard_) ToCommonName ¶
func (wc *Identity_Wildcard_) ToCommonName() *string
ToCommonName receiver for Wildcard Identity
type Identity_Wildcard_Type ¶
type Identity_Wildcard_Type int32
const ( Identity_Wildcard_Gateway Identity_Wildcard_Type = 0 Identity_Wildcard_Operator Identity_Wildcard_Type = 1 Identity_Wildcard_Network Identity_Wildcard_Type = 2 )
func (Identity_Wildcard_Type) Descriptor ¶
func (Identity_Wildcard_Type) Descriptor() protoreflect.EnumDescriptor
func (Identity_Wildcard_Type) Enum ¶
func (x Identity_Wildcard_Type) Enum() *Identity_Wildcard_Type
func (Identity_Wildcard_Type) EnumDescriptor
deprecated
func (Identity_Wildcard_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Identity_Wildcard_Type.Descriptor instead.
func (Identity_Wildcard_Type) Number ¶
func (x Identity_Wildcard_Type) Number() protoreflect.EnumNumber
func (Identity_Wildcard_Type) String ¶
func (x Identity_Wildcard_Type) String() string
func (Identity_Wildcard_Type) Type ¶
func (Identity_Wildcard_Type) Type() protoreflect.EnumType
type LabelPair ¶
type LabelPair struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*LabelPair) Descriptor
deprecated
func (*LabelPair) ProtoMessage ¶
func (*LabelPair) ProtoMessage()
func (*LabelPair) ProtoReflect ¶
func (x *LabelPair) ProtoReflect() protoreflect.Message
type LogLevel ¶
type LogLevel int32
-------------------------------------------------------------------------- Logging levels --------------------------------------------------------------------------
func (LogLevel) Descriptor ¶
func (LogLevel) Descriptor() protoreflect.EnumDescriptor
func (LogLevel) EnumDescriptor
deprecated
func (LogLevel) Number ¶
func (x LogLevel) Number() protoreflect.EnumNumber
func (LogLevel) Type ¶
func (LogLevel) Type() protoreflect.EnumType
type LogLevelMessage ¶
type LogLevelMessage struct { Level LogLevel `protobuf:"varint,1,opt,name=level,proto3,enum=magma.orc8r.LogLevel" json:"level,omitempty"` // contains filtered or unexported fields }
func (*LogLevelMessage) Descriptor
deprecated
func (*LogLevelMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogLevelMessage.ProtoReflect.Descriptor instead.
func (*LogLevelMessage) GetLevel ¶
func (x *LogLevelMessage) GetLevel() LogLevel
func (*LogLevelMessage) ProtoMessage ¶
func (*LogLevelMessage) ProtoMessage()
func (*LogLevelMessage) ProtoReflect ¶
func (x *LogLevelMessage) ProtoReflect() protoreflect.Message
func (*LogLevelMessage) Reset ¶
func (x *LogLevelMessage) Reset()
func (*LogLevelMessage) String ¶
func (x *LogLevelMessage) String() string
type LogLine ¶
type LogLine struct { Line string `protobuf:"bytes,1,opt,name=line,proto3" json:"line,omitempty"` // contains filtered or unexported fields }
func (*LogLine) Descriptor
deprecated
func (*LogLine) ProtoMessage ¶
func (*LogLine) ProtoMessage()
func (*LogLine) ProtoReflect ¶
func (x *LogLine) ProtoReflect() protoreflect.Message
type LogVerbosity ¶
type LogVerbosity struct { Verbosity int32 `protobuf:"varint,1,opt,name=verbosity,proto3" json:"verbosity,omitempty"` // contains filtered or unexported fields }
func (*LogVerbosity) Descriptor
deprecated
func (*LogVerbosity) Descriptor() ([]byte, []int)
Deprecated: Use LogVerbosity.ProtoReflect.Descriptor instead.
func (*LogVerbosity) GetVerbosity ¶
func (x *LogVerbosity) GetVerbosity() int32
func (*LogVerbosity) ProtoMessage ¶
func (*LogVerbosity) ProtoMessage()
func (*LogVerbosity) ProtoReflect ¶
func (x *LogVerbosity) ProtoReflect() protoreflect.Message
func (*LogVerbosity) Reset ¶
func (x *LogVerbosity) Reset()
func (*LogVerbosity) String ¶
func (x *LogVerbosity) String() string
type MagmadClient ¶
type MagmadClient interface { // Starts all magma services StartServices(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) // Stops all magma services StopServices(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) // Reboot the gateway device Reboot(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) // Restart specified magma services RestartServices(ctx context.Context, in *RestartServicesRequest, opts ...grpc.CallOption) (*Void, error) // Updates AG configs and restarts affected AG services SetConfigs(ctx context.Context, in *GatewayConfigs, opts ...grpc.CallOption) (*Void, error) // Get current AG configs GetConfigs(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GatewayConfigs, error) // Execute some network commands to check gateway network health RunNetworkTests(ctx context.Context, in *NetworkTestRequest, opts ...grpc.CallOption) (*NetworkTestResponse, error) // Get gateway hardware ID GetGatewayId(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GetGatewayIdResponse, error) // Execute generic command GenericCommand(ctx context.Context, in *GenericCommandParams, opts ...grpc.CallOption) (*GenericCommandResponse, error) // Get stream of logs TailLogs(ctx context.Context, in *TailLogsRequest, opts ...grpc.CallOption) (Magmad_TailLogsClient, error) }
MagmadClient is the client API for Magmad service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMagmadClient ¶
func NewMagmadClient(cc grpc.ClientConnInterface) MagmadClient
type MagmadServer ¶
type MagmadServer interface { // Starts all magma services StartServices(context.Context, *Void) (*Void, error) // Stops all magma services StopServices(context.Context, *Void) (*Void, error) // Reboot the gateway device Reboot(context.Context, *Void) (*Void, error) // Restart specified magma services RestartServices(context.Context, *RestartServicesRequest) (*Void, error) // Updates AG configs and restarts affected AG services SetConfigs(context.Context, *GatewayConfigs) (*Void, error) // Get current AG configs GetConfigs(context.Context, *Void) (*GatewayConfigs, error) // Execute some network commands to check gateway network health RunNetworkTests(context.Context, *NetworkTestRequest) (*NetworkTestResponse, error) // Get gateway hardware ID GetGatewayId(context.Context, *Void) (*GetGatewayIdResponse, error) // Execute generic command GenericCommand(context.Context, *GenericCommandParams) (*GenericCommandResponse, error) // Get stream of logs TailLogs(*TailLogsRequest, Magmad_TailLogsServer) error }
MagmadServer is the server API for Magmad service.
type Magmad_TailLogsClient ¶
type Magmad_TailLogsClient interface { Recv() (*LogLine, error) grpc.ClientStream }
type Magmad_TailLogsServer ¶
type Magmad_TailLogsServer interface { Send(*LogLine) error grpc.ServerStream }
type MapHWIDToHostnameRequest ¶
type MapHWIDToHostnameRequest struct { HwidToHostname map[string]string `` /* 169-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MapHWIDToHostnameRequest) Descriptor
deprecated
func (*MapHWIDToHostnameRequest) Descriptor() ([]byte, []int)
Deprecated: Use MapHWIDToHostnameRequest.ProtoReflect.Descriptor instead.
func (*MapHWIDToHostnameRequest) GetHwidToHostname ¶
func (x *MapHWIDToHostnameRequest) GetHwidToHostname() map[string]string
func (*MapHWIDToHostnameRequest) ProtoMessage ¶
func (*MapHWIDToHostnameRequest) ProtoMessage()
func (*MapHWIDToHostnameRequest) ProtoReflect ¶
func (x *MapHWIDToHostnameRequest) ProtoReflect() protoreflect.Message
func (*MapHWIDToHostnameRequest) Reset ¶
func (x *MapHWIDToHostnameRequest) Reset()
func (*MapHWIDToHostnameRequest) String ¶
func (x *MapHWIDToHostnameRequest) String() string
func (*MapHWIDToHostnameRequest) Validate ¶
func (m *MapHWIDToHostnameRequest) Validate() error
type MapSessionIDToIMSIRequest ¶
type MapSessionIDToIMSIRequest struct { NetworkID string `protobuf:"bytes,1,opt,name=networkID,proto3" json:"networkID,omitempty"` SessionIDToIMSI map[string]string `` /* 171-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MapSessionIDToIMSIRequest) Descriptor
deprecated
func (*MapSessionIDToIMSIRequest) Descriptor() ([]byte, []int)
Deprecated: Use MapSessionIDToIMSIRequest.ProtoReflect.Descriptor instead.
func (*MapSessionIDToIMSIRequest) GetNetworkID ¶
func (x *MapSessionIDToIMSIRequest) GetNetworkID() string
func (*MapSessionIDToIMSIRequest) GetSessionIDToIMSI ¶
func (x *MapSessionIDToIMSIRequest) GetSessionIDToIMSI() map[string]string
func (*MapSessionIDToIMSIRequest) ProtoMessage ¶
func (*MapSessionIDToIMSIRequest) ProtoMessage()
func (*MapSessionIDToIMSIRequest) ProtoReflect ¶
func (x *MapSessionIDToIMSIRequest) ProtoReflect() protoreflect.Message
func (*MapSessionIDToIMSIRequest) Reset ¶
func (x *MapSessionIDToIMSIRequest) Reset()
func (*MapSessionIDToIMSIRequest) String ¶
func (x *MapSessionIDToIMSIRequest) String() string
func (*MapSessionIDToIMSIRequest) Validate ¶
func (m *MapSessionIDToIMSIRequest) Validate() error
type MconfigStreamRequest ¶
type MconfigStreamRequest struct { Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
Stream request passed as extra args to the streaming mconfig streamer policy. Contains a single field, the offset of the mconfig currently stored on the device.
func (*MconfigStreamRequest) Descriptor
deprecated
func (*MconfigStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use MconfigStreamRequest.ProtoReflect.Descriptor instead.
func (*MconfigStreamRequest) GetOffset ¶
func (x *MconfigStreamRequest) GetOffset() int64
func (*MconfigStreamRequest) ProtoMessage ¶
func (*MconfigStreamRequest) ProtoMessage()
func (*MconfigStreamRequest) ProtoReflect ¶
func (x *MconfigStreamRequest) ProtoReflect() protoreflect.Message
func (*MconfigStreamRequest) Reset ¶
func (x *MconfigStreamRequest) Reset()
func (*MconfigStreamRequest) String ¶
func (x *MconfigStreamRequest) String() string
type MetricLabelName ¶
type MetricLabelName int32
Possible labels, used as metric_name{label_name=label_value}
const ( MetricLabelName_result MetricLabelName = 0 MetricLabelName_cause MetricLabelName = 1 MetricLabelName_tau_type MetricLabelName = 2 MetricLabelName_pdn_type MetricLabelName = 3 MetricLabelName_action MetricLabelName = 4 MetricLabelName_host MetricLabelName = 5 // magmad_ping_rtt_ms MetricLabelName_metric MetricLabelName = 6 // magmad_ping_rtt_ms MetricLabelName_patchlevel MetricLabelName = 7 // python_info MetricLabelName_minor MetricLabelName = 8 // python_info MetricLabelName_major MetricLabelName = 9 // python_info MetricLabelName_version MetricLabelName = 10 // python_info MetricLabelName_implementation MetricLabelName = 11 // python_info MetricLabelName_sensor MetricLabelName = 12 // magmad_temperature MetricLabelName_error_code MetricLabelName = 13 MetricLabelName_error_type MetricLabelName = 14 MetricLabelName_iface_name MetricLabelName = 15 // pipelined network_iface_status MetricLabelName_service_name MetricLabelName = 16 // magmad unexpected_service_restarts MetricLabelName_rule_id MetricLabelName = 17 // pipelined rule install failures MetricLabelName_imsi MetricLabelName = 18 // pipelined rule install failures )
func (MetricLabelName) Descriptor ¶
func (MetricLabelName) Descriptor() protoreflect.EnumDescriptor
func (MetricLabelName) Enum ¶
func (x MetricLabelName) Enum() *MetricLabelName
func (MetricLabelName) EnumDescriptor
deprecated
func (MetricLabelName) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetricLabelName.Descriptor instead.
func (MetricLabelName) Number ¶
func (x MetricLabelName) Number() protoreflect.EnumNumber
func (MetricLabelName) String ¶
func (x MetricLabelName) String() string
func (MetricLabelName) Type ¶
func (MetricLabelName) Type() protoreflect.EnumType
type MetricName ¶
type MetricName int32
For each metric name tracked, we use an enum
const ( // Prometheus metrics MetricName_process_start_time_seconds MetricName = 0 MetricName_process_virtual_memory_bytes MetricName = 1 MetricName_process_resident_memory_bytes MetricName = 2 MetricName_process_cpu_seconds_total MetricName = 3 MetricName_process_open_fds MetricName = 4 MetricName_process_max_fds MetricName = 5 // subscriberdb metrics MetricName_s6a_auth_success MetricName = 6 MetricName_s6a_auth_failure MetricName = 7 MetricName_s6a_location_update MetricName = 8 MetricName_diameter_capabilities_exchange MetricName = 9 MetricName_diameter_watchdog MetricName = 10 MetricName_diameter_disconnect MetricName = 11 // More prometheus metrics MetricName_python_info MetricName = 50 // Metricsd metrics MetricName_service_metrics_collected MetricName = 60 MetricName_process_uptime_seconds MetricName = 61 // mobilityd metrics MetricName_ip_address_allocated MetricName = 100 MetricName_ip_address_released MetricName = 101 MetricName_ip_already_allocated MetricName = 102 MetricName_ip_allocation_failure MetricName = 103 // enodebd metrics MetricName_enodeb_mgmt_connected MetricName = 200 MetricName_enodeb_opstate_enabled MetricName = 201 MetricName_enodeb_rf_tx_enabled MetricName = 202 MetricName_enodeb_gps_connected MetricName = 203 MetricName_enodeb_ptp_connected MetricName = 204 MetricName_enodeb_mme_connected MetricName = 205 MetricName_rrc_estab_attempts MetricName = 206 MetricName_rrc_estab_successes MetricName = 207 MetricName_pdcp_user_plane_bytes_ul MetricName = 208 MetricName_pdcp_user_plane_bytes_dl MetricName = 209 MetricName_rrc_reestab_attempts MetricName = 210 MetricName_rrc_reestab_attempts_reconf_fail MetricName = 211 MetricName_rrc_reestab_attempts_ho_fail MetricName = 212 MetricName_rrc_reestab_attempts_other MetricName = 213 MetricName_rrc_reestab_successes MetricName = 214 MetricName_erab_estab_attempts MetricName = 215 MetricName_erab_estab_successes MetricName = 216 MetricName_erab_estab_failures MetricName = 217 MetricName_erab_release_requests MetricName = 218 MetricName_erab_release_requests_user_inactivity MetricName = 219 MetricName_erab_release_requests_normal MetricName = 220 MetricName_erab_release_requests_radio_resources_not_available MetricName = 221 MetricName_erab_release_requests_reduce_load MetricName = 222 MetricName_erab_release_requests_fail_in_radio_proc MetricName = 223 MetricName_erab_release_requests_eutran_reas MetricName = 224 MetricName_erab_release_requests_radio_radio_conn_lost MetricName = 225 MetricName_erab_release_requests_oam_intervention MetricName = 226 MetricName_enodeb_mgmt_configured MetricName = 227 MetricName_enodeb_reboot_timer_active MetricName = 228 MetricName_enodeb_reboots MetricName = 229 MetricName_enodeb_rf_tx_desired MetricName = 230 // Magmad metrics MetricName_magmad_ping_rtt_ms MetricName = 300 MetricName_cpu_percent MetricName = 301 MetricName_swap_memory_percent MetricName = 302 MetricName_virtual_memory_percent MetricName = 303 MetricName_disk_percent MetricName = 304 MetricName_bytes_sent MetricName = 305 MetricName_bytes_received MetricName = 306 MetricName_temperature MetricName = 307 MetricName_checkin_status MetricName = 308 MetricName_streamer_responses MetricName = 309 MetricName_mem_total MetricName = 310 MetricName_mem_available MetricName = 311 MetricName_mem_used MetricName = 312 MetricName_mem_free MetricName = 313 MetricName_bootstrap_exception MetricName = 314 MetricName_upgrader2_time_taken MetricName = 315 MetricName_upgrader2_error MetricName = 316 MetricName_upgrader2_prepared MetricName = 317 MetricName_upgrader2_downloaded MetricName = 318 MetricName_upgrader2_canary MetricName = 319 MetricName_upgrader2_stable MetricName = 320 MetricName_upgrader2_idle MetricName = 321 MetricName_unexpected_service_restarts MetricName = 322 MetricName_unattended_upgrade_status MetricName = 323 MetricName_service_restart_status MetricName = 324 // Pipelined metrics MetricName_dp_send_msg_error MetricName = 350 MetricName_arp_default_gw_mac_error MetricName = 351 MetricName_openflow_error_msg MetricName = 352 MetricName_unknown_pkt_direction MetricName = 353 MetricName_network_iface_status MetricName = 354 MetricName_enforcement_rule_install_fail MetricName = 355 MetricName_enforcement_stats_rule_install_fail MetricName = 356 /////////////////////////////// // GATEWAY FAILURES & ALERTS // /////////////////////////////// MetricName_mme_restarted MetricName = 400 MetricName_s1_reset_from_enb MetricName = 401 // SCTP MetricName_sctp_reset MetricName = 410 MetricName_sctp_shutdown MetricName = 411 // s6a MetricName_s6a_subscriberdb_connection_failure MetricName = 420 MetricName_s6a_auth_info_response_timer_expired MetricName = 421 // UE attach, Serivce Request MetricName_duplicate_attach_request MetricName = 430 MetricName_initial_context_setup_failure_received MetricName = 431 MetricName_initial_context_setup_request_timer_expired MetricName = 432 MetricName_nas_attach_accept_timer_expired MetricName = 433 MetricName_nas_auth_rsp_timer_expired MetricName = 434 MetricName_nas_security_mode_command_timer_expired MetricName = 435 MetricName_security_mode_reject_received MetricName = 436 MetricName_authentication_failure MetricName = 437 // cause=mac_failure,resync,amf MetricName_mme_spgw_create_session_req MetricName = 438 MetricName_mme_spgw_create_session_rsp MetricName = 439 MetricName_mme_spgw_delete_session_req MetricName = 440 MetricName_mme_spgw_delete_session_rsp MetricName = 441 // UE S1AP context MetricName_ue_context_release_request MetricName = 450 MetricName_ue_context_release_command_timer_expired MetricName = 451 // Detach MetricName_implicit_detach_timer_expired MetricName = 452 // eNB SCTP shutdown context clean up time MetricName_enb_sctp_shutdown_ue_clean_up_timer_expired MetricName = 453 // Other errors MetricName_s1ap_error_ind_received MetricName = 480 MetricName_gtpu_error_ind_received MetricName = 481 MetricName_nas_non_delivery_indication_received MetricName = 482 MetricName_emm_status_received MetricName = 483 MetricName_emm_status_sent MetricName = 484 //////////////////////// // GATEWAY PROCEDURES // //////////////////////// MetricName_mme_new_association MetricName = 500 MetricName_ue_attach MetricName = 501 // result=failure,accept,complete MetricName_service_request MetricName = 502 MetricName_ue_detach MetricName = 503 // cause=network_initiated, // deregister_ue,implicit_detach, // ue_initiated MetricName_spgw_create_session MetricName = 504 MetricName_spgw_delete_session MetricName = 505 MetricName_ue_pdn_connection MetricName = 506 MetricName_tracking_area_update MetricName = 507 MetricName_s1_setup MetricName = 508 // Generic service metrics MetricName_service_errors MetricName = 550 )
func (MetricName) Descriptor ¶
func (MetricName) Descriptor() protoreflect.EnumDescriptor
func (MetricName) Enum ¶
func (x MetricName) Enum() *MetricName
func (MetricName) EnumDescriptor
deprecated
func (MetricName) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetricName.Descriptor instead.
func (MetricName) Number ¶
func (x MetricName) Number() protoreflect.EnumNumber
func (MetricName) String ¶
func (x MetricName) String() string
func (MetricName) Type ¶
func (MetricName) Type() protoreflect.EnumType
type MetricsContainer ¶
type MetricsContainer struct { GatewayId string `protobuf:"bytes,1,opt,name=gatewayId,proto3" json:"gatewayId,omitempty"` // TODO: we should strip this out of metricsd (or duplicate it ourselves) // Prometheus 2 no longer supports protobuf client model Family []*_go.MetricFamily `protobuf:"bytes,2,rep,name=family,proto3" json:"family,omitempty"` // contains filtered or unexported fields }
func (*MetricsContainer) Descriptor
deprecated
func (*MetricsContainer) Descriptor() ([]byte, []int)
Deprecated: Use MetricsContainer.ProtoReflect.Descriptor instead.
func (*MetricsContainer) GetFamily ¶
func (x *MetricsContainer) GetFamily() []*_go.MetricFamily
func (*MetricsContainer) GetGatewayId ¶
func (x *MetricsContainer) GetGatewayId() string
func (*MetricsContainer) ProtoMessage ¶
func (*MetricsContainer) ProtoMessage()
func (*MetricsContainer) ProtoReflect ¶
func (x *MetricsContainer) ProtoReflect() protoreflect.Message
func (*MetricsContainer) Reset ¶
func (x *MetricsContainer) Reset()
func (*MetricsContainer) String ¶
func (x *MetricsContainer) String() string
type MetricsControllerClient ¶
type MetricsControllerClient interface { // Report a collection of metrics from a service Collect(ctx context.Context, in *MetricsContainer, opts ...grpc.CallOption) (*Void, error) // Push a collection of metrics to metricsd Push(ctx context.Context, in *PushedMetricsContainer, opts ...grpc.CallOption) (*Void, error) }
MetricsControllerClient is the client API for MetricsController service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMetricsControllerClient ¶
func NewMetricsControllerClient(cc grpc.ClientConnInterface) MetricsControllerClient
type MetricsControllerServer ¶
type MetricsControllerServer interface { // Report a collection of metrics from a service Collect(context.Context, *MetricsContainer) (*Void, error) // Push a collection of metrics to metricsd Push(context.Context, *PushedMetricsContainer) (*Void, error) }
MetricsControllerServer is the server API for MetricsController service.
type NetworkID ¶
type NetworkID struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
-------------------------------------------------------------------------- NetworkID uniquely identifies the network --------------------------------------------------------------------------
func (*NetworkID) Descriptor
deprecated
func (*NetworkID) ProtoMessage ¶
func (*NetworkID) ProtoMessage()
func (*NetworkID) ProtoReflect ¶
func (x *NetworkID) ProtoReflect() protoreflect.Message
type NetworkTestRequest ¶
type NetworkTestRequest struct { Pings []*PingParams `protobuf:"bytes,1,rep,name=pings,proto3" json:"pings,omitempty"` Traceroutes []*TracerouteParams `protobuf:"bytes,2,rep,name=traceroutes,proto3" json:"traceroutes,omitempty"` // contains filtered or unexported fields }
func (*NetworkTestRequest) Descriptor
deprecated
func (*NetworkTestRequest) Descriptor() ([]byte, []int)
Deprecated: Use NetworkTestRequest.ProtoReflect.Descriptor instead.
func (*NetworkTestRequest) GetPings ¶
func (x *NetworkTestRequest) GetPings() []*PingParams
func (*NetworkTestRequest) GetTraceroutes ¶
func (x *NetworkTestRequest) GetTraceroutes() []*TracerouteParams
func (*NetworkTestRequest) ProtoMessage ¶
func (*NetworkTestRequest) ProtoMessage()
func (*NetworkTestRequest) ProtoReflect ¶
func (x *NetworkTestRequest) ProtoReflect() protoreflect.Message
func (*NetworkTestRequest) Reset ¶
func (x *NetworkTestRequest) Reset()
func (*NetworkTestRequest) String ¶
func (x *NetworkTestRequest) String() string
type NetworkTestResponse ¶
type NetworkTestResponse struct { Pings []*PingResult `protobuf:"bytes,1,rep,name=pings,proto3" json:"pings,omitempty"` Traceroutes []*TracerouteResult `protobuf:"bytes,2,rep,name=traceroutes,proto3" json:"traceroutes,omitempty"` // contains filtered or unexported fields }
func (*NetworkTestResponse) Descriptor
deprecated
func (*NetworkTestResponse) Descriptor() ([]byte, []int)
Deprecated: Use NetworkTestResponse.ProtoReflect.Descriptor instead.
func (*NetworkTestResponse) GetPings ¶
func (x *NetworkTestResponse) GetPings() []*PingResult
func (*NetworkTestResponse) GetTraceroutes ¶
func (x *NetworkTestResponse) GetTraceroutes() []*TracerouteResult
func (*NetworkTestResponse) ProtoMessage ¶
func (*NetworkTestResponse) ProtoMessage()
func (*NetworkTestResponse) ProtoReflect ¶
func (x *NetworkTestResponse) ProtoReflect() protoreflect.Message
func (*NetworkTestResponse) Reset ¶
func (x *NetworkTestResponse) Reset()
func (*NetworkTestResponse) String ¶
func (x *NetworkTestResponse) String() string
type OffsetGatewayConfigs ¶
type OffsetGatewayConfigs struct { Configs *GatewayConfigs `protobuf:"bytes,1,opt,name=configs,proto3" json:"configs,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
Wraps a gateway config and a stream offset that the config was computed from
func (*OffsetGatewayConfigs) Descriptor
deprecated
func (*OffsetGatewayConfigs) Descriptor() ([]byte, []int)
Deprecated: Use OffsetGatewayConfigs.ProtoReflect.Descriptor instead.
func (*OffsetGatewayConfigs) GetConfigs ¶
func (x *OffsetGatewayConfigs) GetConfigs() *GatewayConfigs
func (*OffsetGatewayConfigs) GetOffset ¶
func (x *OffsetGatewayConfigs) GetOffset() int64
func (*OffsetGatewayConfigs) ProtoMessage ¶
func (*OffsetGatewayConfigs) ProtoMessage()
func (*OffsetGatewayConfigs) ProtoReflect ¶
func (x *OffsetGatewayConfigs) ProtoReflect() protoreflect.Message
func (*OffsetGatewayConfigs) Reset ¶
func (x *OffsetGatewayConfigs) Reset()
func (*OffsetGatewayConfigs) String ¶
func (x *OffsetGatewayConfigs) String() string
type PingParams ¶
type PingParams struct { HostOrIp string `protobuf:"bytes,1,opt,name=host_or_ip,json=hostOrIp,proto3" json:"host_or_ip,omitempty"` NumPackets int32 `protobuf:"varint,2,opt,name=num_packets,json=numPackets,proto3" json:"num_packets,omitempty"` // contains filtered or unexported fields }
func (*PingParams) Descriptor
deprecated
func (*PingParams) Descriptor() ([]byte, []int)
Deprecated: Use PingParams.ProtoReflect.Descriptor instead.
func (*PingParams) GetHostOrIp ¶
func (x *PingParams) GetHostOrIp() string
func (*PingParams) GetNumPackets ¶
func (x *PingParams) GetNumPackets() int32
func (*PingParams) ProtoMessage ¶
func (*PingParams) ProtoMessage()
func (*PingParams) ProtoReflect ¶
func (x *PingParams) ProtoReflect() protoreflect.Message
func (*PingParams) Reset ¶
func (x *PingParams) Reset()
func (*PingParams) String ¶
func (x *PingParams) String() string
type PingResult ¶
type PingResult struct { HostOrIp string `protobuf:"bytes,1,opt,name=host_or_ip,json=hostOrIp,proto3" json:"host_or_ip,omitempty"` NumPackets int32 `protobuf:"varint,2,opt,name=num_packets,json=numPackets,proto3" json:"num_packets,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` PacketsTransmitted int32 `protobuf:"varint,4,opt,name=packets_transmitted,json=packetsTransmitted,proto3" json:"packets_transmitted,omitempty"` PacketsReceived int32 `protobuf:"varint,5,opt,name=packets_received,json=packetsReceived,proto3" json:"packets_received,omitempty"` AvgResponseMs float32 `protobuf:"fixed32,6,opt,name=avg_response_ms,json=avgResponseMs,proto3" json:"avg_response_ms,omitempty"` // contains filtered or unexported fields }
func (*PingResult) Descriptor
deprecated
func (*PingResult) Descriptor() ([]byte, []int)
Deprecated: Use PingResult.ProtoReflect.Descriptor instead.
func (*PingResult) GetAvgResponseMs ¶
func (x *PingResult) GetAvgResponseMs() float32
func (*PingResult) GetError ¶
func (x *PingResult) GetError() string
func (*PingResult) GetHostOrIp ¶
func (x *PingResult) GetHostOrIp() string
func (*PingResult) GetNumPackets ¶
func (x *PingResult) GetNumPackets() int32
func (*PingResult) GetPacketsReceived ¶
func (x *PingResult) GetPacketsReceived() int32
func (*PingResult) GetPacketsTransmitted ¶
func (x *PingResult) GetPacketsTransmitted() int32
func (*PingResult) ProtoMessage ¶
func (*PingResult) ProtoMessage()
func (*PingResult) ProtoReflect ¶
func (x *PingResult) ProtoReflect() protoreflect.Message
func (*PingResult) Reset ¶
func (x *PingResult) Reset()
func (*PingResult) String ¶
func (x *PingResult) String() string
type PushedMetric ¶
type PushedMetric struct { MetricName string `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` TimestampMS int64 `protobuf:"varint,3,opt,name=timestampMS,proto3" json:"timestampMS,omitempty"` Labels []*LabelPair `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*PushedMetric) Descriptor
deprecated
func (*PushedMetric) Descriptor() ([]byte, []int)
Deprecated: Use PushedMetric.ProtoReflect.Descriptor instead.
func (*PushedMetric) GetLabels ¶
func (x *PushedMetric) GetLabels() []*LabelPair
func (*PushedMetric) GetMetricName ¶
func (x *PushedMetric) GetMetricName() string
func (*PushedMetric) GetTimestampMS ¶
func (x *PushedMetric) GetTimestampMS() int64
func (*PushedMetric) GetValue ¶
func (x *PushedMetric) GetValue() float64
func (*PushedMetric) ProtoMessage ¶
func (*PushedMetric) ProtoMessage()
func (*PushedMetric) ProtoReflect ¶
func (x *PushedMetric) ProtoReflect() protoreflect.Message
func (*PushedMetric) Reset ¶
func (x *PushedMetric) Reset()
func (*PushedMetric) String ¶
func (x *PushedMetric) String() string
type PushedMetricsContainer ¶
type PushedMetricsContainer struct { NetworkId string `protobuf:"bytes,1,opt,name=networkId,proto3" json:"networkId,omitempty"` Metrics []*PushedMetric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"` // contains filtered or unexported fields }
func (*PushedMetricsContainer) Descriptor
deprecated
func (*PushedMetricsContainer) Descriptor() ([]byte, []int)
Deprecated: Use PushedMetricsContainer.ProtoReflect.Descriptor instead.
func (*PushedMetricsContainer) GetMetrics ¶
func (x *PushedMetricsContainer) GetMetrics() []*PushedMetric
func (*PushedMetricsContainer) GetNetworkId ¶
func (x *PushedMetricsContainer) GetNetworkId() string
func (*PushedMetricsContainer) ProtoMessage ¶
func (*PushedMetricsContainer) ProtoMessage()
func (*PushedMetricsContainer) ProtoReflect ¶
func (x *PushedMetricsContainer) ProtoReflect() protoreflect.Message
func (*PushedMetricsContainer) Reset ¶
func (x *PushedMetricsContainer) Reset()
func (*PushedMetricsContainer) String ¶
func (x *PushedMetricsContainer) String() string
type RedisState ¶
type RedisState struct { SerializedMsg []byte `protobuf:"bytes,1,opt,name=serialized_msg,json=serializedMsg,proto3" json:"serialized_msg,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` IsGarbage bool `protobuf:"varint,3,opt,name=is_garbage,json=isGarbage,proto3" json:"is_garbage,omitempty"` // contains filtered or unexported fields }
func (*RedisState) Descriptor
deprecated
func (*RedisState) Descriptor() ([]byte, []int)
Deprecated: Use RedisState.ProtoReflect.Descriptor instead.
func (*RedisState) GetIsGarbage ¶
func (x *RedisState) GetIsGarbage() bool
func (*RedisState) GetSerializedMsg ¶
func (x *RedisState) GetSerializedMsg() []byte
func (*RedisState) GetVersion ¶
func (x *RedisState) GetVersion() uint64
func (*RedisState) ProtoMessage ¶
func (*RedisState) ProtoMessage()
func (*RedisState) ProtoReflect ¶
func (x *RedisState) ProtoReflect() protoreflect.Message
func (*RedisState) Reset ¶
func (x *RedisState) Reset()
func (*RedisState) String ¶
func (x *RedisState) String() string
type ReloadConfigResponse ¶
type ReloadConfigResponse struct { Result ReloadConfigResponse_ReloadConfigResult `protobuf:"varint,1,opt,name=result,proto3,enum=magma.orc8r.ReloadConfigResponse_ReloadConfigResult" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ReloadConfigResponse) Descriptor
deprecated
func (*ReloadConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReloadConfigResponse.ProtoReflect.Descriptor instead.
func (*ReloadConfigResponse) GetResult ¶
func (x *ReloadConfigResponse) GetResult() ReloadConfigResponse_ReloadConfigResult
func (*ReloadConfigResponse) ProtoMessage ¶
func (*ReloadConfigResponse) ProtoMessage()
func (*ReloadConfigResponse) ProtoReflect ¶
func (x *ReloadConfigResponse) ProtoReflect() protoreflect.Message
func (*ReloadConfigResponse) Reset ¶
func (x *ReloadConfigResponse) Reset()
func (*ReloadConfigResponse) String ¶
func (x *ReloadConfigResponse) String() string
type ReloadConfigResponse_ReloadConfigResult ¶
type ReloadConfigResponse_ReloadConfigResult int32
const ( ReloadConfigResponse_RELOAD_UNKNOWN ReloadConfigResponse_ReloadConfigResult = 0 ReloadConfigResponse_RELOAD_SUCCESS ReloadConfigResponse_ReloadConfigResult = 1 ReloadConfigResponse_RELOAD_FAILURE ReloadConfigResponse_ReloadConfigResult = 2 ReloadConfigResponse_RELOAD_UNSUPPORTED ReloadConfigResponse_ReloadConfigResult = 3 )
func (ReloadConfigResponse_ReloadConfigResult) Descriptor ¶
func (ReloadConfigResponse_ReloadConfigResult) Descriptor() protoreflect.EnumDescriptor
func (ReloadConfigResponse_ReloadConfigResult) EnumDescriptor
deprecated
func (ReloadConfigResponse_ReloadConfigResult) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReloadConfigResponse_ReloadConfigResult.Descriptor instead.
func (ReloadConfigResponse_ReloadConfigResult) Number ¶
func (x ReloadConfigResponse_ReloadConfigResult) Number() protoreflect.EnumNumber
func (ReloadConfigResponse_ReloadConfigResult) String ¶
func (x ReloadConfigResponse_ReloadConfigResult) String() string
func (ReloadConfigResponse_ReloadConfigResult) Type ¶
func (ReloadConfigResponse_ReloadConfigResult) Type() protoreflect.EnumType
type ReportStatesRequest ¶
type ReportStatesRequest struct { States []*State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"` // contains filtered or unexported fields }
func (*ReportStatesRequest) Descriptor
deprecated
func (*ReportStatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportStatesRequest.ProtoReflect.Descriptor instead.
func (*ReportStatesRequest) GetStates ¶
func (x *ReportStatesRequest) GetStates() []*State
func (*ReportStatesRequest) ProtoMessage ¶
func (*ReportStatesRequest) ProtoMessage()
func (*ReportStatesRequest) ProtoReflect ¶
func (x *ReportStatesRequest) ProtoReflect() protoreflect.Message
func (*ReportStatesRequest) Reset ¶
func (x *ReportStatesRequest) Reset()
func (*ReportStatesRequest) String ¶
func (x *ReportStatesRequest) String() string
type ReportStatesResponse ¶
type ReportStatesResponse struct { UnreportedStates []*IDAndError `protobuf:"bytes,1,rep,name=unreportedStates,proto3" json:"unreportedStates,omitempty"` // contains filtered or unexported fields }
func (*ReportStatesResponse) Descriptor
deprecated
func (*ReportStatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReportStatesResponse.ProtoReflect.Descriptor instead.
func (*ReportStatesResponse) GetUnreportedStates ¶
func (x *ReportStatesResponse) GetUnreportedStates() []*IDAndError
func (*ReportStatesResponse) ProtoMessage ¶
func (*ReportStatesResponse) ProtoMessage()
func (*ReportStatesResponse) ProtoReflect ¶
func (x *ReportStatesResponse) ProtoReflect() protoreflect.Message
func (*ReportStatesResponse) Reset ¶
func (x *ReportStatesResponse) Reset()
func (*ReportStatesResponse) String ¶
func (x *ReportStatesResponse) String() string
type Response ¶
type Response struct { HwId *AccessGatewayID `protobuf:"bytes,1,opt,name=hw_id,json=hwId,proto3" json:"hw_id,omitempty"` Challenge []byte `protobuf:"bytes,2,opt,name=challenge,proto3" json:"challenge,omitempty"` // Types that are assignable to Response: // *Response_EchoResponse // *Response_RsaResponse // *Response_EcdsaResponse Response isResponse_Response `protobuf_oneof:"response"` Csr *CSR `protobuf:"bytes,6,opt,name=csr,proto3" json:"csr,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetChallenge ¶
func (*Response) GetEcdsaResponse ¶
func (x *Response) GetEcdsaResponse() *Response_ECDSA
func (*Response) GetEchoResponse ¶
func (x *Response) GetEchoResponse() *Response_Echo
func (*Response) GetHwId ¶
func (x *Response) GetHwId() *AccessGatewayID
func (*Response) GetResponse ¶
func (m *Response) GetResponse() isResponse_Response
func (*Response) GetRsaResponse ¶
func (x *Response) GetRsaResponse() *Response_RSA
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Response_ECDSA ¶
type Response_ECDSA struct { R []byte `protobuf:"bytes,1,opt,name=r,proto3" json:"r,omitempty"` S []byte `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"` // contains filtered or unexported fields }
func (*Response_ECDSA) Descriptor
deprecated
func (*Response_ECDSA) Descriptor() ([]byte, []int)
Deprecated: Use Response_ECDSA.ProtoReflect.Descriptor instead.
func (*Response_ECDSA) GetR ¶
func (x *Response_ECDSA) GetR() []byte
func (*Response_ECDSA) GetS ¶
func (x *Response_ECDSA) GetS() []byte
func (*Response_ECDSA) ProtoMessage ¶
func (*Response_ECDSA) ProtoMessage()
func (*Response_ECDSA) ProtoReflect ¶
func (x *Response_ECDSA) ProtoReflect() protoreflect.Message
func (*Response_ECDSA) Reset ¶
func (x *Response_ECDSA) Reset()
func (*Response_ECDSA) String ¶
func (x *Response_ECDSA) String() string
type Response_EcdsaResponse ¶
type Response_EcdsaResponse struct {
EcdsaResponse *Response_ECDSA `protobuf:"bytes,5,opt,name=ecdsa_response,json=ecdsaResponse,proto3,oneof"`
}
type Response_Echo ¶
type Response_Echo struct { Response []byte `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
func (*Response_Echo) Descriptor
deprecated
func (*Response_Echo) Descriptor() ([]byte, []int)
Deprecated: Use Response_Echo.ProtoReflect.Descriptor instead.
func (*Response_Echo) GetResponse ¶
func (x *Response_Echo) GetResponse() []byte
func (*Response_Echo) ProtoMessage ¶
func (*Response_Echo) ProtoMessage()
func (*Response_Echo) ProtoReflect ¶
func (x *Response_Echo) ProtoReflect() protoreflect.Message
func (*Response_Echo) Reset ¶
func (x *Response_Echo) Reset()
func (*Response_Echo) String ¶
func (x *Response_Echo) String() string
type Response_EchoResponse ¶
type Response_EchoResponse struct {
EchoResponse *Response_Echo `protobuf:"bytes,3,opt,name=echo_response,json=echoResponse,proto3,oneof"`
}
type Response_RSA ¶
type Response_RSA struct { Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*Response_RSA) Descriptor
deprecated
func (*Response_RSA) Descriptor() ([]byte, []int)
Deprecated: Use Response_RSA.ProtoReflect.Descriptor instead.
func (*Response_RSA) GetSignature ¶
func (x *Response_RSA) GetSignature() []byte
func (*Response_RSA) ProtoMessage ¶
func (*Response_RSA) ProtoMessage()
func (*Response_RSA) ProtoReflect ¶
func (x *Response_RSA) ProtoReflect() protoreflect.Message
func (*Response_RSA) Reset ¶
func (x *Response_RSA) Reset()
func (*Response_RSA) String ¶
func (x *Response_RSA) String() string
type Response_RsaResponse ¶
type Response_RsaResponse struct {
RsaResponse *Response_RSA `protobuf:"bytes,4,opt,name=rsa_response,json=rsaResponse,proto3,oneof"`
}
type RestartServicesRequest ¶
type RestartServicesRequest struct { Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*RestartServicesRequest) Descriptor
deprecated
func (*RestartServicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartServicesRequest.ProtoReflect.Descriptor instead.
func (*RestartServicesRequest) GetServices ¶
func (x *RestartServicesRequest) GetServices() []string
func (*RestartServicesRequest) ProtoMessage ¶
func (*RestartServicesRequest) ProtoMessage()
func (*RestartServicesRequest) ProtoReflect ¶
func (x *RestartServicesRequest) ProtoReflect() protoreflect.Message
func (*RestartServicesRequest) Reset ¶
func (x *RestartServicesRequest) Reset()
func (*RestartServicesRequest) String ¶
func (x *RestartServicesRequest) String() string
type Service303Client ¶
type Service303Client interface { // Returns the service level info like name, version, state, status, etc. // GetServiceInfo(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ServiceInfo, error) // Request to stop the service gracefully. // StopService(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) // Collects metrics from the service GetMetrics(ctx context.Context, in *Void, opts ...grpc.CallOption) (*MetricsContainer, error) // Set logging level SetLogLevel(ctx context.Context, in *LogLevelMessage, opts ...grpc.CallOption) (*Void, error) // Set logging verbosity The larger, the more verbose. default 0 SetLogVerbosity(ctx context.Context, in *LogVerbosity, opts ...grpc.CallOption) (*Void, error) // Requests service reloads config files loaded on startup (<servicename>.yml) ReloadServiceConfig(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ReloadConfigResponse, error) // Returns the operational states of devices managed by this service. GetOperationalStates(ctx context.Context, in *Void, opts ...grpc.CallOption) (*GetOperationalStatesResponse, error) }
Service303Client is the client API for Service303 service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewService303Client ¶
func NewService303Client(cc grpc.ClientConnInterface) Service303Client
type Service303Server ¶
type Service303Server interface { // Returns the service level info like name, version, state, status, etc. // GetServiceInfo(context.Context, *Void) (*ServiceInfo, error) // Request to stop the service gracefully. // StopService(context.Context, *Void) (*Void, error) // Collects metrics from the service GetMetrics(context.Context, *Void) (*MetricsContainer, error) // Set logging level SetLogLevel(context.Context, *LogLevelMessage) (*Void, error) // Set logging verbosity The larger, the more verbose. default 0 SetLogVerbosity(context.Context, *LogVerbosity) (*Void, error) // Requests service reloads config files loaded on startup (<servicename>.yml) ReloadServiceConfig(context.Context, *Void) (*ReloadConfigResponse, error) // Returns the operational states of devices managed by this service. GetOperationalStates(context.Context, *Void) (*GetOperationalStatesResponse, error) }
Service303Server is the server API for Service303 service.
type ServiceExitStatus ¶
type ServiceExitStatus struct { LatestServiceResult ServiceExitStatus_ServiceResult `` /* 170-byte string literal not displayed */ LatestExitCode ServiceExitStatus_ExitCode `` /* 150-byte string literal not displayed */ // Optional return code returned by the service during exit LatestRc uint32 `protobuf:"varint,3,opt,name=latest_rc,json=latestRc,proto3" json:"latest_rc,omitempty"` // Clean exit, e.g. SIGNKILL NumCleanExits uint32 `protobuf:"varint,4,opt,name=num_clean_exits,json=numCleanExits,proto3" json:"num_clean_exits,omitempty"` // Unclean exit e.g. CORE_DUMP or non zero exit code. NumFailExits uint32 `protobuf:"varint,5,opt,name=num_fail_exits,json=numFailExits,proto3" json:"num_fail_exits,omitempty"` // contains filtered or unexported fields }
func (*ServiceExitStatus) Descriptor
deprecated
func (*ServiceExitStatus) Descriptor() ([]byte, []int)
Deprecated: Use ServiceExitStatus.ProtoReflect.Descriptor instead.
func (*ServiceExitStatus) GetLatestExitCode ¶
func (x *ServiceExitStatus) GetLatestExitCode() ServiceExitStatus_ExitCode
func (*ServiceExitStatus) GetLatestRc ¶
func (x *ServiceExitStatus) GetLatestRc() uint32
func (*ServiceExitStatus) GetLatestServiceResult ¶
func (x *ServiceExitStatus) GetLatestServiceResult() ServiceExitStatus_ServiceResult
func (*ServiceExitStatus) GetNumCleanExits ¶
func (x *ServiceExitStatus) GetNumCleanExits() uint32
func (*ServiceExitStatus) GetNumFailExits ¶
func (x *ServiceExitStatus) GetNumFailExits() uint32
func (*ServiceExitStatus) ProtoMessage ¶
func (*ServiceExitStatus) ProtoMessage()
func (*ServiceExitStatus) ProtoReflect ¶
func (x *ServiceExitStatus) ProtoReflect() protoreflect.Message
func (*ServiceExitStatus) Reset ¶
func (x *ServiceExitStatus) Reset()
func (*ServiceExitStatus) String ¶
func (x *ServiceExitStatus) String() string
type ServiceExitStatus_ExitCode ¶
type ServiceExitStatus_ExitCode int32
ExitCode enumeration as defined in service "result" by systemd
const ( ServiceExitStatus_UNUSED_EXIT_CODE ServiceExitStatus_ExitCode = 0 ServiceExitStatus_EXITED ServiceExitStatus_ExitCode = 1 ServiceExitStatus_KILLED ServiceExitStatus_ExitCode = 2 ServiceExitStatus_DUMPED ServiceExitStatus_ExitCode = 3 )
func (ServiceExitStatus_ExitCode) Descriptor ¶
func (ServiceExitStatus_ExitCode) Descriptor() protoreflect.EnumDescriptor
func (ServiceExitStatus_ExitCode) Enum ¶
func (x ServiceExitStatus_ExitCode) Enum() *ServiceExitStatus_ExitCode
func (ServiceExitStatus_ExitCode) EnumDescriptor
deprecated
func (ServiceExitStatus_ExitCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceExitStatus_ExitCode.Descriptor instead.
func (ServiceExitStatus_ExitCode) Number ¶
func (x ServiceExitStatus_ExitCode) Number() protoreflect.EnumNumber
func (ServiceExitStatus_ExitCode) String ¶
func (x ServiceExitStatus_ExitCode) String() string
func (ServiceExitStatus_ExitCode) Type ¶
func (ServiceExitStatus_ExitCode) Type() protoreflect.EnumType
type ServiceExitStatus_ServiceResult ¶
type ServiceExitStatus_ServiceResult int32
ServiceResult enumeration as defined in service "result" by systemd
const ( ServiceExitStatus_UNUSED ServiceExitStatus_ServiceResult = 0 ServiceExitStatus_SUCCESS ServiceExitStatus_ServiceResult = 1 ServiceExitStatus_PROTOCOL ServiceExitStatus_ServiceResult = 2 ServiceExitStatus_TIMEOUT ServiceExitStatus_ServiceResult = 3 ServiceExitStatus_EXIT_CODE ServiceExitStatus_ServiceResult = 4 ServiceExitStatus_SIGNAL ServiceExitStatus_ServiceResult = 5 ServiceExitStatus_CORE_DUMP ServiceExitStatus_ServiceResult = 6 ServiceExitStatus_WATCHDOG ServiceExitStatus_ServiceResult = 7 ServiceExitStatus_START_LIMIT_HIT ServiceExitStatus_ServiceResult = 8 ServiceExitStatus_RESOURCES ServiceExitStatus_ServiceResult = 9 )
func (ServiceExitStatus_ServiceResult) Descriptor ¶
func (ServiceExitStatus_ServiceResult) Descriptor() protoreflect.EnumDescriptor
func (ServiceExitStatus_ServiceResult) Enum ¶
func (x ServiceExitStatus_ServiceResult) Enum() *ServiceExitStatus_ServiceResult
func (ServiceExitStatus_ServiceResult) EnumDescriptor
deprecated
func (ServiceExitStatus_ServiceResult) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceExitStatus_ServiceResult.Descriptor instead.
func (ServiceExitStatus_ServiceResult) Number ¶
func (x ServiceExitStatus_ServiceResult) Number() protoreflect.EnumNumber
func (ServiceExitStatus_ServiceResult) String ¶
func (x ServiceExitStatus_ServiceResult) String() string
func (ServiceExitStatus_ServiceResult) Type ¶
func (ServiceExitStatus_ServiceResult) Type() protoreflect.EnumType
type ServiceInfo ¶
type ServiceInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` State ServiceInfo_ServiceState `protobuf:"varint,3,opt,name=state,proto3,enum=magma.orc8r.ServiceInfo_ServiceState" json:"state,omitempty"` Status *ServiceStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` Health ServiceInfo_ApplicationHealth `protobuf:"varint,5,opt,name=health,proto3,enum=magma.orc8r.ServiceInfo_ApplicationHealth" json:"health,omitempty"` // Time when the service was started (in seconds since epoch) StartTimeSecs uint64 `protobuf:"varint,6,opt,name=start_time_secs,json=startTimeSecs,proto3" json:"start_time_secs,omitempty"` // contains filtered or unexported fields }
func (*ServiceInfo) Descriptor
deprecated
func (*ServiceInfo) Descriptor() ([]byte, []int)
Deprecated: Use ServiceInfo.ProtoReflect.Descriptor instead.
func (*ServiceInfo) GetHealth ¶
func (x *ServiceInfo) GetHealth() ServiceInfo_ApplicationHealth
func (*ServiceInfo) GetName ¶
func (x *ServiceInfo) GetName() string
func (*ServiceInfo) GetStartTimeSecs ¶
func (x *ServiceInfo) GetStartTimeSecs() uint64
func (*ServiceInfo) GetState ¶
func (x *ServiceInfo) GetState() ServiceInfo_ServiceState
func (*ServiceInfo) GetStatus ¶
func (x *ServiceInfo) GetStatus() *ServiceStatus
func (*ServiceInfo) GetVersion ¶
func (x *ServiceInfo) GetVersion() string
func (*ServiceInfo) ProtoMessage ¶
func (*ServiceInfo) ProtoMessage()
func (*ServiceInfo) ProtoReflect ¶
func (x *ServiceInfo) ProtoReflect() protoreflect.Message
func (*ServiceInfo) Reset ¶
func (x *ServiceInfo) Reset()
func (*ServiceInfo) String ¶
func (x *ServiceInfo) String() string
type ServiceInfo_ApplicationHealth ¶
type ServiceInfo_ApplicationHealth int32
Gives information about whether the application is usable. Though the process may have started, the connections may not be set up. APP_HEALTHY in this case means the application is entirely usable
const ( ServiceInfo_APP_UNKNOWN ServiceInfo_ApplicationHealth = 0 ServiceInfo_APP_UNHEALTHY ServiceInfo_ApplicationHealth = 1 ServiceInfo_APP_HEALTHY ServiceInfo_ApplicationHealth = 2 )
func (ServiceInfo_ApplicationHealth) Descriptor ¶
func (ServiceInfo_ApplicationHealth) Descriptor() protoreflect.EnumDescriptor
func (ServiceInfo_ApplicationHealth) Enum ¶
func (x ServiceInfo_ApplicationHealth) Enum() *ServiceInfo_ApplicationHealth
func (ServiceInfo_ApplicationHealth) EnumDescriptor
deprecated
func (ServiceInfo_ApplicationHealth) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceInfo_ApplicationHealth.Descriptor instead.
func (ServiceInfo_ApplicationHealth) Number ¶
func (x ServiceInfo_ApplicationHealth) Number() protoreflect.EnumNumber
func (ServiceInfo_ApplicationHealth) String ¶
func (x ServiceInfo_ApplicationHealth) String() string
func (ServiceInfo_ApplicationHealth) Type ¶
func (ServiceInfo_ApplicationHealth) Type() protoreflect.EnumType
type ServiceInfo_ServiceState ¶
type ServiceInfo_ServiceState int32
const ( ServiceInfo_UNKNOWN ServiceInfo_ServiceState = 0 ServiceInfo_STARTING ServiceInfo_ServiceState = 1 ServiceInfo_ALIVE ServiceInfo_ServiceState = 2 ServiceInfo_STOPPING ServiceInfo_ServiceState = 3 ServiceInfo_STOPPED ServiceInfo_ServiceState = 4 )
func (ServiceInfo_ServiceState) Descriptor ¶
func (ServiceInfo_ServiceState) Descriptor() protoreflect.EnumDescriptor
func (ServiceInfo_ServiceState) Enum ¶
func (x ServiceInfo_ServiceState) Enum() *ServiceInfo_ServiceState
func (ServiceInfo_ServiceState) EnumDescriptor
deprecated
func (ServiceInfo_ServiceState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceInfo_ServiceState.Descriptor instead.
func (ServiceInfo_ServiceState) Number ¶
func (x ServiceInfo_ServiceState) Number() protoreflect.EnumNumber
func (ServiceInfo_ServiceState) String ¶
func (x ServiceInfo_ServiceState) String() string
func (ServiceInfo_ServiceState) Type ¶
func (ServiceInfo_ServiceState) Type() protoreflect.EnumType
type ServiceStatus ¶
type ServiceStatus struct { // Metadata from the services that will be sent to the cloud through checkin Meta map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ServiceStatus) Descriptor
deprecated
func (*ServiceStatus) Descriptor() ([]byte, []int)
Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.
func (*ServiceStatus) GetMeta ¶
func (x *ServiceStatus) GetMeta() map[string]string
func (*ServiceStatus) ProtoMessage ¶
func (*ServiceStatus) ProtoMessage()
func (*ServiceStatus) ProtoReflect ¶
func (x *ServiceStatus) ProtoReflect() protoreflect.Message
func (*ServiceStatus) Reset ¶
func (x *ServiceStatus) Reset()
func (*ServiceStatus) String ¶
func (x *ServiceStatus) String() string
type State ¶
type State struct { // Type determines how the value is deserialized and validated on the cloud service side Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` DeviceID string `protobuf:"bytes,2,opt,name=deviceID,proto3" json:"deviceID,omitempty"` // Value contains the operational state json-serialized. Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*State) Descriptor
deprecated
func (*State) GetDeviceID ¶
func (*State) GetVersion ¶
func (*State) ProtoMessage ¶
func (*State) ProtoMessage()
func (*State) ProtoReflect ¶
func (x *State) ProtoReflect() protoreflect.Message
type StateID ¶
type StateID struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` DeviceID string `protobuf:"bytes,2,opt,name=deviceID,proto3" json:"deviceID,omitempty"` // contains filtered or unexported fields }
func (*StateID) Descriptor
deprecated
func (*StateID) GetDeviceID ¶
func (*StateID) ProtoMessage ¶
func (*StateID) ProtoMessage()
func (*StateID) ProtoReflect ¶
func (x *StateID) ProtoReflect() protoreflect.Message
type StateServiceClient ¶
type StateServiceClient interface { // GetStates retrieves states from blobstorage. GetStates(ctx context.Context, in *GetStatesRequest, opts ...grpc.CallOption) (*GetStatesResponse, error) // ReportStates saves states into blobstorage. ReportStates(ctx context.Context, in *ReportStatesRequest, opts ...grpc.CallOption) (*ReportStatesResponse, error) // DeleteStates deletes states from blobstorage. DeleteStates(ctx context.Context, in *DeleteStatesRequest, opts ...grpc.CallOption) (*Void, error) // SyncStates retrieves states from blobstorage, compares their versions // to the states included in the request, and returns the IDAndVersions // that differ. SyncStates(ctx context.Context, in *SyncStatesRequest, opts ...grpc.CallOption) (*SyncStatesResponse, error) }
StateServiceClient is the client API for StateService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStateServiceClient ¶
func NewStateServiceClient(cc grpc.ClientConnInterface) StateServiceClient
type StateServiceServer ¶
type StateServiceServer interface { // GetStates retrieves states from blobstorage. GetStates(context.Context, *GetStatesRequest) (*GetStatesResponse, error) // ReportStates saves states into blobstorage. ReportStates(context.Context, *ReportStatesRequest) (*ReportStatesResponse, error) // DeleteStates deletes states from blobstorage. DeleteStates(context.Context, *DeleteStatesRequest) (*Void, error) // SyncStates retrieves states from blobstorage, compares their versions // to the states included in the request, and returns the IDAndVersions // that differ. SyncStates(context.Context, *SyncStatesRequest) (*SyncStatesResponse, error) }
StateServiceServer is the server API for StateService service.
type StreamRequest ¶
type StreamRequest struct { GatewayId string `protobuf:"bytes,1,opt,name=gatewayId,proto3" json:"gatewayId,omitempty"` // stream_name to attach to. // E.g., subscriberdb, config, etc. StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"` // extra_args contain any extra data to send up with the stream request. // This value will be different per stream provider. ExtraArgs *any.Any `protobuf:"bytes,3,opt,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"` // contains filtered or unexported fields }
func (*StreamRequest) Descriptor
deprecated
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetExtraArgs ¶
func (x *StreamRequest) GetExtraArgs() *any.Any
func (*StreamRequest) GetGatewayId ¶
func (x *StreamRequest) GetGatewayId() string
func (*StreamRequest) GetStreamName ¶
func (x *StreamRequest) GetStreamName() string
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶
func (x *StreamRequest) String() string
type StreamerClient ¶
type StreamerClient interface { // GetUpdates streams config updates from the cloud. // The RPC call would be kept open to push new updates as they happen. GetUpdates(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (Streamer_GetUpdatesClient, error) }
StreamerClient is the client API for Streamer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStreamerClient ¶
func NewStreamerClient(cc grpc.ClientConnInterface) StreamerClient
type StreamerServer ¶
type StreamerServer interface { // GetUpdates streams config updates from the cloud. // The RPC call would be kept open to push new updates as they happen. GetUpdates(*StreamRequest, Streamer_GetUpdatesServer) error }
StreamerServer is the server API for Streamer service.
type Streamer_GetUpdatesClient ¶
type Streamer_GetUpdatesClient interface { Recv() (*DataUpdateBatch, error) grpc.ClientStream }
type Streamer_GetUpdatesServer ¶
type Streamer_GetUpdatesServer interface { Send(*DataUpdateBatch) error grpc.ServerStream }
type SyncRPCRequest ¶
type SyncRPCRequest struct { // unique request Id passed in from cloud ReqId uint32 `protobuf:"varint,1,opt,name=reqId,proto3" json:"reqId,omitempty"` ReqBody *GatewayRequest `protobuf:"bytes,2,opt,name=reqBody,proto3" json:"reqBody,omitempty"` // cloud will send a heartBeat every minute, if no other requests are sent // down to the gateway HeartBeat bool `protobuf:"varint,3,opt,name=heartBeat,proto3" json:"heartBeat,omitempty"` // connClosed is set to true when the client closes the connection ConnClosed bool `protobuf:"varint,4,opt,name=connClosed,proto3" json:"connClosed,omitempty"` // contains filtered or unexported fields }
SyncRPCRequest is sent down to gateway from cloud
func (*SyncRPCRequest) Descriptor
deprecated
func (*SyncRPCRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncRPCRequest.ProtoReflect.Descriptor instead.
func (*SyncRPCRequest) GetConnClosed ¶
func (x *SyncRPCRequest) GetConnClosed() bool
func (*SyncRPCRequest) GetHeartBeat ¶
func (x *SyncRPCRequest) GetHeartBeat() bool
func (*SyncRPCRequest) GetReqBody ¶
func (x *SyncRPCRequest) GetReqBody() *GatewayRequest
func (*SyncRPCRequest) GetReqId ¶
func (x *SyncRPCRequest) GetReqId() uint32
func (*SyncRPCRequest) ProtoMessage ¶
func (*SyncRPCRequest) ProtoMessage()
func (*SyncRPCRequest) ProtoReflect ¶
func (x *SyncRPCRequest) ProtoReflect() protoreflect.Message
func (*SyncRPCRequest) Reset ¶
func (x *SyncRPCRequest) Reset()
func (*SyncRPCRequest) String ¶
func (x *SyncRPCRequest) String() string
type SyncRPCResponse ¶
type SyncRPCResponse struct { ReqId uint32 `protobuf:"varint,1,opt,name=reqId,proto3" json:"reqId,omitempty"` RespBody *GatewayResponse `protobuf:"bytes,2,opt,name=respBody,proto3" json:"respBody,omitempty"` // gateway will send a heartBeat if it hasn't received SyncRPCRequests from cloud for a while. // If it's a heartbeat, reqId and respBody will be ignored. HeartBeat bool `protobuf:"varint,3,opt,name=heartBeat,proto3" json:"heartBeat,omitempty"` // contains filtered or unexported fields }
SyncRPCResponse is sent from gateway to cloud
func (*SyncRPCResponse) Descriptor
deprecated
func (*SyncRPCResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncRPCResponse.ProtoReflect.Descriptor instead.
func (*SyncRPCResponse) GetHeartBeat ¶
func (x *SyncRPCResponse) GetHeartBeat() bool
func (*SyncRPCResponse) GetReqId ¶
func (x *SyncRPCResponse) GetReqId() uint32
func (*SyncRPCResponse) GetRespBody ¶
func (x *SyncRPCResponse) GetRespBody() *GatewayResponse
func (*SyncRPCResponse) ProtoMessage ¶
func (*SyncRPCResponse) ProtoMessage()
func (*SyncRPCResponse) ProtoReflect ¶
func (x *SyncRPCResponse) ProtoReflect() protoreflect.Message
func (*SyncRPCResponse) Reset ¶
func (x *SyncRPCResponse) Reset()
func (*SyncRPCResponse) String ¶
func (x *SyncRPCResponse) String() string
type SyncRPCServiceClient ¶
type SyncRPCServiceClient interface { // creates a bidirectional stream from gateway to cloud // so cloud can send in SyncRPCRequest, and wait for SyncRPCResponse. // This will be the underlying service for Synchronous RPC from the cloud. EstablishSyncRPCStream(ctx context.Context, opts ...grpc.CallOption) (SyncRPCService_EstablishSyncRPCStreamClient, error) // same method as EstablishSyncRPCStream, but named differently for backward compatibility SyncRPC(ctx context.Context, opts ...grpc.CallOption) (SyncRPCService_SyncRPCClient, error) }
SyncRPCServiceClient is the client API for SyncRPCService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewSyncRPCServiceClient ¶
func NewSyncRPCServiceClient(cc grpc.ClientConnInterface) SyncRPCServiceClient
type SyncRPCServiceServer ¶
type SyncRPCServiceServer interface { // creates a bidirectional stream from gateway to cloud // so cloud can send in SyncRPCRequest, and wait for SyncRPCResponse. // This will be the underlying service for Synchronous RPC from the cloud. EstablishSyncRPCStream(SyncRPCService_EstablishSyncRPCStreamServer) error // same method as EstablishSyncRPCStream, but named differently for backward compatibility SyncRPC(SyncRPCService_SyncRPCServer) error }
SyncRPCServiceServer is the server API for SyncRPCService service.
type SyncRPCService_EstablishSyncRPCStreamClient ¶
type SyncRPCService_EstablishSyncRPCStreamClient interface { Send(*SyncRPCResponse) error Recv() (*SyncRPCRequest, error) grpc.ClientStream }
type SyncRPCService_EstablishSyncRPCStreamServer ¶
type SyncRPCService_EstablishSyncRPCStreamServer interface { Send(*SyncRPCRequest) error Recv() (*SyncRPCResponse, error) grpc.ServerStream }
type SyncRPCService_SyncRPCClient ¶
type SyncRPCService_SyncRPCClient interface { Send(*SyncRPCResponse) error Recv() (*SyncRPCRequest, error) grpc.ClientStream }
type SyncRPCService_SyncRPCServer ¶
type SyncRPCService_SyncRPCServer interface { Send(*SyncRPCRequest) error Recv() (*SyncRPCResponse, error) grpc.ServerStream }
type SyncStatesRequest ¶
type SyncStatesRequest struct { States []*IDAndVersion `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"` // contains filtered or unexported fields }
func (*SyncStatesRequest) Descriptor
deprecated
func (*SyncStatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncStatesRequest.ProtoReflect.Descriptor instead.
func (*SyncStatesRequest) GetStates ¶
func (x *SyncStatesRequest) GetStates() []*IDAndVersion
func (*SyncStatesRequest) ProtoMessage ¶
func (*SyncStatesRequest) ProtoMessage()
func (*SyncStatesRequest) ProtoReflect ¶
func (x *SyncStatesRequest) ProtoReflect() protoreflect.Message
func (*SyncStatesRequest) Reset ¶
func (x *SyncStatesRequest) Reset()
func (*SyncStatesRequest) String ¶
func (x *SyncStatesRequest) String() string
type SyncStatesResponse ¶
type SyncStatesResponse struct { UnsyncedStates []*IDAndVersion `protobuf:"bytes,1,rep,name=unsyncedStates,proto3" json:"unsyncedStates,omitempty"` // contains filtered or unexported fields }
func (*SyncStatesResponse) Descriptor
deprecated
func (*SyncStatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncStatesResponse.ProtoReflect.Descriptor instead.
func (*SyncStatesResponse) GetUnsyncedStates ¶
func (x *SyncStatesResponse) GetUnsyncedStates() []*IDAndVersion
func (*SyncStatesResponse) ProtoMessage ¶
func (*SyncStatesResponse) ProtoMessage()
func (*SyncStatesResponse) ProtoReflect ¶
func (x *SyncStatesResponse) ProtoReflect() protoreflect.Message
func (*SyncStatesResponse) Reset ¶
func (x *SyncStatesResponse) Reset()
func (*SyncStatesResponse) String ¶
func (x *SyncStatesResponse) String() string
type TailLogsRequest ¶
type TailLogsRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // contains filtered or unexported fields }
func (*TailLogsRequest) Descriptor
deprecated
func (*TailLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use TailLogsRequest.ProtoReflect.Descriptor instead.
func (*TailLogsRequest) GetService ¶
func (x *TailLogsRequest) GetService() string
func (*TailLogsRequest) ProtoMessage ¶
func (*TailLogsRequest) ProtoMessage()
func (*TailLogsRequest) ProtoReflect ¶
func (x *TailLogsRequest) ProtoReflect() protoreflect.Message
func (*TailLogsRequest) Reset ¶
func (x *TailLogsRequest) Reset()
func (*TailLogsRequest) String ¶
func (x *TailLogsRequest) String() string
type Tenant ¶
type Tenant struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Networks []string `protobuf:"bytes,2,rep,name=networks,proto3" json:"networks,omitempty"` // contains filtered or unexported fields }
func (*Tenant) Descriptor
deprecated
func (*Tenant) GetNetworks ¶
func (*Tenant) ProtoMessage ¶
func (*Tenant) ProtoMessage()
func (*Tenant) ProtoReflect ¶
func (x *Tenant) ProtoReflect() protoreflect.Message
type TenantList ¶
type TenantList struct { Tenants []*IDAndTenant `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"` // contains filtered or unexported fields }
func (*TenantList) Descriptor
deprecated
func (*TenantList) Descriptor() ([]byte, []int)
Deprecated: Use TenantList.ProtoReflect.Descriptor instead.
func (*TenantList) GetTenants ¶
func (x *TenantList) GetTenants() []*IDAndTenant
func (*TenantList) ProtoMessage ¶
func (*TenantList) ProtoMessage()
func (*TenantList) ProtoReflect ¶
func (x *TenantList) ProtoReflect() protoreflect.Message
func (*TenantList) Reset ¶
func (x *TenantList) Reset()
func (*TenantList) String ¶
func (x *TenantList) String() string
type TenantsServiceClient ¶
type TenantsServiceClient interface { GetAllTenants(ctx context.Context, in *Void, opts ...grpc.CallOption) (*TenantList, error) GetTenant(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*Tenant, error) CreateTenant(ctx context.Context, in *IDAndTenant, opts ...grpc.CallOption) (*Void, error) SetTenant(ctx context.Context, in *IDAndTenant, opts ...grpc.CallOption) (*Void, error) DeleteTenant(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*Void, error) }
TenantsServiceClient is the client API for TenantsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTenantsServiceClient ¶
func NewTenantsServiceClient(cc grpc.ClientConnInterface) TenantsServiceClient
type TenantsServiceServer ¶
type TenantsServiceServer interface { GetAllTenants(context.Context, *Void) (*TenantList, error) GetTenant(context.Context, *GetTenantRequest) (*Tenant, error) CreateTenant(context.Context, *IDAndTenant) (*Void, error) SetTenant(context.Context, *IDAndTenant) (*Void, error) DeleteTenant(context.Context, *GetTenantRequest) (*Void, error) }
TenantsServiceServer is the server API for TenantsService service.
type TracerouteHop ¶
type TracerouteHop struct { Idx int32 `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"` Probes []*TracerouteProbe `protobuf:"bytes,2,rep,name=probes,proto3" json:"probes,omitempty"` // contains filtered or unexported fields }
func (*TracerouteHop) Descriptor
deprecated
func (*TracerouteHop) Descriptor() ([]byte, []int)
Deprecated: Use TracerouteHop.ProtoReflect.Descriptor instead.
func (*TracerouteHop) GetIdx ¶
func (x *TracerouteHop) GetIdx() int32
func (*TracerouteHop) GetProbes ¶
func (x *TracerouteHop) GetProbes() []*TracerouteProbe
func (*TracerouteHop) ProtoMessage ¶
func (*TracerouteHop) ProtoMessage()
func (*TracerouteHop) ProtoReflect ¶
func (x *TracerouteHop) ProtoReflect() protoreflect.Message
func (*TracerouteHop) Reset ¶
func (x *TracerouteHop) Reset()
func (*TracerouteHop) String ¶
func (x *TracerouteHop) String() string
type TracerouteParams ¶
type TracerouteParams struct { HostOrIp string `protobuf:"bytes,1,opt,name=host_or_ip,json=hostOrIp,proto3" json:"host_or_ip,omitempty"` MaxHops int32 `protobuf:"varint,2,opt,name=max_hops,json=maxHops,proto3" json:"max_hops,omitempty"` BytesPerPacket int32 `protobuf:"varint,3,opt,name=bytes_per_packet,json=bytesPerPacket,proto3" json:"bytes_per_packet,omitempty"` // contains filtered or unexported fields }
func (*TracerouteParams) Descriptor
deprecated
func (*TracerouteParams) Descriptor() ([]byte, []int)
Deprecated: Use TracerouteParams.ProtoReflect.Descriptor instead.
func (*TracerouteParams) GetBytesPerPacket ¶
func (x *TracerouteParams) GetBytesPerPacket() int32
func (*TracerouteParams) GetHostOrIp ¶
func (x *TracerouteParams) GetHostOrIp() string
func (*TracerouteParams) GetMaxHops ¶
func (x *TracerouteParams) GetMaxHops() int32
func (*TracerouteParams) ProtoMessage ¶
func (*TracerouteParams) ProtoMessage()
func (*TracerouteParams) ProtoReflect ¶
func (x *TracerouteParams) ProtoReflect() protoreflect.Message
func (*TracerouteParams) Reset ¶
func (x *TracerouteParams) Reset()
func (*TracerouteParams) String ¶
func (x *TracerouteParams) String() string
type TracerouteProbe ¶
type TracerouteProbe struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` RttMs float32 `protobuf:"fixed32,3,opt,name=rtt_ms,json=rttMs,proto3" json:"rtt_ms,omitempty"` // contains filtered or unexported fields }
func (*TracerouteProbe) Descriptor
deprecated
func (*TracerouteProbe) Descriptor() ([]byte, []int)
Deprecated: Use TracerouteProbe.ProtoReflect.Descriptor instead.
func (*TracerouteProbe) GetHostname ¶
func (x *TracerouteProbe) GetHostname() string
func (*TracerouteProbe) GetIp ¶
func (x *TracerouteProbe) GetIp() string
func (*TracerouteProbe) GetRttMs ¶
func (x *TracerouteProbe) GetRttMs() float32
func (*TracerouteProbe) ProtoMessage ¶
func (*TracerouteProbe) ProtoMessage()
func (*TracerouteProbe) ProtoReflect ¶
func (x *TracerouteProbe) ProtoReflect() protoreflect.Message
func (*TracerouteProbe) Reset ¶
func (x *TracerouteProbe) Reset()
func (*TracerouteProbe) String ¶
func (x *TracerouteProbe) String() string
type TracerouteResult ¶
type TracerouteResult struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` HostOrIp string `protobuf:"bytes,2,opt,name=host_or_ip,json=hostOrIp,proto3" json:"host_or_ip,omitempty"` Hops []*TracerouteHop `protobuf:"bytes,3,rep,name=hops,proto3" json:"hops,omitempty"` // contains filtered or unexported fields }
func (*TracerouteResult) Descriptor
deprecated
func (*TracerouteResult) Descriptor() ([]byte, []int)
Deprecated: Use TracerouteResult.ProtoReflect.Descriptor instead.
func (*TracerouteResult) GetError ¶
func (x *TracerouteResult) GetError() string
func (*TracerouteResult) GetHops ¶
func (x *TracerouteResult) GetHops() []*TracerouteHop
func (*TracerouteResult) GetHostOrIp ¶
func (x *TracerouteResult) GetHostOrIp() string
func (*TracerouteResult) ProtoMessage ¶
func (*TracerouteResult) ProtoMessage()
func (*TracerouteResult) ProtoReflect ¶
func (x *TracerouteResult) ProtoReflect() protoreflect.Message
func (*TracerouteResult) Reset ¶
func (x *TracerouteResult) Reset()
func (*TracerouteResult) String ¶
func (x *TracerouteResult) String() string
type UnimplementedBootstrapperServer ¶
type UnimplementedBootstrapperServer struct { }
UnimplementedBootstrapperServer can be embedded to have forward compatible implementations.
func (*UnimplementedBootstrapperServer) GetChallenge ¶
func (*UnimplementedBootstrapperServer) GetChallenge(context.Context, *AccessGatewayID) (*Challenge, error)
func (*UnimplementedBootstrapperServer) RequestSign ¶
func (*UnimplementedBootstrapperServer) RequestSign(context.Context, *Response) (*Certificate, error)
type UnimplementedDirectoryLookupServer ¶
type UnimplementedDirectoryLookupServer struct { }
UnimplementedDirectoryLookupServer can be embedded to have forward compatible implementations.
func (*UnimplementedDirectoryLookupServer) GetHostnameForHWID ¶
func (*UnimplementedDirectoryLookupServer) GetHostnameForHWID(context.Context, *GetHostnameForHWIDRequest) (*GetHostnameForHWIDResponse, error)
func (*UnimplementedDirectoryLookupServer) GetIMSIForSessionID ¶
func (*UnimplementedDirectoryLookupServer) GetIMSIForSessionID(context.Context, *GetIMSIForSessionIDRequest) (*GetIMSIForSessionIDResponse, error)
func (*UnimplementedDirectoryLookupServer) MapHWIDsToHostnames ¶
func (*UnimplementedDirectoryLookupServer) MapHWIDsToHostnames(context.Context, *MapHWIDToHostnameRequest) (*Void, error)
func (*UnimplementedDirectoryLookupServer) MapSessionIDsToIMSIs ¶
func (*UnimplementedDirectoryLookupServer) MapSessionIDsToIMSIs(context.Context, *MapSessionIDToIMSIRequest) (*Void, error)
type UnimplementedEventServiceServer ¶
type UnimplementedEventServiceServer struct { }
UnimplementedEventServiceServer can be embedded to have forward compatible implementations.
type UnimplementedGatewayDirectoryServiceServer ¶
type UnimplementedGatewayDirectoryServiceServer struct { }
UnimplementedGatewayDirectoryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedGatewayDirectoryServiceServer) DeleteRecord ¶
func (*UnimplementedGatewayDirectoryServiceServer) DeleteRecord(context.Context, *DeleteRecordRequest) (*Void, error)
func (*UnimplementedGatewayDirectoryServiceServer) GetAllDirectoryRecords ¶
func (*UnimplementedGatewayDirectoryServiceServer) GetAllDirectoryRecords(context.Context, *Void) (*AllDirectoryRecords, error)
func (*UnimplementedGatewayDirectoryServiceServer) GetDirectoryField ¶
func (*UnimplementedGatewayDirectoryServiceServer) GetDirectoryField(context.Context, *GetDirectoryFieldRequest) (*DirectoryField, error)
func (*UnimplementedGatewayDirectoryServiceServer) UpdateRecord ¶
func (*UnimplementedGatewayDirectoryServiceServer) UpdateRecord(context.Context, *UpdateRecordRequest) (*Void, error)
type UnimplementedMagmadServer ¶
type UnimplementedMagmadServer struct { }
UnimplementedMagmadServer can be embedded to have forward compatible implementations.
func (*UnimplementedMagmadServer) GenericCommand ¶
func (*UnimplementedMagmadServer) GenericCommand(context.Context, *GenericCommandParams) (*GenericCommandResponse, error)
func (*UnimplementedMagmadServer) GetConfigs ¶
func (*UnimplementedMagmadServer) GetConfigs(context.Context, *Void) (*GatewayConfigs, error)
func (*UnimplementedMagmadServer) GetGatewayId ¶
func (*UnimplementedMagmadServer) GetGatewayId(context.Context, *Void) (*GetGatewayIdResponse, error)
func (*UnimplementedMagmadServer) RestartServices ¶
func (*UnimplementedMagmadServer) RestartServices(context.Context, *RestartServicesRequest) (*Void, error)
func (*UnimplementedMagmadServer) RunNetworkTests ¶
func (*UnimplementedMagmadServer) RunNetworkTests(context.Context, *NetworkTestRequest) (*NetworkTestResponse, error)
func (*UnimplementedMagmadServer) SetConfigs ¶
func (*UnimplementedMagmadServer) SetConfigs(context.Context, *GatewayConfigs) (*Void, error)
func (*UnimplementedMagmadServer) StartServices ¶
func (*UnimplementedMagmadServer) StopServices ¶
func (*UnimplementedMagmadServer) TailLogs ¶
func (*UnimplementedMagmadServer) TailLogs(*TailLogsRequest, Magmad_TailLogsServer) error
type UnimplementedMetricsControllerServer ¶
type UnimplementedMetricsControllerServer struct { }
UnimplementedMetricsControllerServer can be embedded to have forward compatible implementations.
func (*UnimplementedMetricsControllerServer) Collect ¶
func (*UnimplementedMetricsControllerServer) Collect(context.Context, *MetricsContainer) (*Void, error)
func (*UnimplementedMetricsControllerServer) Push ¶
func (*UnimplementedMetricsControllerServer) Push(context.Context, *PushedMetricsContainer) (*Void, error)
type UnimplementedService303Server ¶
type UnimplementedService303Server struct { }
UnimplementedService303Server can be embedded to have forward compatible implementations.
func (*UnimplementedService303Server) GetMetrics ¶
func (*UnimplementedService303Server) GetMetrics(context.Context, *Void) (*MetricsContainer, error)
func (*UnimplementedService303Server) GetOperationalStates ¶
func (*UnimplementedService303Server) GetOperationalStates(context.Context, *Void) (*GetOperationalStatesResponse, error)
func (*UnimplementedService303Server) GetServiceInfo ¶
func (*UnimplementedService303Server) GetServiceInfo(context.Context, *Void) (*ServiceInfo, error)
func (*UnimplementedService303Server) ReloadServiceConfig ¶
func (*UnimplementedService303Server) ReloadServiceConfig(context.Context, *Void) (*ReloadConfigResponse, error)
func (*UnimplementedService303Server) SetLogLevel ¶
func (*UnimplementedService303Server) SetLogLevel(context.Context, *LogLevelMessage) (*Void, error)
func (*UnimplementedService303Server) SetLogVerbosity ¶
func (*UnimplementedService303Server) SetLogVerbosity(context.Context, *LogVerbosity) (*Void, error)
func (*UnimplementedService303Server) StopService ¶
type UnimplementedStateServiceServer ¶
type UnimplementedStateServiceServer struct { }
UnimplementedStateServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedStateServiceServer) DeleteStates ¶
func (*UnimplementedStateServiceServer) DeleteStates(context.Context, *DeleteStatesRequest) (*Void, error)
func (*UnimplementedStateServiceServer) GetStates ¶
func (*UnimplementedStateServiceServer) GetStates(context.Context, *GetStatesRequest) (*GetStatesResponse, error)
func (*UnimplementedStateServiceServer) ReportStates ¶
func (*UnimplementedStateServiceServer) ReportStates(context.Context, *ReportStatesRequest) (*ReportStatesResponse, error)
func (*UnimplementedStateServiceServer) SyncStates ¶
func (*UnimplementedStateServiceServer) SyncStates(context.Context, *SyncStatesRequest) (*SyncStatesResponse, error)
type UnimplementedStreamerServer ¶
type UnimplementedStreamerServer struct { }
UnimplementedStreamerServer can be embedded to have forward compatible implementations.
func (*UnimplementedStreamerServer) GetUpdates ¶
func (*UnimplementedStreamerServer) GetUpdates(*StreamRequest, Streamer_GetUpdatesServer) error
type UnimplementedSyncRPCServiceServer ¶
type UnimplementedSyncRPCServiceServer struct { }
UnimplementedSyncRPCServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedSyncRPCServiceServer) EstablishSyncRPCStream ¶
func (*UnimplementedSyncRPCServiceServer) EstablishSyncRPCStream(SyncRPCService_EstablishSyncRPCStreamServer) error
func (*UnimplementedSyncRPCServiceServer) SyncRPC ¶
func (*UnimplementedSyncRPCServiceServer) SyncRPC(SyncRPCService_SyncRPCServer) error
type UnimplementedTenantsServiceServer ¶
type UnimplementedTenantsServiceServer struct { }
UnimplementedTenantsServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTenantsServiceServer) CreateTenant ¶
func (*UnimplementedTenantsServiceServer) CreateTenant(context.Context, *IDAndTenant) (*Void, error)
func (*UnimplementedTenantsServiceServer) DeleteTenant ¶
func (*UnimplementedTenantsServiceServer) DeleteTenant(context.Context, *GetTenantRequest) (*Void, error)
func (*UnimplementedTenantsServiceServer) GetAllTenants ¶
func (*UnimplementedTenantsServiceServer) GetAllTenants(context.Context, *Void) (*TenantList, error)
func (*UnimplementedTenantsServiceServer) GetTenant ¶
func (*UnimplementedTenantsServiceServer) GetTenant(context.Context, *GetTenantRequest) (*Tenant, error)
func (*UnimplementedTenantsServiceServer) SetTenant ¶
func (*UnimplementedTenantsServiceServer) SetTenant(context.Context, *IDAndTenant) (*Void, error)
type UpdateRecordRequest ¶
type UpdateRecordRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` Fields map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateRecordRequest) Descriptor
deprecated
func (*UpdateRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRecordRequest.ProtoReflect.Descriptor instead.
func (*UpdateRecordRequest) GetFields ¶
func (x *UpdateRecordRequest) GetFields() map[string]string
func (*UpdateRecordRequest) GetId ¶
func (x *UpdateRecordRequest) GetId() string
func (*UpdateRecordRequest) GetLocation ¶
func (x *UpdateRecordRequest) GetLocation() string
func (*UpdateRecordRequest) ProtoMessage ¶
func (*UpdateRecordRequest) ProtoMessage()
func (*UpdateRecordRequest) ProtoReflect ¶
func (x *UpdateRecordRequest) ProtoReflect() protoreflect.Message
func (*UpdateRecordRequest) Reset ¶
func (x *UpdateRecordRequest) Reset()
func (*UpdateRecordRequest) String ¶
func (x *UpdateRecordRequest) String() string
type Void ¶
type Void struct {
// contains filtered or unexported fields
}
func (*Void) Descriptor
deprecated
func (*Void) ProtoMessage ¶
func (*Void) ProtoMessage()
func (*Void) ProtoReflect ¶
func (x *Void) ProtoReflect() protoreflect.Message
Source Files
¶
- bootstrapper.pb.go
- certifier.pb.go
- common.pb.go
- directoryd.pb.go
- directoryd_helper.go
- errors.go
- eventd.pb.go
- fillin.go
- gen.go
- identity.pb.go
- identity_helper.go
- magmad.pb.go
- marshaler.go
- mconfig.pb.go
- mconfig_digest.go
- metricsd.pb.go
- metricsd_helper.go
- redis.pb.go
- service303.pb.go
- service_status.pb.go
- state.pb.go
- streamer.pb.go
- sync_rpc_service.pb.go
- tenants.pb.go