topo

package
v0.7.60 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2021 License: Apache-2.0 Imports: 18 Imported by: 159

README

Topology Service: Go Bindings

This package provides Go bindings for the gRPC services implemented by the µONOS Topology service.

Documentation

Overview

Package topo is a generated GoMock package.

Index

Constants

View Source 
const (
	Address = "address"
	Target  = "target"
	Type    = "type"
	Version = "version"
	Timeout = "timeout"
	Role    = "role"
)

Attribute keys

View Source 
const NullID = ""

NullID ...

Variables

View Source 
var (
	ErrInvalidLengthConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRan        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRan          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRan = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTopo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTopo = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ChannelState_name = map[int32]string{
	0: "UNKNOWN_CHANNEL_STATE",
	1: "CONNECTED",
	2: "DISCONNECTED",
}
View Source 
var ChannelState_value = map[string]int32{
	"UNKNOWN_CHANNEL_STATE": 0,
	"CONNECTED":             1,
	"DISCONNECTED":          2,
}
View Source 
var ConnectivityState_name = map[int32]string{
	0: "UNKNOWN_CONNECTIVITY_STATE",
	1: "REACHABLE",
	2: "UNREACHABLE",
}
View Source 
var ConnectivityState_value = map[string]int32{
	"UNKNOWN_CONNECTIVITY_STATE": 0,
	"REACHABLE":                  1,
	"UNREACHABLE":                2,
}
View Source 
var EventType_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var EventType_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"UPDATED": 2,
	"REMOVED": 3,
}
View Source 
var Object_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "ENTITY",
	2: "RELATION",
	3: "KIND",
}
View Source 
var Object_Type_value = map[string]int32{
	"UNSPECIFIED": 0,
	"ENTITY":      1,
	"RELATION":    2,
	"KIND":        3,
}
View Source 
var Protocol_name = map[int32]string{
	0: "UNKNOWN_PROTOCOL",
	1: "GNMI",
	2: "P4RUNTIME",
	3: "GNOI",
	4: "E2AP",
}
View Source 
var Protocol_value = map[string]int32{
	"UNKNOWN_PROTOCOL": 0,
	"GNMI":             1,
	"P4RUNTIME":        2,
	"GNOI":             3,
	"E2AP":             4,
}
View Source 
var RANEntityKinds_name = map[int32]string{
	0: "E2NODE",
	1: "E2CELL",
}
View Source 
var RANEntityKinds_value = map[string]int32{
	"E2NODE": 0,
	"E2CELL": 1,
}
View Source 
var RANRelationKinds_name = map[int32]string{
	0: "CONTROLS",
	1: "CONTAINS",
	2: "NEIGHBORS",
}
View Source 
var RANRelationKinds_value = map[string]int32{
	"CONTROLS":  0,
	"CONTAINS":  1,
	"NEIGHBORS": 2,
}
View Source 
var ServiceState_name = map[int32]string{
	0: "UNKNOWN_SERVICE_STATE",
	1: "AVAILABLE",
	2: "UNAVAILABLE",
	3: "CONNECTING",
}
View Source 
var ServiceState_value = map[string]int32{
	"UNKNOWN_SERVICE_STATE": 0,
	"AVAILABLE":             1,
	"UNAVAILABLE":           2,
	"CONNECTING":            3,
}
View Source 
var TopoClientFactory = func(cc *grpc.ClientConn) TopoClient {
	return NewTopoClient(cc)
}

TopoClientFactory : Default EntityServiceClient creation.

Functions

func RegisterTopoServer 

func RegisterTopoServer(s *grpc.Server, srv TopoServer)

Types

type AdHoc added in v0.7.34 

type AdHoc struct {
	Properties map[string]string `` /* 161-byte string literal not displayed */
}

Aspect for ad-hoc properties

func (*AdHoc) Descriptor added in v0.7.34 

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

func (*AdHoc) GetProperties added in v0.7.34 

func (m *AdHoc) GetProperties() map[string]string

func (*AdHoc) Marshal added in v0.7.34 

func (m *AdHoc) Marshal() (dAtA []byte, err error)

func (*AdHoc) MarshalTo added in v0.7.34 

func (m *AdHoc) MarshalTo(dAtA []byte) (int, error)

func (*AdHoc) MarshalToSizedBuffer added in v0.7.34 

func (m *AdHoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AdHoc) ProtoMessage added in v0.7.34 

func (*AdHoc) ProtoMessage()

func (*AdHoc) Reset added in v0.7.34 

func (m *AdHoc) Reset()

func (*AdHoc) Size added in v0.7.34 

func (m *AdHoc) Size() (n int)

func (*AdHoc) String added in v0.7.34 

func (m *AdHoc) String() string

func (*AdHoc) Unmarshal added in v0.7.34 

func (m *AdHoc) Unmarshal(dAtA []byte) error

func (*AdHoc) XXX_DiscardUnknown added in v0.7.34 

func (m *AdHoc) XXX_DiscardUnknown()

func (*AdHoc) XXX_Marshal added in v0.7.34 

func (m *AdHoc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdHoc) XXX_Merge added in v0.7.34 

func (m *AdHoc) XXX_Merge(src proto.Message)

func (*AdHoc) XXX_Size added in v0.7.34 

func (m *AdHoc) XXX_Size() int

func (*AdHoc) XXX_Unmarshal added in v0.7.34 

func (m *AdHoc) XXX_Unmarshal(b []byte) error

type Asset added in v0.7.37 

type Asset struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Manufacturer string `protobuf:"bytes,2,opt,name=manufacturer,proto3" json:"manufacturer,omitempty"`
	Model        string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	Serial       string `protobuf:"bytes,4,opt,name=serial,proto3" json:"serial,omitempty"`
	Asset        string `protobuf:"bytes,5,opt,name=asset,proto3" json:"asset,omitempty"`
	SwVersion    string `protobuf:"bytes,6,opt,name=sw_version,json=swVersion,proto3" json:"sw_version,omitempty"`
	Role         string `protobuf:"bytes,8,opt,name=role,proto3" json:"role,omitempty"`
}

Basic asset information

func (*Asset) Descriptor added in v0.7.37 

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

func (*Asset) GetAsset added in v0.7.37 

func (m *Asset) GetAsset() string

func (*Asset) GetManufacturer added in v0.7.37 

func (m *Asset) GetManufacturer() string

func (*Asset) GetModel added in v0.7.37 

func (m *Asset) GetModel() string

func (*Asset) GetName added in v0.7.37 

func (m *Asset) GetName() string

func (*Asset) GetRole added in v0.7.37 

func (m *Asset) GetRole() string

func (*Asset) GetSerial added in v0.7.37 

func (m *Asset) GetSerial() string

func (*Asset) GetSwVersion added in v0.7.37 

func (m *Asset) GetSwVersion() string

func (*Asset) Marshal added in v0.7.37 

func (m *Asset) Marshal() (dAtA []byte, err error)

func (*Asset) MarshalTo added in v0.7.37 

func (m *Asset) MarshalTo(dAtA []byte) (int, error)

func (*Asset) MarshalToSizedBuffer added in v0.7.37 

func (m *Asset) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Asset) ProtoMessage added in v0.7.37 

func (*Asset) ProtoMessage()

func (*Asset) Reset added in v0.7.37 

func (m *Asset) Reset()

func (*Asset) Size added in v0.7.37 

func (m *Asset) Size() (n int)

func (*Asset) String added in v0.7.37 

func (m *Asset) String() string

func (*Asset) Unmarshal added in v0.7.37 

func (m *Asset) Unmarshal(dAtA []byte) error

func (*Asset) XXX_DiscardUnknown added in v0.7.37 

func (m *Asset) XXX_DiscardUnknown()

func (*Asset) XXX_Marshal added in v0.7.37 

func (m *Asset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Asset) XXX_Merge added in v0.7.37 

func (m *Asset) XXX_Merge(src proto.Message)

func (*Asset) XXX_Size added in v0.7.37 

func (m *Asset) XXX_Size() int

func (*Asset) XXX_Unmarshal added in v0.7.37 

func (m *Asset) XXX_Unmarshal(b []byte) error

type ChannelState 

type ChannelState int32

ConnectivityState represents the state of a gRPC channel to the device from the service container 

const (
	//UNKNOWN_CHANNEL_STATE constant needed to go around proto3 nullifying the 0 values
	ChannelState_UNKNOWN_CHANNEL_STATE ChannelState = 0
	// CONNECTED indicates the corresponding grpc channel is connected on this device
	ChannelState_CONNECTED ChannelState = 1
	// DISCONNECTED indicates the corresponding grpc channel is not connected on this device
	ChannelState_DISCONNECTED ChannelState = 2
)

func (ChannelState) EnumDescriptor 

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

func (ChannelState) String 

func (x ChannelState) String() string

type Configurable added in v0.7.34 

