protos

package module
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2020 License: BSD-3-Clause Imports: 25 Imported by: 114

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

View Source 
const MAGMA_ALT_NAME_TAG string = "magma_alt_name"

Go Struct tag to specify an alternative name for field name matching

Variables

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

View Source 
var (
	CertType_name = map[int32]string{
		0: "DEFAULT",
		1: "VPN",
	}
	CertType_value = map[string]int32{
		"DEFAULT": 0,
		"VPN":     1,
	}
)

Enum value maps for CertType.

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

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

View Source 
var (
	MetricName_name = map[int32]string{}/* 119 elements not displayed */

	MetricName_value = map[string]int32{}/* 119 elements not displayed */

)

Enum value maps for MetricName.

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

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

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

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

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

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

View Source 
var File_bootstrapper_proto protoreflect.FileDescriptor
View Source 
var File_certifier_proto protoreflect.FileDescriptor
View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_directoryd_proto protoreflect.FileDescriptor
View Source 
var File_eventd_proto protoreflect.FileDescriptor
View Source 
var File_identity_proto protoreflect.FileDescriptor
View Source 
var File_magmad_proto protoreflect.FileDescriptor
View Source 
var File_mconfig_proto protoreflect.FileDescriptor
View Source 
var File_metricsd_proto protoreflect.FileDescriptor
View Source 
var File_redis_proto protoreflect.FileDescriptor
View Source 
var File_service303_proto protoreflect.FileDescriptor
View Source 
var File_service_status_proto protoreflect.FileDescriptor
View Source 
var File_state_proto protoreflect.FileDescriptor
View Source 
var File_streamer_proto protoreflect.FileDescriptor
View Source 
var File_sync_rpc_service_proto protoreflect.FileDescriptor
View Source 
var File_tenants_proto protoreflect.FileDescriptor

Functions

func CreateTestIdentityImplValue 

func CreateTestIdentityImplValue() isIdentity_Value

func Errorf 

func Errorf(code codes.Code, format string, a ...interface{}) error

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 

func GetClientCertExpiration(ctx context.Context) int64

GetClientCertExpiration retreives from cxt & returns Unix time in seconds of client certificate expiration if present, 0 if not present

func GetDecodedLabel 

func GetDecodedLabel(m *dto.Metric) []*dto.LabelPair

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 

func GetEnumNameIfPossible(toConvert string,
	protoEnumMapping map[int32]string) string

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 

func GetHashToIdentity(ids []*Identity) map[string]*Identity

GetHashToIdentity converts the passed slice to a map, whose keys are the hash strings of each Identity proto.

func GetHashableIdentitiesTable 

func GetHashableIdentitiesTable() map[string]string

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 Marshal 

func Marshal(msg proto.Message) ([]byte, error)

func MarshalIntern 

func MarshalIntern(msg proto.Message) ([]byte, error)

func MarshalJSON 

func MarshalJSON(msg proto.Message) ([]byte, error)

func MarshalMconfig 

func MarshalMconfig(msg proto.Message) ([]byte, error)

MarshalMconfig is a special mconfig marshaler tolerant to unregistered Any types

func MarshalMconfigToString 

func MarshalMconfigToString(msg proto.Message) (string, error)

MarshalMconfigToString - same as MarshalMconfig but returns string

func NewContextWithCertExpiration 

func NewContextWithCertExpiration(ctx context.Context, certExp int64) context.Context

NewContextWithCertExpiration returns a new Context that carries the given certificate expiration time

func NewGrpcValidationError 

func NewGrpcValidationError(err error) error

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 

func TestMarshal(msg proto.Message) string

func Unmarshal 

func Unmarshal(bt []byte, msg proto.Message) error

func UnmarshalMconfig 

func UnmarshalMconfig(bt []byte, msg proto.Message) error

UnmarshalMconfig is a special mconfig Unmarshaler tolerant to unregistered Any types

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) Descriptor() ([]byte, []int)

Deprecated: Use Bytes.ProtoReflect.Descriptor instead.

func (*Bytes) GetVal 

func (x *Bytes) GetVal() []byte

func (*Bytes) MarshalJSONPB 

func (bm *Bytes) MarshalJSONPB(_ *jsonpb.Marshaler) ([]byte, error)

MarshalJSONPB implements JSONPBMarshaler interface for Bytes type

func (*Bytes) ProtoMessage 

func (*Bytes) ProtoMessage()

func (*Bytes) ProtoReflect 

func (x *Bytes) ProtoReflect() protoreflect.Message

func (*Bytes) Reset 

func (x *Bytes) Reset()

func (*Bytes) String 

func (x *Bytes) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use CACert.ProtoReflect.Descriptor instead.

func (*CACert) GetCert 

func (x *CACert) GetCert() []byte

func (*CACert) ProtoMessage 

func (*CACert) ProtoMessage()