type Configurable struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Target  string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Timeout uint64 `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

Configurable device aspect

func (*Configurable) Descriptor added in v0.7.34 

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

func (*Configurable) GetAddress added in v0.7.34 

func (m *Configurable) GetAddress() string

func (*Configurable) GetTarget added in v0.7.34 

func (m *Configurable) GetTarget() string

func (*Configurable) GetTimeout added in v0.7.34 

func (m *Configurable) GetTimeout() uint64

func (*Configurable) GetType added in v0.7.34 

func (m *Configurable) GetType() string

func (*Configurable) GetVersion added in v0.7.34 

func (m *Configurable) GetVersion() string

func (*Configurable) Marshal added in v0.7.34 

func (m *Configurable) Marshal() (dAtA []byte, err error)

func (*Configurable) MarshalTo added in v0.7.34 

func (m *Configurable) MarshalTo(dAtA []byte) (int, error)

func (*Configurable) MarshalToSizedBuffer added in v0.7.34 

func (m *Configurable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Configurable) ProtoMessage added in v0.7.34 

func (*Configurable) ProtoMessage()

func (*Configurable) Reset added in v0.7.34 

func (m *Configurable) Reset()

func (*Configurable) Size added in v0.7.34 

func (m *Configurable) Size() (n int)

func (*Configurable) String added in v0.7.34 

func (m *Configurable) String() string

func (*Configurable) Unmarshal added in v0.7.34 

func (m *Configurable) Unmarshal(dAtA []byte) error

func (*Configurable) XXX_DiscardUnknown added in v0.7.34 

func (m *Configurable) XXX_DiscardUnknown()

func (*Configurable) XXX_Marshal added in v0.7.34 

func (m *Configurable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configurable) XXX_Merge added in v0.7.34 

func (m *Configurable) XXX_Merge(src proto.Message)

func (*Configurable) XXX_Size added in v0.7.34 

func (m *Configurable) XXX_Size() int

func (*Configurable) XXX_Unmarshal added in v0.7.34 

func (m *Configurable) XXX_Unmarshal(b []byte) error

type ConnectivityState 

type ConnectivityState int32

ConnectivityState represents the L3 reachability of a device from the service container (e.g. enos-config), independently of gRPC or the service itself (e.g. gNMI) 

const (
	//UNKNOWN_CONNECTIVITY_STATE constant needed to go around proto3 nullifying the 0 values
	ConnectivityState_UNKNOWN_CONNECTIVITY_STATE ConnectivityState = 0
	// REACHABLE indicates the the service can reach the device at L3
	ConnectivityState_REACHABLE ConnectivityState = 1
	// UNREACHABLE indicates the the service can't reach the device at L3
	ConnectivityState_UNREACHABLE ConnectivityState = 2
)

func (ConnectivityState) EnumDescriptor 

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

func (ConnectivityState) String 

func (x ConnectivityState) String() string

type Coverage added in v0.7.34 

type Coverage struct {
	Height   int32 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	ArcWidth int32 `protobuf:"varint,2,opt,name=arc_width,json=arcWidth,proto3" json:"arc_width,omitempty"`
	Azimuth  int32 `protobuf:"varint,3,opt,name=azimuth,proto3" json:"azimuth,omitempty"`
	Tilt     int32 `protobuf:"varint,4,opt,name=tilt,proto3" json:"tilt,omitempty"`
}

Area of coverage; expected value type of "coverage" aspect

func (*Coverage) Descriptor added in v0.7.34 

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

func (*Coverage) GetArcWidth added in v0.7.34 

func (m *Coverage) GetArcWidth() int32

func (*Coverage) GetAzimuth added in v0.7.34 

func (m *Coverage) GetAzimuth() int32

func (*Coverage) GetHeight added in v0.7.34 

func (m *Coverage) GetHeight() int32

func (*Coverage) GetTilt added in v0.7.34 

func (m *Coverage) GetTilt() int32

func (*Coverage) Marshal added in v0.7.34 

func (m *Coverage) Marshal() (dAtA []byte, err error)

func (*Coverage) MarshalTo added in v0.7.34 

func (m *Coverage) MarshalTo(dAtA []byte) (int, error)

func (*Coverage) MarshalToSizedBuffer added in v0.7.34 

func (m *Coverage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Coverage) ProtoMessage added in v0.7.34 

func (*Coverage) ProtoMessage()

func (*Coverage) Reset added in v0.7.34 

func (m *Coverage) Reset()

func (*Coverage) Size added in v0.7.34 

func (m *Coverage) Size() (n int)

func (*Coverage) String added in v0.7.34 

func (m *Coverage) String() string

func (*Coverage) Unmarshal added in v0.7.34 

func (m *Coverage) Unmarshal(dAtA []byte) error

func (*Coverage) XXX_DiscardUnknown added in v0.7.34 

func (m *Coverage) XXX_DiscardUnknown()

func (*Coverage) XXX_Marshal added in v0.7.34 

func (m *Coverage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Coverage) XXX_Merge added in v0.7.34 

func (m *Coverage) XXX_Merge(src proto.Message)

func (*Coverage) XXX_Size added in v0.7.34 

func (m *Coverage) XXX_Size() int

func (*Coverage) XXX_Unmarshal added in v0.7.34 

func (m *Coverage) XXX_Unmarshal(b []byte) error

type CreateRequest 

type CreateRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetObject 

func (m *CreateRequest) GetObject() *Object

func (*CreateRequest) Marshal 

func (m *CreateRequest) Marshal() (dAtA []byte, err error)

func (*CreateRequest) MarshalTo 

func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateRequest) MarshalToSizedBuffer 

func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) Size 

func (m *CreateRequest) Size() (n int)

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) Unmarshal 

func (m *CreateRequest) Unmarshal(dAtA []byte) error

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRequest) XXX_Merge 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

type CreateResponse 

type CreateResponse struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) GetObject 

func (m *CreateResponse) GetObject() *Object

func (*CreateResponse) Marshal 

func (m *CreateResponse) Marshal() (dAtA []byte, err error)

func (*CreateResponse) MarshalTo 

func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)

func (*CreateResponse) MarshalToSizedBuffer 

func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) Size 

func (m *CreateResponse) Size() (n int)

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) Unmarshal 

func (m *CreateResponse) Unmarshal(dAtA []byte) error

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateResponse) XXX_Merge 

func (m *CreateResponse) XXX_Merge(src proto.Message)

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

func (m *CreateResponse) XXX_Unmarshal(b []byte) error

type DeleteRequest 

type DeleteRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetID 

func (m *DeleteRequest) GetID() ID

func (*DeleteRequest) Marshal 

func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRequest) MarshalTo 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToSizedBuffer 

func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

func (m *DeleteRequest) Unmarshal(dAtA []byte) error

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge 

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DeleteResponse 

type DeleteResponse struct {
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) Marshal 

func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

func (*DeleteResponse) MarshalTo 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToSizedBuffer 

func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

func (m *DeleteResponse) Unmarshal(dAtA []byte) error

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteResponse) XXX_Merge 

func (m *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

func (m *DeleteResponse) XXX_Unmarshal(b []byte) error

type E2Cell added in v0.7.34 

type E2Cell struct {
	CellObjectID string `protobuf:"bytes,1,opt,name=cell_object_id,json=cellObjectId,proto3" json:"cell_object_id,omitempty"`
	AntennaCount uint32 `protobuf:"varint,2,opt,name=antenna_count,json=antennaCount,proto3" json:"antenna_count,omitempty"`
	EARFCN       uint32 `protobuf:"varint,3,opt,name=earfcn,proto3" json:"earfcn,omitempty"`
	CellType     string `protobuf:"bytes,4,opt,name=cell_type,json=cellType,proto3" json:"cell_type,omitempty"`
	PCI          uint32 `protobuf:"varint,5,opt,name=pci,proto3" json:"pci,omitempty"`
}

E2Cell aspect; expected value type of "E2CELL" aspect and expected on entities of "E2CELL" kind

func (*E2Cell) Descriptor added in v0.7.34 

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

func (*E2Cell) GetAntennaCount added in v0.7.34 

func (m *E2Cell) GetAntennaCount() uint32

func (*E2Cell) GetCellObjectID added in v0.7.58 

func (m *E2Cell) GetCellObjectID() string

func (*E2Cell) GetCellType added in v0.7.34 

func (m *E2Cell) GetCellType() string

func (*E2Cell) GetEARFCN added in v0.7.34 

func (m *E2Cell) GetEARFCN() uint32

func (*E2Cell) GetPCI added in v0.7.58 

func (m *E2Cell) GetPCI() uint32

func (*E2Cell) Marshal added in v0.7.34 

func (m *E2Cell) Marshal() (dAtA []byte, err error)

func (*E2Cell) MarshalTo added in v0.7.34 

func (m *E2Cell) MarshalTo(dAtA []byte) (int, error)

func (*E2Cell) MarshalToSizedBuffer added in v0.7.34 

func (m *E2Cell) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*E2Cell) ProtoMessage added in v0.7.34 

func (*E2Cell) ProtoMessage()

func (*E2Cell) Reset added in v0.7.34 

func (m *E2Cell) Reset()

func (*E2Cell) Size added in v0.7.34 

func (m *E2Cell) Size() (n int)

func (*E2Cell) String added in v0.7.34 

func (m *E2Cell) String() string

func (*E2Cell) Unmarshal added in v0.7.34 

func (m *E2Cell) Unmarshal(dAtA []byte) error

func (*E2Cell) XXX_DiscardUnknown added in v0.7.34 

func (m *E2Cell) XXX_DiscardUnknown()

func (*E2Cell) XXX_Marshal added in v0.7.34 

func (m *E2Cell) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*E2Cell) XXX_Merge added in v0.7.34 

func (m *E2Cell) XXX_Merge(src proto.Message)

func (*E2Cell) XXX_Size added in v0.7.34 

func (m *E2Cell) XXX_Size() int

func (*E2Cell) XXX_Unmarshal added in v0.7.34 

func (m *E2Cell) XXX_Unmarshal(b []byte) error

type E2Node added in v0.7.34 

type E2Node struct {
	ServiceModels map[string]*ServiceModelInfo `` /* 188-byte string literal not displayed */
}

E2Node aspect; expected value type of "E2NODE" aspect and expected on entities of "E2NODE" kind

func (*E2Node) Descriptor added in v0.7.34 

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

func (*E2Node) GetServiceModels added in v0.7.34 

func (m *E2Node) GetServiceModels() map[string]*ServiceModelInfo

func (*E2Node) Marshal added in v0.7.34 

func (m *E2Node) Marshal() (dAtA []byte, err error)

func (*E2Node) MarshalTo added in v0.7.34 

func (m *E2Node) MarshalTo(dAtA []byte) (int, error)

func (*E2Node) MarshalToSizedBuffer added in v0.7.34 

func (m *E2Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*E2Node) ProtoMessage added in v0.7.34 

func (*E2Node) ProtoMessage()

func (*E2Node) Reset added in v0.7.34 

func (m *E2Node) Reset()

func (*E2Node) Size added in v0.7.34 

func (m *E2Node) Size() (n int)

func (*E2Node) String added in v0.7.34 

func (m *E2Node) String() string

func (*E2Node) Unmarshal added in v0.7.34 

func (m *E2Node) Unmarshal(dAtA []byte) error

func (*E2Node) XXX_DiscardUnknown added in v0.7.34 

func (m *E2Node) XXX_DiscardUnknown()

func (*E2Node) XXX_Marshal added in v0.7.34 

func (m *E2Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*E2Node) XXX_Merge added in v0.7.34 

func (m *E2Node) XXX_Merge(src proto.Message)

func (*E2Node) XXX_Size added in v0.7.34 

func (m *E2Node) XXX_Size() int

func (*E2Node) XXX_Unmarshal added in v0.7.34 

func (m *E2Node) XXX_Unmarshal(b []byte) error

type Entity 

type Entity struct {
	// user-defined entity kind
	KindID ID `protobuf:"bytes,1,opt,name=kind_id,json=kindId,proto3,casttype=ID" json:"kind_id,omitempty"`
}

Entity represents any "thing" that is represented in the topology

func (*Entity) Descriptor 

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

func (*Entity) GetKindID 

func (m *Entity) GetKindID() ID

func (*Entity) Marshal 

func (m *Entity) Marshal() (dAtA []byte, err error)

func (*Entity) MarshalTo 

func (m *Entity) MarshalTo(dAtA []byte) (int, error)

func (*Entity) MarshalToSizedBuffer 

func (m *Entity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) Size 

func (m *Entity) Size() (n int)

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) Unmarshal 

func (m *Entity) Unmarshal(dAtA []byte) error

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entity) XXX_Merge 

func (m *Entity) XXX_Merge(src proto.Message)

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

func (m *Entity) XXX_Unmarshal(b []byte) error

type EqualFilter added in v0.7.42 

type EqualFilter struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*EqualFilter) Descriptor added in v0.7.42 

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

func (*EqualFilter) GetValue added in v0.7.42 

func (m *EqualFilter) GetValue() string

func (*EqualFilter) Marshal added in v0.7.42 

func (m *EqualFilter) Marshal() (dAtA []byte, err error)

func (*EqualFilter) MarshalTo added in v0.7.42 

func (m *EqualFilter) MarshalTo(dAtA []byte) (int, error)

func (*EqualFilter) MarshalToSizedBuffer added in v0.7.42 

func (m *EqualFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EqualFilter) ProtoMessage added in v0.7.42 

func (*EqualFilter) ProtoMessage()

func (*EqualFilter) Reset added in v0.7.42 

func (m *EqualFilter) Reset()

func (*EqualFilter) Size added in v0.7.42 

func (m *EqualFilter) Size() (n int)

func (*EqualFilter) String added in v0.7.42 

func (m *EqualFilter) String() string

func (*EqualFilter) Unmarshal added in v0.7.42 

func (m *EqualFilter) Unmarshal(dAtA []byte) error

func (*EqualFilter) XXX_DiscardUnknown added in v0.7.42 

func (m *EqualFilter) XXX_DiscardUnknown()

func (*EqualFilter) XXX_Marshal added in v0.7.42 

func (m *EqualFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EqualFilter) XXX_Merge added in v0.7.42 

func (m *EqualFilter) XXX_Merge(src proto.Message)

func (*EqualFilter) XXX_Size added in v0.7.42 

func (m *EqualFilter) XXX_Size() int

func (*EqualFilter) XXX_Unmarshal added in v0.7.42 

func (m *EqualFilter) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	Type   EventType `protobuf:"varint,1,opt,name=type,proto3,enum=onos.topo.EventType" json:"type,omitempty"`
	Object Object    `protobuf:"bytes,2,opt,name=object,proto3" json:"object"`
}

Event is a topo operation event

func (*Event) Descriptor 

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

func (*Event) GetObject 

func (m *Event) GetObject() Object

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventType 

type EventType int32

EventType is a topo operation event type 

const (
	EventType_NONE    EventType = 0
	EventType_ADDED   EventType = 1
	EventType_UPDATED EventType = 2
	EventType_REMOVED EventType = 3
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type Filter added in v0.7.42 

type Filter struct {
	// Types that are valid to be assigned to Filter:
	//	*Filter_Equal_
	//	*Filter_Not
	//	*Filter_In
	Filter isFilter_Filter `protobuf_oneof:"filter"`
	Key    string          `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
}

func (*Filter) Descriptor added in v0.7.42 

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

func (*Filter) GetEqual_ added in v0.7.42 

func (m *Filter) GetEqual_() *EqualFilter

func (*Filter) GetFilter added in v0.7.42 

func (m *Filter) GetFilter() isFilter_Filter

func (*Filter) GetIn added in v0.7.42 

func (m *Filter) GetIn() *InFilter

func (*Filter) GetKey added in v0.7.42 

func (m *Filter) GetKey() string

func (*Filter) GetNot added in v0.7.42 

func (m *Filter) GetNot() *NotFilter

func (*Filter) Marshal added in v0.7.42 

func (m *Filter) Marshal() (dAtA []byte, err error)

func (*Filter) MarshalTo added in v0.7.42 

func (m *Filter) MarshalTo(dAtA []byte) (int, error)

func (*Filter) MarshalToSizedBuffer added in v0.7.42 

func (m *Filter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter) ProtoMessage added in v0.7.42 

func (*Filter) ProtoMessage()

func (*Filter) Reset added in v0.7.42 

func (m *Filter) Reset()

func (*Filter) Size added in v0.7.42 

func (m *Filter) Size() (n int)

func (*Filter) String added in v0.7.42 

func (m *Filter) String() string

func (*Filter) Unmarshal added in v0.7.42 

func (m *Filter) Unmarshal(dAtA []byte) error

func (*Filter) XXX_DiscardUnknown added in v0.7.42 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal added in v0.7.42 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge added in v0.7.42 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_OneofWrappers added in v0.7.42 

func (*Filter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Filter) XXX_Size added in v0.7.42 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal added in v0.7.42 

func (m *Filter) XXX_Unmarshal(b []byte) error

type Filter_Equal_ added in v0.7.42 

type Filter_Equal_ struct {
	Equal_ *EqualFilter `protobuf:"bytes,1,opt,name=equal,proto3,oneof" json:"equal,omitempty"`
}

func (*Filter_Equal_) MarshalTo added in v0.7.42 

func (m *Filter_Equal_) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Equal_) MarshalToSizedBuffer added in v0.7.42 

func (m *Filter_Equal_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_Equal_) Size added in v0.7.42 

func (m *Filter_Equal_) Size() (n int)

type Filter_In added in v0.7.42 

type Filter_In struct {
	In *InFilter `protobuf:"bytes,3,opt,name=in,proto3,oneof" json:"in,omitempty"`
}

func (*Filter_In) MarshalTo added in v0.7.42 

func (m *Filter_In) MarshalTo(dAtA []byte) (int, error)

func (*Filter_In) MarshalToSizedBuffer added in v0.7.42 

func (m *Filter_In) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_In) Size added in v0.7.42 

func (m *Filter_In) Size() (n int)

type Filter_Not added in v0.7.42 

type Filter_Not struct {
	Not *NotFilter `protobuf:"bytes,2,opt,name=not,proto3,oneof" json:"not,omitempty"`
}

func (*Filter_Not) MarshalTo added in v0.7.42 

func (m *Filter_Not) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Not) MarshalToSizedBuffer added in v0.7.42 

func (m *Filter_Not) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_Not) Size added in v0.7.42 

func (m *Filter_Not) Size() (n int)

type Filters added in v0.7.42 

type Filters struct {
	KindFilters  []*Filter `protobuf:"bytes,1,rep,name=kind_filters,json=kindFilters,proto3" json:"kind_filters,omitempty"`
	LabelFilters []*Filter `protobuf:"bytes,2,rep,name=label_filters,json=labelFilters,proto3" json:"label_filters,omitempty"`
}

func (*Filters) Descriptor added in v0.7.42 

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

func (*Filters) GetKindFilters added in v0.7.42 

func (m *Filters) GetKindFilters() []*Filter

func (*Filters) GetLabelFilters added in v0.7.42 

func (m *Filters) GetLabelFilters() []*Filter

func (*Filters) Marshal added in v0.7.42 

func (m *Filters) Marshal() (dAtA []byte, err error)

func (*Filters) MarshalTo added in v0.7.42 

func (m *Filters) MarshalTo(dAtA []byte) (int, error)

func (*Filters) MarshalToSizedBuffer added in v0.7.42 

func (m *Filters) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filters) ProtoMessage added in v0.7.42 

func (*Filters) ProtoMessage()

func (*Filters) Reset added in v0.7.42 

func (m *Filters) Reset()

func (*Filters) Size added in v0.7.42 

func (m *Filters) Size() (n int)

func (*Filters) String added in v0.7.42 

func (m *Filters) String() string

func (*Filters) Unmarshal added in v0.7.42 

func (m *Filters) Unmarshal(dAtA []byte) error

func (*Filters) XXX_DiscardUnknown added in v0.7.42 

func (m *Filters) XXX_DiscardUnknown()

func (*Filters) XXX_Marshal added in v0.7.42 

func (m *Filters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filters) XXX_Merge added in v0.7.42 

func (m *Filters) XXX_Merge(src proto.Message)

func (*Filters) XXX_Size added in v0.7.42 

func (m *Filters) XXX_Size() int

func (*Filters) XXX_Unmarshal added in v0.7.42 

func (m *Filters) XXX_Unmarshal(b []byte) error

type GetRequest 

type GetRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetID 

func (m *GetRequest) GetID() ID

func (*GetRequest) Marshal 

func (m *GetRequest) Marshal() (dAtA []byte, err error)

func (*GetRequest) MarshalTo 

func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRequest) MarshalToSizedBuffer 

func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

func (m *GetRequest) Size() (n int)

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

func (m *GetRequest) Unmarshal(dAtA []byte) error

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge 

func (m *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

type GetResponse 

type GetResponse struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetObject 

func (m *GetResponse) GetObject() *Object

func (*GetResponse) Marshal 

func (m *GetResponse) Marshal() (dAtA []byte, err error)

func (*GetResponse) MarshalTo 

func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetResponse) MarshalToSizedBuffer 

func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

func (m *GetResponse) Size() (n int)

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

func (m *GetResponse) Unmarshal(dAtA []byte) error

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResponse) XXX_Merge 

func (m *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

func (m *GetResponse) XXX_Unmarshal(b []byte) error

type ID 

type ID string

ID ...

type InFilter added in v0.7.42 

type InFilter struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*InFilter) Descriptor added in v0.7.42 

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

func (*InFilter) GetValues added in v0.7.42 

func (m *InFilter) GetValues() []string

func (*InFilter) Marshal added in v0.7.42 

func (m *InFilter) Marshal() (dAtA []byte, err error)

func (*InFilter) MarshalTo added in v0.7.42 

func (m *InFilter) MarshalTo(dAtA []byte) (int, error)

func (*InFilter) MarshalToSizedBuffer added in v0.7.42 

func (m *InFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InFilter) ProtoMessage added in v0.7.42 

func (*InFilter) ProtoMessage()

func (*InFilter) Reset added in v0.7.42 

func (m *InFilter) Reset()

func (*InFilter) Size added in v0.7.42 

func (m *InFilter) Size() (n int)

func (*InFilter) String added in v0.7.42 

func (m *InFilter) String() string

func (*InFilter) Unmarshal added in v0.7.42 

func (m *InFilter) Unmarshal(dAtA []byte) error

func (*InFilter) XXX_DiscardUnknown added in v0.7.42 

func (m *InFilter) XXX_DiscardUnknown()

func (*InFilter) XXX_Marshal added in v0.7.42 

func (m *InFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InFilter) XXX_Merge added in v0.7.42 

func (m *InFilter) XXX_Merge(src proto.Message)

func (*InFilter) XXX_Size added in v0.7.42 

func (m *InFilter) XXX_Size() int

func (*InFilter) XXX_Unmarshal added in v0.7.42 

func (m *InFilter) XXX_Unmarshal(b []byte) error

type KPMMeasurement added in v0.7.34 