func (*CACert) ProtoReflect 

func (x *CACert) ProtoReflect() protoreflect.Message

func (*CACert) Reset 

func (x *CACert) Reset()

func (*CACert) String 

func (x *CACert) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use CSR.ProtoReflect.Descriptor instead.

func (*CSR) GetCertType 

func (x *CSR) GetCertType() CertType

func (*CSR) GetCsrDer 

func (x *CSR) GetCsrDer() []byte

func (*CSR) GetId 

func (x *CSR) GetId() *Identity

func (*CSR) GetValidTime 

func (x *CSR) GetValidTime() *duration.Duration

func (*CSR) ProtoMessage 

func (*CSR) ProtoMessage()

func (*CSR) ProtoReflect 

func (x *CSR) ProtoReflect() protoreflect.Message

func (*CSR) Reset 

func (x *CSR) Reset()

func (*CSR) String 

func (x *CSR) String() string

type CertType 

type CertType int32
const (
	CertType_DEFAULT CertType = 0 // Bootstrap cert
	CertType_VPN     CertType = 1
)

func (CertType) Descriptor 

func (CertType) Descriptor() protoreflect.EnumDescriptor

func (CertType) Enum 

func (x CertType) Enum() *CertType

func (CertType) EnumDescriptor deprecated 

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

Deprecated: Use CertType.Descriptor instead.

func (CertType) Number 

func (x CertType) Number() protoreflect.EnumNumber

func (CertType) String 

func (x CertType) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Challenge.ProtoReflect.Descriptor instead.

func (*Challenge) GetChallenge 

func (x *Challenge) GetChallenge() []byte

func (*Challenge) GetKeyType 

func (x *Challenge) GetKeyType() ChallengeKey_KeyType

func (*Challenge) ProtoMessage 

func (*Challenge) ProtoMessage()

func (*Challenge) ProtoReflect 

func (x *Challenge) ProtoReflect() protoreflect.Message

func (*Challenge) Reset 

func (x *Challenge) Reset()

func (*Challenge) String 

func (x *Challenge) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEventType 

func (x *Event) GetEventType() string

func (*Event) GetStreamName 

func (x *Event) GetStreamName() string

func (*Event) GetTag 

func (x *Event) GetTag() string

func (*Event) GetValue 

func (x *Event) GetValue() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use IDList.ProtoReflect.Descriptor instead.

func (*IDList) GetIds 

func (x *IDList) GetIds() []string

func (*IDList) ProtoMessage 

func (*IDList) ProtoMessage()

func (*IDList) ProtoReflect 

func (x *IDList) ProtoReflect() protoreflect.Message

func (*IDList) Reset 

func (x *IDList) Reset()

func (*IDList) String 

func (x *IDList) String() string

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 

func GetClientIdentity(ctx context.Context) *Identity

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 

func NewGatewayIdentity(hwId, networkId, logicalId string) *Identity

NewGatewayIdentity returns Gateway identity corresponding to given hardware network & logical gateway IDs

func NewGatewayWildcardIdentity 

func NewGatewayWildcardIdentity() *Identity

NewGatewayWildcardIdentity returns Gateway wildcard Identity

func NewNetworkIdentity 

func NewNetworkIdentity(networkId string) *Identity

NewNetworkIdentity returns Network identity corresponding to given networkId

func NewNetworkWildcardIdentity 

func NewNetworkWildcardIdentity() *Identity

NewNetworkWildcardIdentity returns Network Wildcard Identity

func NewOperatorIdentity 

func NewOperatorIdentity(opId string) *Identity

NewOperatorIdentity returns Operator identity corresponding to given opId

func NewOperatorWildcardIdentity 

func NewOperatorWildcardIdentity() *Identity

NewOperatorWildcardIdentity returns Operator wildcard Identity

func (*Identity) Descriptor deprecated 

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

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetGateway 

func (x *Identity) GetGateway() *Identity_Gateway

func (*Identity) GetNetwork 

func (x *Identity) GetNetwork() string

func (*Identity) GetOperator 

func (x *Identity) GetOperator() string

func (*Identity) GetValue 

func (m *Identity) GetValue() isIdentity_Value

func (*Identity) GetWildcard 

func (x *Identity) GetWildcard() *Identity_Wildcard

func (*Identity) GetWildcardForIdentity 

func (id *Identity) GetWildcardForIdentity() *Identity

func (*Identity) HashString 

func (id *Identity) HashString() string

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 

func (wildcard *Identity) Match(entity *Identity) bool

A helper to verify if a given entity matches the wildcard pattern For now only match all (*) is supported

func (*Identity) NewContextWithIdentity 

func (id *Identity) NewContextWithIdentity(ctx context.Context) context.Context

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

func (x *Identity) Reset()

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 

func (id *Identity) SetNetwork(networkId string) *Identity

SetNetwork sets Identity to be given network identity (networkId) and returns the receiver (Identity pointer)