type KPMMeasurement struct {
	ID   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*KPMMeasurement) Descriptor added in v0.7.34 

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

func (*KPMMeasurement) GetID added in v0.7.34 

func (m *KPMMeasurement) GetID() string

func (*KPMMeasurement) GetName added in v0.7.34 

func (m *KPMMeasurement) GetName() string

func (*KPMMeasurement) Marshal added in v0.7.34 

func (m *KPMMeasurement) Marshal() (dAtA []byte, err error)

func (*KPMMeasurement) MarshalTo added in v0.7.34 

func (m *KPMMeasurement) MarshalTo(dAtA []byte) (int, error)

func (*KPMMeasurement) MarshalToSizedBuffer added in v0.7.34 

func (m *KPMMeasurement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KPMMeasurement) ProtoMessage added in v0.7.34 

func (*KPMMeasurement) ProtoMessage()

func (*KPMMeasurement) Reset added in v0.7.34 

func (m *KPMMeasurement) Reset()

func (*KPMMeasurement) Size added in v0.7.34 

func (m *KPMMeasurement) Size() (n int)

func (*KPMMeasurement) String added in v0.7.34 

func (m *KPMMeasurement) String() string

func (*KPMMeasurement) Unmarshal added in v0.7.34 

func (m *KPMMeasurement) Unmarshal(dAtA []byte) error

func (*KPMMeasurement) XXX_DiscardUnknown added in v0.7.34 

func (m *KPMMeasurement) XXX_DiscardUnknown()

func (*KPMMeasurement) XXX_Marshal added in v0.7.34 

func (m *KPMMeasurement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KPMMeasurement) XXX_Merge added in v0.7.34 

func (m *KPMMeasurement) XXX_Merge(src proto.Message)

func (*KPMMeasurement) XXX_Size added in v0.7.34 

func (m *KPMMeasurement) XXX_Size() int

func (*KPMMeasurement) XXX_Unmarshal added in v0.7.34 

func (m *KPMMeasurement) XXX_Unmarshal(b []byte) error

type KPMRanFunction added in v0.7.34 

type KPMRanFunction struct {
	ID           string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ReportStyles []*KPMReportStyle `protobuf:"bytes,2,rep,name=report_styles,json=reportStyles,proto3" json:"report_styles,omitempty"`
}

func (*KPMRanFunction) Descriptor added in v0.7.34 

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

func (*KPMRanFunction) GetID added in v0.7.34 

func (m *KPMRanFunction) GetID() string

func (*KPMRanFunction) GetReportStyles added in v0.7.58 

func (m *KPMRanFunction) GetReportStyles() []*KPMReportStyle

func (*KPMRanFunction) Marshal added in v0.7.34 

func (m *KPMRanFunction) Marshal() (dAtA []byte, err error)

func (*KPMRanFunction) MarshalTo added in v0.7.34 

func (m *KPMRanFunction) MarshalTo(dAtA []byte) (int, error)

func (*KPMRanFunction) MarshalToSizedBuffer added in v0.7.34 

func (m *KPMRanFunction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KPMRanFunction) ProtoMessage added in v0.7.34 

func (*KPMRanFunction) ProtoMessage()

func (*KPMRanFunction) Reset added in v0.7.34 

func (m *KPMRanFunction) Reset()

func (*KPMRanFunction) Size added in v0.7.34 

func (m *KPMRanFunction) Size() (n int)

func (*KPMRanFunction) String added in v0.7.34 

func (m *KPMRanFunction) String() string

func (*KPMRanFunction) Unmarshal added in v0.7.34 

func (m *KPMRanFunction) Unmarshal(dAtA []byte) error

func (*KPMRanFunction) XXX_DiscardUnknown added in v0.7.34 

func (m *KPMRanFunction) XXX_DiscardUnknown()

func (*KPMRanFunction) XXX_Marshal added in v0.7.34 

func (m *KPMRanFunction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KPMRanFunction) XXX_Merge added in v0.7.34 

func (m *KPMRanFunction) XXX_Merge(src proto.Message)

func (*KPMRanFunction) XXX_Size added in v0.7.34 

func (m *KPMRanFunction) XXX_Size() int

func (*KPMRanFunction) XXX_Unmarshal added in v0.7.34 

func (m *KPMRanFunction) XXX_Unmarshal(b []byte) error

type KPMReportStyle added in v0.7.58 

type KPMReportStyle struct {
	Name         string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type         int32             `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Measurements []*KPMMeasurement `protobuf:"bytes,3,rep,name=measurements,proto3" json:"measurements,omitempty"`
}

func (*KPMReportStyle) Descriptor added in v0.7.58 

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

func (*KPMReportStyle) GetMeasurements added in v0.7.58 

func (m *KPMReportStyle) GetMeasurements() []*KPMMeasurement

func (*KPMReportStyle) GetName added in v0.7.58 

func (m *KPMReportStyle) GetName() string

func (*KPMReportStyle) GetType added in v0.7.58 

func (m *KPMReportStyle) GetType() int32

func (*KPMReportStyle) Marshal added in v0.7.58 

func (m *KPMReportStyle) Marshal() (dAtA []byte, err error)

func (*KPMReportStyle) MarshalTo added in v0.7.58 

func (m *KPMReportStyle) MarshalTo(dAtA []byte) (int, error)

func (*KPMReportStyle) MarshalToSizedBuffer added in v0.7.58 

func (m *KPMReportStyle) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KPMReportStyle) ProtoMessage added in v0.7.58 

func (*KPMReportStyle) ProtoMessage()

func (*KPMReportStyle) Reset added in v0.7.58 

func (m *KPMReportStyle) Reset()

func (*KPMReportStyle) Size added in v0.7.58 

func (m *KPMReportStyle) Size() (n int)

func (*KPMReportStyle) String added in v0.7.58 

func (m *KPMReportStyle) String() string

func (*KPMReportStyle) Unmarshal added in v0.7.58 

func (m *KPMReportStyle) Unmarshal(dAtA []byte) error

func (*KPMReportStyle) XXX_DiscardUnknown added in v0.7.58 

func (m *KPMReportStyle) XXX_DiscardUnknown()

func (*KPMReportStyle) XXX_Marshal added in v0.7.58 

func (m *KPMReportStyle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KPMReportStyle) XXX_Merge added in v0.7.58 

func (m *KPMReportStyle) XXX_Merge(src proto.Message)

func (*KPMReportStyle) XXX_Size added in v0.7.58 

func (m *KPMReportStyle) XXX_Size() int

func (*KPMReportStyle) XXX_Unmarshal added in v0.7.58 

func (m *KPMReportStyle) XXX_Unmarshal(b []byte) error

type Kind 

type Kind struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

Kind represents an archetype of an object, i.e. entity or relation

func (*Kind) Descriptor 

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

func (*Kind) GetName 

func (m *Kind) GetName() string

func (*Kind) Marshal 

func (m *Kind) Marshal() (dAtA []byte, err error)

func (*Kind) MarshalTo 

func (m *Kind) MarshalTo(dAtA []byte) (int, error)

func (*Kind) MarshalToSizedBuffer 

func (m *Kind) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Kind) ProtoMessage 

func (*Kind) ProtoMessage()

func (*Kind) Reset 

func (m *Kind) Reset()

func (*Kind) Size 

func (m *Kind) Size() (n int)

func (*Kind) String 

func (m *Kind) String() string

func (*Kind) Unmarshal 

func (m *Kind) Unmarshal(dAtA []byte) error

func (*Kind) XXX_DiscardUnknown 

func (m *Kind) XXX_DiscardUnknown()

func (*Kind) XXX_Marshal 

func (m *Kind) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Kind) XXX_Merge 

func (m *Kind) XXX_Merge(src proto.Message)

func (*Kind) XXX_Size 

func (m *Kind) XXX_Size() int

func (*Kind) XXX_Unmarshal 

func (m *Kind) XXX_Unmarshal(b []byte) error

type ListRequest 

type ListRequest struct {
	Filters *Filters `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters,omitempty"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetFilters added in v0.7.42 

func (m *ListRequest) GetFilters() *Filters

func (*ListRequest) Marshal 

func (m *ListRequest) Marshal() (dAtA []byte, err error)

func (*ListRequest) MarshalTo 

func (m *ListRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListRequest) MarshalToSizedBuffer 

func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) Size 

func (m *ListRequest) Size() (n int)

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) Unmarshal 

func (m *ListRequest) Unmarshal(dAtA []byte) error

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListResponse 

type ListResponse struct {
	Objects []Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) GetObjects 

func (m *ListResponse) GetObjects() []Object

func (*ListResponse) Marshal 

func (m *ListResponse) Marshal() (dAtA []byte, err error)

func (*ListResponse) MarshalTo 

func (m *ListResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListResponse) MarshalToSizedBuffer 

func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) Size 

func (m *ListResponse) Size() (n int)

func (*ListResponse) String 

func (m *ListResponse) String() string

func (*ListResponse) Unmarshal 

func (m *ListResponse) Unmarshal(dAtA []byte) error

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListResponse) XXX_Merge 

func (m *ListResponse) XXX_Merge(src proto.Message)

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

func (m *ListResponse) XXX_Unmarshal(b []byte) error

type Location added in v0.7.34 

type Location struct {
	Lat float64 `protobuf:"fixed64,1,opt,name=lat,proto3" json:"lat,omitempty"`
	Lng float64 `protobuf:"fixed64,2,opt,name=lng,proto3" json:"lng,omitempty"`
}

Geographical location; expected value type of "location" aspect

func (*Location) Descriptor added in v0.7.34 

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

func (*Location) GetLat added in v0.7.34 

func (m *Location) GetLat() float64

func (*Location) GetLng added in v0.7.34 

func (m *Location) GetLng() float64

func (*Location) Marshal added in v0.7.34 

func (m *Location) Marshal() (dAtA []byte, err error)

func (*Location) MarshalTo added in v0.7.34 

func (m *Location) MarshalTo(dAtA []byte) (int, error)

func (*Location) MarshalToSizedBuffer added in v0.7.34 

func (m *Location) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Location) ProtoMessage added in v0.7.34 

func (*Location) ProtoMessage()

func (*Location) Reset added in v0.7.34 

func (m *Location) Reset()

func (*Location) Size added in v0.7.34 

func (m *Location) Size() (n int)

func (*Location) String added in v0.7.34 

func (m *Location) String() string

func (*Location) Unmarshal added in v0.7.34 

func (m *Location) Unmarshal(dAtA []byte) error

func (*Location) XXX_DiscardUnknown added in v0.7.34 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal added in v0.7.34 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge added in v0.7.34 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size added in v0.7.34 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal added in v0.7.34 

func (m *Location) XXX_Unmarshal(b []byte) error

type MastershipState added in v0.7.34 

type MastershipState struct {
	Term   uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

Aspect for tracking device mastership

func (*MastershipState) Descriptor added in v0.7.34 

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

func (*MastershipState) GetNodeId added in v0.7.34 

func (m *MastershipState) GetNodeId() string

func (*MastershipState) GetTerm added in v0.7.34 

func (m *MastershipState) GetTerm() uint64

func (*MastershipState) Marshal added in v0.7.34 

func (m *MastershipState) Marshal() (dAtA []byte, err error)

func (*MastershipState) MarshalTo added in v0.7.34 

func (m *MastershipState) MarshalTo(dAtA []byte) (int, error)

func (*MastershipState) MarshalToSizedBuffer added in v0.7.34 

func (m *MastershipState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MastershipState) ProtoMessage added in v0.7.34 

func (*MastershipState) ProtoMessage()

func (*MastershipState) Reset added in v0.7.34 

func (m *MastershipState) Reset()

func (*MastershipState) Size added in v0.7.34 

func (m *MastershipState) Size() (n int)

func (*MastershipState) String added in v0.7.34 

func (m *MastershipState) String() string

func (*MastershipState) Unmarshal added in v0.7.34 

func (m *MastershipState) Unmarshal(dAtA []byte) error

func (*MastershipState) XXX_DiscardUnknown added in v0.7.34 

func (m *MastershipState) XXX_DiscardUnknown()

func (*MastershipState) XXX_Marshal added in v0.7.34 

func (m *MastershipState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MastershipState) XXX_Merge added in v0.7.34 

func (m *MastershipState) XXX_Merge(src proto.Message)

func (*MastershipState) XXX_Size added in v0.7.34 

func (m *MastershipState) XXX_Size() int

func (*MastershipState) XXX_Unmarshal added in v0.7.34 

func (m *MastershipState) XXX_Unmarshal(b []byte) error

type MockTopoClient added in v0.6.11 

type MockTopoClient struct {
	// contains filtered or unexported fields
}

MockTopoClient is a mock of TopoClient interface

func NewMockTopoClient added in v0.6.11 

func NewMockTopoClient(ctrl *gomock.Controller) *MockTopoClient

NewMockTopoClient creates a new mock instance

func (*MockTopoClient) Create added in v0.6.11 

func (m *MockTopoClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)

Create mocks base method

func (*MockTopoClient) Delete added in v0.6.11 

func (m *MockTopoClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)

Delete mocks base method

func (*MockTopoClient) EXPECT added in v0.6.11 

func (m *MockTopoClient) EXPECT() *MockTopoClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTopoClient) Get added in v0.6.11 

func (m *MockTopoClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)

Get mocks base method

func (*MockTopoClient) List added in v0.6.11 

func (m *MockTopoClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)

List mocks base method

func (*MockTopoClient) Update added in v0.6.11 

func (m *MockTopoClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)

Update mocks base method

func (*MockTopoClient) Watch added in v0.6.11 

func (m *MockTopoClient) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Topo_WatchClient, error)

Watch mocks base method

type MockTopoClientMockRecorder added in v0.6.11 

type MockTopoClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockTopoClientMockRecorder is the mock recorder for MockTopoClient

func (*MockTopoClientMockRecorder) Create added in v0.6.11 

func (mr *MockTopoClientMockRecorder) Create(ctx, in interface{}, opts ...interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockTopoClientMockRecorder) Delete added in v0.6.11 

func (mr *MockTopoClientMockRecorder) Delete(ctx, in interface{}, opts ...interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockTopoClientMockRecorder) Get added in v0.6.11 

func (mr *MockTopoClientMockRecorder) Get(ctx, in interface{}, opts ...interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockTopoClientMockRecorder) List added in v0.6.11 

func (mr *MockTopoClientMockRecorder) List(ctx, in interface{}, opts ...interface{}) *gomock.Call

List indicates an expected call of List

func (*MockTopoClientMockRecorder) Update added in v0.6.11 

func (mr *MockTopoClientMockRecorder) Update(ctx, in interface{}, opts ...interface{}) *gomock.Call

Update indicates an expected call of Update

func (*MockTopoClientMockRecorder) Watch added in v0.6.11 

func (mr *MockTopoClientMockRecorder) Watch(ctx, in interface{}, opts ...interface{}) *gomock.Call

Watch indicates an expected call of Watch

type MockTopoServer added in v0.6.11 

type MockTopoServer struct {
	// contains filtered or unexported fields
}

MockTopoServer is a mock of TopoServer interface

func NewMockTopoServer added in v0.6.11 

func NewMockTopoServer(ctrl *gomock.Controller) *MockTopoServer

NewMockTopoServer creates a new mock instance

func (*MockTopoServer) Create added in v0.6.11 

func (m *MockTopoServer) Create(arg0 context.Context, arg1 *CreateRequest) (*CreateResponse, error)

Create mocks base method

func (*MockTopoServer) Delete added in v0.6.11 

func (m *MockTopoServer) Delete(arg0 context.Context, arg1 *DeleteRequest) (*DeleteResponse, error)

Delete mocks base method

func (*MockTopoServer) EXPECT added in v0.6.11 

func (m *MockTopoServer) EXPECT() *MockTopoServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTopoServer) Get added in v0.6.11 

func (m *MockTopoServer) Get(arg0 context.Context, arg1 *GetRequest) (*GetResponse, error)

Get mocks base method

func (*MockTopoServer) List added in v0.6.11 

func (m *MockTopoServer) List(arg0 context.Context, arg1 *ListRequest) (*ListResponse, error)

List mocks base method

func (*MockTopoServer) Update added in v0.6.11 

func (m *MockTopoServer) Update(arg0 context.Context, arg1 *UpdateRequest) (*UpdateResponse, error)

Update mocks base method

func (*MockTopoServer) Watch added in v0.6.11 

func (m *MockTopoServer) Watch(arg0 *WatchRequest, arg1 Topo_WatchServer) error

Watch mocks base method

type MockTopoServerMockRecorder added in v0.6.11 

type MockTopoServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockTopoServerMockRecorder is the mock recorder for MockTopoServer

func (*MockTopoServerMockRecorder) Create added in v0.6.11 

func (mr *MockTopoServerMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockTopoServerMockRecorder) Delete added in v0.6.11 

func (mr *MockTopoServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockTopoServerMockRecorder) Get added in v0.6.11 

func (mr *MockTopoServerMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockTopoServerMockRecorder) List added in v0.6.11 

func (mr *MockTopoServerMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

List indicates an expected call of List

func (*MockTopoServerMockRecorder) Update added in v0.6.11 

func (mr *MockTopoServerMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call

Update indicates an expected call of Update

func (*MockTopoServerMockRecorder) Watch added in v0.6.11 

func (mr *MockTopoServerMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Watch indicates an expected call of Watch

type MockTopo_WatchClient added in v0.6.11 

type MockTopo_WatchClient struct {
	// contains filtered or unexported fields
}

MockTopo_WatchClient is a mock of Topo_WatchClient interface

func NewMockTopo_WatchClient added in v0.6.11 

func NewMockTopo_WatchClient(ctrl *gomock.Controller) *MockTopo_WatchClient

NewMockTopo_WatchClient creates a new mock instance

func (*MockTopo_WatchClient) CloseSend added in v0.6.11 

func (m *MockTopo_WatchClient) CloseSend() error

CloseSend mocks base method

func (*MockTopo_WatchClient) Context added in v0.6.11 

func (m *MockTopo_WatchClient) Context() context.Context

Context mocks base method

func (*MockTopo_WatchClient) EXPECT added in v0.6.11 

func (m *MockTopo_WatchClient) EXPECT() *MockTopo_WatchClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTopo_WatchClient) Header added in v0.6.11 

func (m *MockTopo_WatchClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockTopo_WatchClient) Recv added in v0.6.11 

func (m *MockTopo_WatchClient) Recv() (*WatchResponse, error)

Recv mocks base method

func (*MockTopo_WatchClient) RecvMsg added in v0.6.11 

func (m_2 *MockTopo_WatchClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockTopo_WatchClient) SendMsg added in v0.6.11 

func (m_2 *MockTopo_WatchClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockTopo_WatchClient) Trailer added in v0.6.11 

func (m *MockTopo_WatchClient) Trailer() metadata.MD

Trailer mocks base method

type MockTopo_WatchClientMockRecorder added in v0.6.11 

type MockTopo_WatchClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockTopo_WatchClientMockRecorder is the mock recorder for MockTopo_WatchClient

func (*MockTopo_WatchClientMockRecorder) CloseSend added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockTopo_WatchClientMockRecorder) Context added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockTopo_WatchClientMockRecorder) Header added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockTopo_WatchClientMockRecorder) Recv added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockTopo_WatchClientMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockTopo_WatchClientMockRecorder) SendMsg added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockTopo_WatchClientMockRecorder) Trailer added in v0.6.11 

func (mr *MockTopo_WatchClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockTopo_WatchServer added in v0.6.11 

type MockTopo_WatchServer struct {
	// contains filtered or unexported fields
}

MockTopo_WatchServer is a mock of Topo_WatchServer interface

func NewMockTopo_WatchServer added in v0.6.11 

func NewMockTopo_WatchServer(ctrl *gomock.Controller) *MockTopo_WatchServer

NewMockTopo_WatchServer creates a new mock instance

func (*MockTopo_WatchServer) Context added in v0.6.11 

func (m *MockTopo_WatchServer) Context() context.Context

Context mocks base method

func (*MockTopo_WatchServer) EXPECT added in v0.6.11 

func (m *MockTopo_WatchServer) EXPECT() *MockTopo_WatchServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTopo_WatchServer) RecvMsg added in v0.6.11 

func (m_2 *MockTopo_WatchServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockTopo_WatchServer) Send added in v0.6.11 

func (m *MockTopo_WatchServer) Send(arg0 *WatchResponse) error

Send mocks base method

func (*MockTopo_WatchServer) SendHeader added in v0.6.11 

func (m *MockTopo_WatchServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockTopo_WatchServer) SendMsg added in v0.6.11 

func (m_2 *MockTopo_WatchServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockTopo_WatchServer) SetHeader added in v0.6.11 

func (m *MockTopo_WatchServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockTopo_WatchServer) SetTrailer added in v0.6.11 

func (m *MockTopo_WatchServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockTopo_WatchServerMockRecorder added in v0.6.11 

type MockTopo_WatchServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockTopo_WatchServerMockRecorder is the mock recorder for MockTopo_WatchServer

func (*MockTopo_WatchServerMockRecorder) Context added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockTopo_WatchServerMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockTopo_WatchServerMockRecorder) Send added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockTopo_WatchServerMockRecorder) SendHeader added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockTopo_WatchServerMockRecorder) SendMsg added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockTopo_WatchServerMockRecorder) SetHeader added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockTopo_WatchServerMockRecorder) SetTrailer added in v0.6.11 