func (*Identity) SetOperator 

func (id *Identity) SetOperator(opId string) *Identity

SetOperator sets Identity to be given operator identity (opid) and returns the receiver (Identity pointer)

func (*Identity) String 

func (x *Identity) String() string

func (*Identity) ToCommonName 

func (id *Identity) ToCommonName() *string

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)

func (*Identity) TypeName 

func (id *Identity) TypeName() *string

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) Descriptor() ([]byte, []int)

Deprecated: Use LabelPair.ProtoReflect.Descriptor instead.

func (*LabelPair) GetName 

func (x *LabelPair) GetName() string

func (*LabelPair) GetValue 

func (x *LabelPair) GetValue() string

func (*LabelPair) ProtoMessage 

func (*LabelPair) ProtoMessage()

func (*LabelPair) ProtoReflect 

func (x *LabelPair) ProtoReflect() protoreflect.Message

func (*LabelPair) Reset 

func (x *LabelPair) Reset()

func (*LabelPair) String 

func (x *LabelPair) String() string

type LogLevel 

type LogLevel int32

-------------------------------------------------------------------------- Logging levels -------------------------------------------------------------------------- 

const (
	LogLevel_DEBUG   LogLevel = 0
	LogLevel_INFO    LogLevel = 1
	LogLevel_WARNING LogLevel = 2
	LogLevel_ERROR   LogLevel = 3
	LogLevel_FATAL   LogLevel = 4
)

func (LogLevel) Descriptor 

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated 

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

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number 

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String 

func (x LogLevel) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use LogLine.ProtoReflect.Descriptor instead.

func (*LogLine) GetLine 

func (x *LogLine) GetLine() string

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) ProtoReflect 

func (x *LogLine) ProtoReflect() protoreflect.Message

func (*LogLine) Reset 

func (x *LogLine) Reset()

func (*LogLine) String 

func (x *LogLine) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NetworkID.ProtoReflect.Descriptor instead.

func (*NetworkID) GetId 

func (x *NetworkID) GetId() string

func (*NetworkID) ProtoMessage 

func (*NetworkID) ProtoMessage()

func (*NetworkID) ProtoReflect 

func (x *NetworkID) ProtoReflect() protoreflect.Message

func (*NetworkID) Reset 

func (x *NetworkID) Reset()

func (*NetworkID) String 

func (x *NetworkID) String() string

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

func (x ReloadConfigResponse_ReloadConfigResult) Enum() *ReloadConfigResponse_ReloadConfigResult

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetChallenge 

func (x *Response) GetChallenge() []byte

func (*Response) GetCsr 

func (x *Response) GetCsr() *CSR

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetDeviceID 

func (x *State) GetDeviceID() string

func (*State) GetType 

func (x *State) GetType() string

func (*State) GetValue 

func (x *State) GetValue() []byte

func (*State) GetVersion 

func (x *State) GetVersion() uint64

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) ProtoReflect 

func (x *State) ProtoReflect() protoreflect.Message

func (*State) Reset 

func (x *State) Reset()

func (*State) String 

func (x *State) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use StateID.ProtoReflect.Descriptor instead.

func (*StateID) GetDeviceID 

func (x *StateID) GetDeviceID() string

func (*StateID) GetType 

func (x *StateID) GetType() string

func (*StateID) ProtoMessage 

func (*StateID) ProtoMessage()

func (*StateID) ProtoReflect 

func (x *StateID) ProtoReflect() protoreflect.Message

func (*StateID) Reset 

func (x *StateID) Reset()

func (*StateID) String 

func (x *StateID) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Tenant.ProtoReflect.Descriptor instead.

func (*Tenant) GetName 

func (x *Tenant) GetName() string

func (*Tenant) GetNetworks 

func (x *Tenant) GetNetworks() []string

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) ProtoReflect 

func (x *Tenant) ProtoReflect() protoreflect.Message

func (*Tenant) Reset 

func (x *Tenant) Reset()

func (*Tenant) String 

func (x *Tenant) String() string

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.

func (*UnimplementedEventServiceServer) LogEvent 

func (*UnimplementedEventServiceServer) LogEvent(context.Context, *Event) (*Void, error)

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

func (*UnimplementedMagmadServer) Reboot(context.Context, *Void) (*Void, 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) StartServices(context.Context, *Void) (*Void, error)

func (*UnimplementedMagmadServer) StopServices 

func (*UnimplementedMagmadServer) StopServices(context.Context, *Void) (*Void, error)

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 

func (*UnimplementedService303Server) StopService(context.Context, *Void) (*Void, error)

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) Descriptor() ([]byte, []int)

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) ProtoReflect 

func (x *Void) ProtoReflect() protoreflect.Message

func (*Void) Reset 

func (x *Void) Reset()

func (*Void) String 

func (x *Void) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.