func (mr *MockTopo_WatchServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type MockisObject_Obj added in v0.6.11 

type MockisObject_Obj struct {
	// contains filtered or unexported fields
}

MockisObject_Obj is a mock of isObject_Obj interface

func NewMockisObject_Obj added in v0.6.11 

func NewMockisObject_Obj(ctrl *gomock.Controller) *MockisObject_Obj

NewMockisObject_Obj creates a new mock instance

func (*MockisObject_Obj) EXPECT added in v0.6.11 

func (m *MockisObject_Obj) EXPECT() *MockisObject_ObjMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockisObject_Obj) MarshalTo added in v0.6.11 

func (m *MockisObject_Obj) MarshalTo(arg0 []byte) (int, error)

MarshalTo mocks base method

func (*MockisObject_Obj) Size added in v0.6.11 

func (m *MockisObject_Obj) Size() int

Size mocks base method

type MockisObject_ObjMockRecorder added in v0.6.11 

type MockisObject_ObjMockRecorder struct {
	// contains filtered or unexported fields
}

MockisObject_ObjMockRecorder is the mock recorder for MockisObject_Obj

func (*MockisObject_ObjMockRecorder) MarshalTo added in v0.6.11 

func (mr *MockisObject_ObjMockRecorder) MarshalTo(arg0 interface{}) *gomock.Call

MarshalTo indicates an expected call of MarshalTo

func (*MockisObject_ObjMockRecorder) Size added in v0.6.11 

func (mr *MockisObject_ObjMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size

type NotFilter added in v0.7.42 

type NotFilter struct {
	Inner *Filter `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"`
}

func (*NotFilter) Descriptor added in v0.7.42 

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

func (*NotFilter) GetInner added in v0.7.42 

func (m *NotFilter) GetInner() *Filter

func (*NotFilter) Marshal added in v0.7.42 

func (m *NotFilter) Marshal() (dAtA []byte, err error)

func (*NotFilter) MarshalTo added in v0.7.42 

func (m *NotFilter) MarshalTo(dAtA []byte) (int, error)

func (*NotFilter) MarshalToSizedBuffer added in v0.7.42 

func (m *NotFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotFilter) ProtoMessage added in v0.7.42 

func (*NotFilter) ProtoMessage()

func (*NotFilter) Reset added in v0.7.42 

func (m *NotFilter) Reset()

func (*NotFilter) Size added in v0.7.42 

func (m *NotFilter) Size() (n int)

func (*NotFilter) String added in v0.7.42 

func (m *NotFilter) String() string

func (*NotFilter) Unmarshal added in v0.7.42 

func (m *NotFilter) Unmarshal(dAtA []byte) error

func (*NotFilter) XXX_DiscardUnknown added in v0.7.42 

func (m *NotFilter) XXX_DiscardUnknown()

func (*NotFilter) XXX_Marshal added in v0.7.42 

func (m *NotFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotFilter) XXX_Merge added in v0.7.42 

func (m *NotFilter) XXX_Merge(src proto.Message)

func (*NotFilter) XXX_Size added in v0.7.42 

func (m *NotFilter) XXX_Size() int

func (*NotFilter) XXX_Unmarshal added in v0.7.42 

func (m *NotFilter) XXX_Unmarshal(b []byte) error

type Object 

type Object struct {
	ID       ID          `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
	Revision Revision    `protobuf:"varint,2,opt,name=revision,proto3,casttype=Revision" json:"revision,omitempty"`
	Type     Object_Type `protobuf:"varint,3,opt,name=type,proto3,enum=onos.topo.Object_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Obj:
	//	*Object_Entity
	//	*Object_Relation
	//	*Object_Kind
	Obj isObject_Obj `protobuf_oneof:"obj"`
	// Map of aspects as typed values; for kind, these represent expected aspects and their default values
	Aspects map[string]*types.Any `` /* 155-byte string literal not displayed */
	// Arbitrary labels for classification/search
	Labels map[string]string `` /* 153-byte string literal not displayed */
}

Object is an one of the following: a kind (archetype of entity or relation), an entity, a relation

func (*Object) Descriptor 

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

func (*Object) GetAspect added in v0.7.37 

func (obj *Object) GetAspect(destValue proto.Message) proto.Message

GetAspect retrieves the specified aspect value from the given object.

func (*Object) GetAspectBytes added in v0.7.38 

func (obj *Object) GetAspectBytes(aspectType string) ([]byte, error)

GetAspectBytes applies the specified aspect as raw JSON bytes to the given object.

func (*Object) GetAspectSafe added in v0.7.37 

func (obj *Object) GetAspectSafe(destValue proto.Message) (proto.Message, error)

GetAspectSafe retrieves the specified aspect value from the given object.

func (*Object) GetAspects added in v0.7.37 

func (m *Object) GetAspects() map[string]*types.Any

func (*Object) GetEntity 

func (m *Object) GetEntity() *Entity

func (*Object) GetID 

func (m *Object) GetID() ID

func (*Object) GetKind 

func (m *Object) GetKind() *Kind

func (*Object) GetLabels added in v0.7.33 

func (m *Object) GetLabels() map[string]string

func (*Object) GetObj 

func (m *Object) GetObj() isObject_Obj

func (*Object) GetRelation 

func (m *Object) GetRelation() *Relation

func (*Object) GetRevision 

func (m *Object) GetRevision() Revision

func (*Object) GetType 

func (m *Object) GetType() Object_Type

func (*Object) Marshal 

func (m *Object) Marshal() (dAtA []byte, err error)

func (*Object) MarshalTo 

func (m *Object) MarshalTo(dAtA []byte) (int, error)

func (*Object) MarshalToSizedBuffer 

func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) SetAspect added in v0.7.37 

func (obj *Object) SetAspect(value proto.Message) error

SetAspect applies the specified aspect value to the given object.

func (*Object) SetAspectBytes added in v0.7.38 

func (obj *Object) SetAspectBytes(aspectType string, jsonValue []byte) error

SetAspectBytes applies the specified aspect as raw JSON bytes to the given object.

func (*Object) Size 

func (m *Object) Size() (n int)

func (*Object) String 

func (m *Object) String() string

func (*Object) Unmarshal 

func (m *Object) Unmarshal(dAtA []byte) error

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Object) XXX_Merge 

func (m *Object) XXX_Merge(src proto.Message)

func (*Object) XXX_OneofWrappers 

func (*Object) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

func (m *Object) XXX_Unmarshal(b []byte) error

type Object_Entity 

type Object_Entity struct {
	Entity *Entity `protobuf:"bytes,4,opt,name=entity,proto3,oneof" json:"entity,omitempty"`
}

func (*Object_Entity) MarshalTo 

func (m *Object_Entity) MarshalTo(dAtA []byte) (int, error)

func (*Object_Entity) MarshalToSizedBuffer 

func (m *Object_Entity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object_Entity) Size 

func (m *Object_Entity) Size() (n int)

type Object_Kind 

type Object_Kind struct {
	Kind *Kind `protobuf:"bytes,6,opt,name=kind,proto3,oneof" json:"kind,omitempty"`
}

func (*Object_Kind) MarshalTo 

func (m *Object_Kind) MarshalTo(dAtA []byte) (int, error)

func (*Object_Kind) MarshalToSizedBuffer 

func (m *Object_Kind) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object_Kind) Size 

func (m *Object_Kind) Size() (n int)

type Object_Relation 

type Object_Relation struct {
	Relation *Relation `protobuf:"bytes,5,opt,name=relation,proto3,oneof" json:"relation,omitempty"`
}

func (*Object_Relation) MarshalTo 

func (m *Object_Relation) MarshalTo(dAtA []byte) (int, error)

func (*Object_Relation) MarshalToSizedBuffer 

func (m *Object_Relation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object_Relation) Size 

func (m *Object_Relation) Size() (n int)

type Object_Type 

type Object_Type int32
const (
	Object_UNSPECIFIED Object_Type = 0
	Object_ENTITY      Object_Type = 1
	Object_RELATION    Object_Type = 2
	Object_KIND        Object_Type = 3
)

func (Object_Type) EnumDescriptor 

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

func (Object_Type) String 

func (x Object_Type) String() string

type Protocol 

type Protocol int32

Protocol to interact with a device 

const (
	//UNKNOWN_PROTOCOL constant needed to go around proto3 nullifying the 0 values
	Protocol_UNKNOWN_PROTOCOL Protocol = 0
	// GNMI protocol reference
	Protocol_GNMI Protocol = 1
	// P4RUNTIME protocol reference
	Protocol_P4RUNTIME Protocol = 2
	// GNOI protocol reference
	Protocol_GNOI Protocol = 3
	// E2 Control Plane Protocol
	Protocol_E2AP Protocol = 4
)

func (Protocol) EnumDescriptor 

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

func (Protocol) String 

func (x Protocol) String() string

type ProtocolState 

type ProtocolState struct {
	//The protocol to which state relates
	Protocol Protocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=onos.topo.Protocol" json:"protocol,omitempty"`
	//ConnectivityState contains the L3 connectivity information
	ConnectivityState ConnectivityState `protobuf:"varint,2,opt,name=connectivityState,proto3,enum=onos.topo.ConnectivityState" json:"connectivityState,omitempty"`
	//ChannelState relates to the availability of the gRPC channel
	ChannelState ChannelState `protobuf:"varint,3,opt,name=channelState,proto3,enum=onos.topo.ChannelState" json:"channelState,omitempty"`
	//ServiceState indicates the availability of the gRPC servic on top of the channel
	ServiceState ServiceState `protobuf:"varint,4,opt,name=serviceState,proto3,enum=onos.topo.ServiceState" json:"serviceState,omitempty"`
}

ProtocolState contains information related to service and connectivity to a device

func (*ProtocolState) Descriptor 

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

func (*ProtocolState) GetChannelState 

func (m *ProtocolState) GetChannelState() ChannelState

func (*ProtocolState) GetConnectivityState 

func (m *ProtocolState) GetConnectivityState() ConnectivityState

func (*ProtocolState) GetProtocol 

func (m *ProtocolState) GetProtocol() Protocol

func (*ProtocolState) GetServiceState 

func (m *ProtocolState) GetServiceState() ServiceState

func (*ProtocolState) Marshal 

func (m *ProtocolState) Marshal() (dAtA []byte, err error)

func (*ProtocolState) MarshalTo 

func (m *ProtocolState) MarshalTo(dAtA []byte) (int, error)

func (*ProtocolState) MarshalToSizedBuffer 

func (m *ProtocolState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProtocolState) ProtoMessage 

func (*ProtocolState) ProtoMessage()

func (*ProtocolState) Reset 

func (m *ProtocolState) Reset()

func (*ProtocolState) Size 

func (m *ProtocolState) Size() (n int)

func (*ProtocolState) String 

func (m *ProtocolState) String() string

func (*ProtocolState) Unmarshal 

func (m *ProtocolState) Unmarshal(dAtA []byte) error

func (*ProtocolState) XXX_DiscardUnknown 

func (m *ProtocolState) XXX_DiscardUnknown()

func (*ProtocolState) XXX_Marshal 

func (m *ProtocolState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtocolState) XXX_Merge 

func (m *ProtocolState) XXX_Merge(src proto.Message)

func (*ProtocolState) XXX_Size 

func (m *ProtocolState) XXX_Size() int

func (*ProtocolState) XXX_Unmarshal 

func (m *ProtocolState) XXX_Unmarshal(b []byte) error

type Protocols added in v0.7.43 

type Protocols struct {
	State []*ProtocolState `protobuf:"bytes,1,rep,name=state,proto3" json:"state,omitempty"`
}

Protocols

func (*Protocols) Descriptor added in v0.7.43 

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

func (*Protocols) GetState added in v0.7.43 

func (m *Protocols) GetState() []*ProtocolState

func (*Protocols) Marshal added in v0.7.43 

func (m *Protocols) Marshal() (dAtA []byte, err error)

func (*Protocols) MarshalTo added in v0.7.43 

func (m *Protocols) MarshalTo(dAtA []byte) (int, error)

func (*Protocols) MarshalToSizedBuffer added in v0.7.43 

func (m *Protocols) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Protocols) ProtoMessage added in v0.7.43 

func (*Protocols) ProtoMessage()

func (*Protocols) Reset added in v0.7.43 

func (m *Protocols) Reset()

func (*Protocols) Size added in v0.7.43 

func (m *Protocols) Size() (n int)

func (*Protocols) String added in v0.7.43 

func (m *Protocols) String() string

func (*Protocols) Unmarshal added in v0.7.43 

func (m *Protocols) Unmarshal(dAtA []byte) error

func (*Protocols) XXX_DiscardUnknown added in v0.7.43 

func (m *Protocols) XXX_DiscardUnknown()

func (*Protocols) XXX_Marshal added in v0.7.43 

func (m *Protocols) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Protocols) XXX_Merge added in v0.7.43 

func (m *Protocols) XXX_Merge(src proto.Message)

func (*Protocols) XXX_Size added in v0.7.43 

func (m *Protocols) XXX_Size() int

func (*Protocols) XXX_Unmarshal added in v0.7.43 

func (m *Protocols) XXX_Unmarshal(b []byte) error

type RANEntityKinds added in v0.7.34 

type RANEntityKinds int32

Kinds of RAN entities 

const (
	RANEntityKinds_E2NODE RANEntityKinds = 0
	RANEntityKinds_E2CELL RANEntityKinds = 1
)

func (RANEntityKinds) EnumDescriptor added in v0.7.34 

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

func (RANEntityKinds) String added in v0.7.34 

func (x RANEntityKinds) String() string

type RANRelationKinds added in v0.7.34 

type RANRelationKinds int32

Kinds of RAN relations 

const (
	RANRelationKinds_CONTROLS  RANRelationKinds = 0
	RANRelationKinds_CONTAINS  RANRelationKinds = 1
	RANRelationKinds_NEIGHBORS RANRelationKinds = 2
)

func (RANRelationKinds) EnumDescriptor added in v0.7.34 

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

func (RANRelationKinds) String added in v0.7.34 

func (x RANRelationKinds) String() string

type RCRanFunction added in v0.7.34 

type RCRanFunction struct {
	ID           string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ReportStyles []*RCReportStyle `protobuf:"bytes,2,rep,name=report_styles,json=reportStyles,proto3" json:"report_styles,omitempty"`
}

func (*RCRanFunction) Descriptor added in v0.7.34 

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

func (*RCRanFunction) GetID added in v0.7.34 

func (m *RCRanFunction) GetID() string

func (*RCRanFunction) GetReportStyles added in v0.7.58 

func (m *RCRanFunction) GetReportStyles() []*RCReportStyle

func (*RCRanFunction) Marshal added in v0.7.34 

func (m *RCRanFunction) Marshal() (dAtA []byte, err error)

func (*RCRanFunction) MarshalTo added in v0.7.34 

func (m *RCRanFunction) MarshalTo(dAtA []byte) (int, error)

func (*RCRanFunction) MarshalToSizedBuffer added in v0.7.34 

func (m *RCRanFunction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RCRanFunction) ProtoMessage added in v0.7.34 

func (*RCRanFunction) ProtoMessage()

func (*RCRanFunction) Reset added in v0.7.34 

func (m *RCRanFunction) Reset()

func (*RCRanFunction) Size added in v0.7.34 

func (m *RCRanFunction) Size() (n int)

func (*RCRanFunction) String added in v0.7.34 

func (m *RCRanFunction) String() string

func (*RCRanFunction) Unmarshal added in v0.7.34 

func (m *RCRanFunction) Unmarshal(dAtA []byte) error

func (*RCRanFunction) XXX_DiscardUnknown added in v0.7.34 

func (m *RCRanFunction) XXX_DiscardUnknown()

func (*RCRanFunction) XXX_Marshal added in v0.7.34 

func (m *RCRanFunction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RCRanFunction) XXX_Merge added in v0.7.34 

func (m *RCRanFunction) XXX_Merge(src proto.Message)

func (*RCRanFunction) XXX_Size added in v0.7.34 

func (m *RCRanFunction) XXX_Size() int

func (*RCRanFunction) XXX_Unmarshal added in v0.7.34 

func (m *RCRanFunction) XXX_Unmarshal(b []byte) error

type RCReportStyle added in v0.7.58 

type RCReportStyle struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type int32  `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
}

func (*RCReportStyle) Descriptor added in v0.7.58 

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

func (*RCReportStyle) GetName added in v0.7.58 

func (m *RCReportStyle) GetName() string

func (*RCReportStyle) GetType added in v0.7.58 

func (m *RCReportStyle) GetType() int32

func (*RCReportStyle) Marshal added in v0.7.58 

func (m *RCReportStyle) Marshal() (dAtA []byte, err error)

func (*RCReportStyle) MarshalTo added in v0.7.58 

func (m *RCReportStyle) MarshalTo(dAtA []byte) (int, error)

func (*RCReportStyle) MarshalToSizedBuffer added in v0.7.58 

func (m *RCReportStyle) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RCReportStyle) ProtoMessage added in v0.7.58 

func (*RCReportStyle) ProtoMessage()

func (*RCReportStyle) Reset added in v0.7.58 

func (m *RCReportStyle) Reset()

func (*RCReportStyle) Size added in v0.7.58 

func (m *RCReportStyle) Size() (n int)

func (*RCReportStyle) String added in v0.7.58 

func (m *RCReportStyle) String() string

func (*RCReportStyle) Unmarshal added in v0.7.58 

func (m *RCReportStyle) Unmarshal(dAtA []byte) error

func (*RCReportStyle) XXX_DiscardUnknown added in v0.7.58 

func (m *RCReportStyle) XXX_DiscardUnknown()

func (*RCReportStyle) XXX_Marshal added in v0.7.58 

func (m *RCReportStyle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RCReportStyle) XXX_Merge added in v0.7.58 

func (m *RCReportStyle) XXX_Merge(src proto.Message)

func (*RCReportStyle) XXX_Size added in v0.7.58 

func (m *RCReportStyle) XXX_Size() int

func (*RCReportStyle) XXX_Unmarshal added in v0.7.58 

func (m *RCReportStyle) XXX_Unmarshal(b []byte) error

type Relation 

type Relation struct {
	// user defined relation kind
	KindID      ID `protobuf:"bytes,1,opt,name=kind_id,json=kindId,proto3,casttype=ID" json:"kind_id,omitempty"`
	SrcEntityID ID `protobuf:"bytes,2,opt,name=src_entity_id,json=srcEntityId,proto3,casttype=ID" json:"src_entity_id,omitempty"`
	TgtEntityID ID `protobuf:"bytes,3,opt,name=tgt_entity_id,json=tgtEntityId,proto3,casttype=ID" json:"tgt_entity_id,omitempty"`
}

Relation represents any "relation" between two entitites in the topology.

func (*Relation) Descriptor 

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

func (*Relation) GetKindID 

func (m *Relation) GetKindID() ID

func (*Relation) GetSrcEntityID 

func (m *Relation) GetSrcEntityID() ID

func (*Relation) GetTgtEntityID 

func (m *Relation) GetTgtEntityID() ID

func (*Relation) Marshal 

func (m *Relation) Marshal() (dAtA []byte, err error)

func (*Relation) MarshalTo 

func (m *Relation) MarshalTo(dAtA []byte) (int, error)

func (*Relation) MarshalToSizedBuffer 

func (m *Relation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Relation) ProtoMessage 

func (*Relation) ProtoMessage()

func (*Relation) Reset 

func (m *Relation) Reset()

func (*Relation) Size 

func (m *Relation) Size() (n int)

func (*Relation) String 

func (m *Relation) String() string

func (*Relation) Unmarshal 

func (m *Relation) Unmarshal(dAtA []byte) error

func (*Relation) XXX_DiscardUnknown 

func (m *Relation) XXX_DiscardUnknown()

func (*Relation) XXX_Marshal 

func (m *Relation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Relation) XXX_Merge 

func (m *Relation) XXX_Merge(src proto.Message)

func (*Relation) XXX_Size 

func (m *Relation) XXX_Size() int

func (*Relation) XXX_Unmarshal 

func (m *Relation) XXX_Unmarshal(b []byte) error

type Revision 

type Revision uint64

Revision is an object revision

type ServiceModelInfo added in v0.7.34 

type ServiceModelInfo struct {
	OID          string       `protobuf:"bytes,1,opt,name=oid,proto3" json:"oid,omitempty"`
	Name         string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	RanFunctions []*types.Any `protobuf:"bytes,3,rep,name=ran_functions,json=ranFunctions,proto3" json:"ran_functions,omitempty"`
}

func (*ServiceModelInfo) Descriptor added in v0.7.34 

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

func (*ServiceModelInfo) GetName added in v0.7.34 

func (m *ServiceModelInfo) GetName() string

func (*ServiceModelInfo) GetOID added in v0.7.34 

func (m *ServiceModelInfo) GetOID() string

func (*ServiceModelInfo) GetRanFunctions added in v0.7.34 

func (m *ServiceModelInfo) GetRanFunctions() []*types.Any

func (*ServiceModelInfo) Marshal added in v0.7.34 

func (m *ServiceModelInfo) Marshal() (dAtA []byte, err error)

func (*ServiceModelInfo) MarshalTo added in v0.7.34 

func (m *ServiceModelInfo) MarshalTo(dAtA []byte) (int, error)

func (*ServiceModelInfo) MarshalToSizedBuffer added in v0.7.34 

func (m *ServiceModelInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceModelInfo) ProtoMessage added in v0.7.34 

func (*ServiceModelInfo) ProtoMessage()

func (*ServiceModelInfo) Reset added in v0.7.34 

func (m *ServiceModelInfo) Reset()

func (*ServiceModelInfo) Size added in v0.7.34 

func (m *ServiceModelInfo) Size() (n int)

func (*ServiceModelInfo) String added in v0.7.34 

func (m *ServiceModelInfo) String() string

func (*ServiceModelInfo) Unmarshal added in v0.7.34 

func (m *ServiceModelInfo) Unmarshal(dAtA []byte) error

func (*ServiceModelInfo) XXX_DiscardUnknown added in v0.7.34 

func (m *ServiceModelInfo) XXX_DiscardUnknown()

func (*ServiceModelInfo) XXX_Marshal added in v0.7.34 

func (m *ServiceModelInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceModelInfo) XXX_Merge added in v0.7.34 

func (m *ServiceModelInfo) XXX_Merge(src proto.Message)

func (*ServiceModelInfo) XXX_Size added in v0.7.34 

func (m *ServiceModelInfo) XXX_Size() int

func (*ServiceModelInfo) XXX_Unmarshal added in v0.7.34 

func (m *ServiceModelInfo) XXX_Unmarshal(b []byte) error

type ServiceState 

type ServiceState int32

ServiceState represents the state of the gRPC service (e.g. gNMI) to the device from the service container 

const (
	//UNKNOWN_SERVICE_STATE constant needed to go around proto3 nullifying the 0 values
	ServiceState_UNKNOWN_SERVICE_STATE ServiceState = 0
	// AVAILABLE indicates the corresponding grpc service is available
	ServiceState_AVAILABLE ServiceState = 1
	// UNAVAILABLE indicates the corresponding grpc service is not available
	ServiceState_UNAVAILABLE ServiceState = 2
	// CONNECTING indicates the corresponding protocol is in the connecting phase on this device
	ServiceState_CONNECTING ServiceState = 3
)

func (ServiceState) EnumDescriptor 

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

func (ServiceState) String 

func (x ServiceState) String() string

type TLSOptions added in v0.7.34 

type TLSOptions struct {
	Insecure bool   `protobuf:"varint,1,opt,name=insecure,proto3" json:"insecure,omitempty"`
	Plain    bool   `protobuf:"varint,2,opt,name=plain,proto3" json:"plain,omitempty"`
	Key      string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	CaCert   string `protobuf:"bytes,4,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
	Cert     string `protobuf:"bytes,5,opt,name=cert,proto3" json:"cert,omitempty"`
}

TLS connectivity aspect

func (*TLSOptions) Descriptor added in v0.7.34 

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

func (*TLSOptions) GetCaCert added in v0.7.34 

func (m *TLSOptions) GetCaCert() string

func (*TLSOptions) GetCert added in v0.7.34 

func (m *TLSOptions) GetCert() string

func (*TLSOptions) GetInsecure added in v0.7.34 

func (m *TLSOptions) GetInsecure() bool

func (*TLSOptions) GetKey added in v0.7.34 

func (m *TLSOptions) GetKey() string

func (*TLSOptions) GetPlain added in v0.7.34 

func (m *TLSOptions) GetPlain() bool

func (*TLSOptions) Marshal added in v0.7.34 

func (m *TLSOptions) Marshal() (dAtA []byte, err error)

func (*TLSOptions) MarshalTo added in v0.7.34 

func (m *TLSOptions) MarshalTo(dAtA []byte) (int, error)

func (*TLSOptions) MarshalToSizedBuffer added in v0.7.34 

func (m *TLSOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TLSOptions) ProtoMessage added in v0.7.34 

func (*TLSOptions) ProtoMessage()

func (*TLSOptions) Reset added in v0.7.34 

func (m *TLSOptions) Reset()

func (*TLSOptions) Size added in v0.7.34 

func (m *TLSOptions) Size() (n int)

func (*TLSOptions) String added in v0.7.34 

func (m *TLSOptions) String() string

func (*TLSOptions) Unmarshal added in v0.7.34 

func (m *TLSOptions) Unmarshal(dAtA []byte) error

func (*TLSOptions) XXX_DiscardUnknown added in v0.7.34 

func (m *TLSOptions) XXX_DiscardUnknown()

func (*TLSOptions) XXX_Marshal added in v0.7.34 

func (m *TLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TLSOptions) XXX_Merge added in v0.7.34 

func (m *TLSOptions) XXX_Merge(src proto.Message)

func (*TLSOptions) XXX_Size added in v0.7.34 

func (m *TLSOptions) XXX_Size() int

func (*TLSOptions) XXX_Unmarshal added in v0.7.34 

func (m *TLSOptions) XXX_Unmarshal(b []byte) error

type TopoClient 

type TopoClient interface {
	// Create a new topology object
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Get an object from topology
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Update an existing topology object
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	// Delete an object from topology
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// List gets a stream of requested objects
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// Watch returns a stream of topo change notifications
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Topo_WatchClient, error)
}

TopoClient is the client API for Topo service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func CreateTopoClient 

func CreateTopoClient(cc *grpc.ClientConn) TopoClient

CreateTopoClient creates and returns a new topo device client

func NewTopoClient 

func NewTopoClient(cc *grpc.ClientConn) TopoClient

type TopoServer 

type TopoServer interface {
	// Create a new topology object
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Get an object from topology
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Update an existing topology object
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	// Delete an object from topology
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// List gets a stream of requested objects
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Watch returns a stream of topo change notifications
	Watch(*WatchRequest, Topo_WatchServer) error
}

TopoServer is the server API for Topo service.

type Topo_WatchClient 

type Topo_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type Topo_WatchServer 

type Topo_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type UnimplementedTopoServer 

type UnimplementedTopoServer struct {
}

UnimplementedTopoServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopoServer) Create 

func (*UnimplementedTopoServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedTopoServer) Delete 

func (*UnimplementedTopoServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedTopoServer) Get 

func (*UnimplementedTopoServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedTopoServer) List 

func (*UnimplementedTopoServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

func (*UnimplementedTopoServer) Update 

func (*UnimplementedTopoServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)

func (*UnimplementedTopoServer) Watch 

func (*UnimplementedTopoServer) Watch(req *WatchRequest, srv Topo_WatchServer) error

type UpdateRequest 

type UpdateRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) GetObject 

func (m *UpdateRequest) GetObject() *Object

func (*UpdateRequest) Marshal 

func (m *UpdateRequest) Marshal() (dAtA []byte, err error)

func (*UpdateRequest) MarshalTo 

func (m *UpdateRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateRequest) MarshalToSizedBuffer 

func (m *UpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) Size 

func (m *UpdateRequest) Size() (n int)

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

func (*UpdateRequest) Unmarshal 

func (m *UpdateRequest) Unmarshal(dAtA []byte) error

func (*UpdateRequest) XXX_DiscardUnknown 

func (m *UpdateRequest) XXX_DiscardUnknown()

func (*UpdateRequest) XXX_Marshal 

func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateRequest) XXX_Merge 

func (m *UpdateRequest) XXX_Merge(src proto.Message)

func (*UpdateRequest) XXX_Size 

func (m *UpdateRequest) XXX_Size() int

func (*UpdateRequest) XXX_Unmarshal 

func (m *UpdateRequest) XXX_Unmarshal(b []byte) error

type UpdateResponse 

type UpdateResponse struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*UpdateResponse) Descriptor 

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

func (*UpdateResponse) GetObject 

func (m *UpdateResponse) GetObject() *Object

func (*UpdateResponse) Marshal 

func (m *UpdateResponse) Marshal() (dAtA []byte, err error)

func (*UpdateResponse) MarshalTo 

func (m *UpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateResponse) MarshalToSizedBuffer 

func (m *UpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) Reset 

func (m *UpdateResponse) Reset()

func (*UpdateResponse) Size 

func (m *UpdateResponse) Size() (n int)

func (*UpdateResponse) String 

func (m *UpdateResponse) String() string

func (*UpdateResponse) Unmarshal 

func (m *UpdateResponse) Unmarshal(dAtA []byte) error

func (*UpdateResponse) XXX_DiscardUnknown 

func (m *UpdateResponse) XXX_DiscardUnknown()

func (*UpdateResponse) XXX_Marshal 

func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateResponse) XXX_Merge 

func (m *UpdateResponse) XXX_Merge(src proto.Message)

func (*UpdateResponse) XXX_Size 

func (m *UpdateResponse) XXX_Size() int

func (*UpdateResponse) XXX_Unmarshal 

func (m *UpdateResponse) XXX_Unmarshal(b []byte) error

type WatchRequest 

type WatchRequest struct {
	Filters  *Filters `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters,omitempty"`
	Noreplay bool     `protobuf:"varint,2,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetFilters added in v0.7.42 

func (m *WatchRequest) GetFilters() *Filters

func (*WatchRequest) GetNoreplay 

func (m *WatchRequest) GetNoreplay() bool

func (*WatchRequest) Marshal 

func (m *WatchRequest) Marshal() (dAtA []byte, err error)

func (*WatchRequest) MarshalTo 

func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchRequest) MarshalToSizedBuffer 

func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) Size 

func (m *WatchRequest) Size() (n int)

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) Unmarshal 

func (m *WatchRequest) Unmarshal(dAtA []byte) error

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchRequest) XXX_Merge 

func (m *WatchRequest) XXX_Merge(src proto.Message)

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

func (m *WatchRequest) XXX_Unmarshal(b []byte) error

type WatchResponse 

type WatchResponse struct {
	Event Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
}

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetEvent 

func (m *WatchResponse) GetEvent() Event

func (*WatchResponse) Marshal 

func (m *WatchResponse) Marshal() (dAtA []byte, err error)

func (*WatchResponse) MarshalTo 

func (m *WatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*WatchResponse) MarshalToSizedBuffer 

func (m *WatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) Size 

func (m *WatchResponse) Size() (n int)

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) Unmarshal 

func (m *WatchResponse) Unmarshal(dAtA []byte) error

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchResponse) XXX_Merge 

func (m *WatchResponse) XXX_Merge(src proto.Message)

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

func (m *WatchResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

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.