topo

package
v0.7.83 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 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 (
	// Relations
	CONTROLS  = "controls"
	CONTAINS  = "contains"
	NEIGHBORS = "neighbors"

	// RAN Entities
	E2NODE = "e2node"
	E2CELL = "e2cell"
	E2T    = "e2t"
)

Entity and Relation Kinds

View Source 
const NullID = ""

NullID represents a null/empty/omitted identifier; usually an indicator for system to generate one.

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 CellGlobalIDType_name = map[int32]string{
	0: "NRCGI",
	1: "ECGI",
}
View Source 
var CellGlobalIDType_value = map[string]int32{
	"NRCGI": 0,
	"ECGI":  1,
}
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",
	3: "E2T",
}
View Source 
var RANEntityKinds_value = map[string]int32{
	"E2NODE": 0,
	"E2CELL": 1,
	"E2T":    3,
}
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 RelationFilterScope_name = map[int32]string{
	0: "TARGET_ONLY",
	1: "ALL",
	2: "SOURCE_AND_TARGET",
}
View Source 
var RelationFilterScope_value = map[string]int32{
	"TARGET_ONLY":       0,
	"ALL":               1,
	"SOURCE_AND_TARGET": 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 SortOrder_name = map[int32]string{
	0: "UNORDERED",
	1: "ASCENDING",
	2: "DESCENDING",
}
View Source 
var SortOrder_value = map[string]int32{
	"UNORDERED":  0,
	"ASCENDING":  1,
	"DESCENDING": 2,
}
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 CellGlobalID added in v0.7.63 

type CellGlobalID struct {
	Value string           `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type  CellGlobalIDType `protobuf:"varint,2,opt,name=type,proto3,enum=onos.topo.CellGlobalIDType" json:"type,omitempty"`
}

func (*CellGlobalID) Descriptor added in v0.7.63 

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

func (*CellGlobalID) GetType added in v0.7.63 

func (m *CellGlobalID) GetType() CellGlobalIDType

func (*CellGlobalID) GetValue added in v0.7.63 

func (m *CellGlobalID) GetValue() string

func (*CellGlobalID) Marshal added in v0.7.63 

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

func (*CellGlobalID) MarshalTo added in v0.7.63 

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

func (*CellGlobalID) MarshalToSizedBuffer added in v0.7.63 

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

func (*CellGlobalID) ProtoMessage added in v0.7.63 

func (*CellGlobalID) ProtoMessage()

func (*CellGlobalID) Reset added in v0.7.63 

func (m *CellGlobalID) Reset()

func (*CellGlobalID) Size added in v0.7.63 

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

func (*CellGlobalID) String added in v0.7.63 

func (m *CellGlobalID) String() string

func (*CellGlobalID) Unmarshal added in v0.7.63 

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

func (*CellGlobalID) XXX_DiscardUnknown added in v0.7.63 

func (m *CellGlobalID) XXX_DiscardUnknown()

func (*CellGlobalID) XXX_Marshal added in v0.7.63 

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

func (*CellGlobalID) XXX_Merge added in v0.7.63 

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

func (*CellGlobalID) XXX_Size added in v0.7.63 

func (m *CellGlobalID) XXX_Size() int

func (*CellGlobalID) XXX_Unmarshal added in v0.7.63 

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

type CellGlobalIDType added in v0.7.63 

type CellGlobalIDType int32
const (
	CellGlobalIDType_NRCGI CellGlobalIDType = 0
	CellGlobalIDType_ECGI  CellGlobalIDType = 1
)

func (CellGlobalIDType) EnumDescriptor added in v0.7.63 

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

func (CellGlobalIDType) String added in v0.7.63 

func (x CellGlobalIDType) String() string

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"`
	CellGlobalID *CellGlobalID `protobuf:"bytes,2,opt,name=cell_global_id,json=cellGlobalId,proto3" json:"cell_global_id,omitempty"`
	AntennaCount uint32        `protobuf:"varint,3,opt,name=antenna_count,json=antennaCount,proto3" json:"antenna_count,omitempty"`
	EARFCN       uint32        `protobuf:"varint,4,opt,name=earfcn,proto3" json:"earfcn,omitempty"`
	CellType     string        `protobuf:"bytes,5,opt,name=cell_type,json=cellType,proto3" json:"cell_type,omitempty"`
	PCI          uint32        `protobuf:"varint,6,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) GetCellGlobalID added in v0.7.63 

func (m *E2Cell) GetCellGlobalID() *CellGlobalID

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"`
	// these lists are maintained by the system and are provided as read-only values for clients
	SrcRelationIDs []ID `protobuf:"bytes,2,rep,name=src_relation_ids,json=srcRelationIds,proto3,casttype=ID" json:"src_relation_ids,omitempty"`
	TgtRelationIDs []ID `protobuf:"bytes,3,rep,name=tgt_relation_ids,json=tgtRelationIds,proto3,casttype=ID" json:"tgt_relation_ids,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) GetSrcRelationIDs added in v0.7.85 

func (m *Entity) GetSrcRelationIDs() []ID

func (*Entity) GetTgtRelationIDs added in v0.7.85 

func (m *Entity) GetTgtRelationIDs() []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 {
	KindFilter     *Filter         `protobuf:"bytes,1,opt,name=kind_filter,json=kindFilter,proto3" json:"kind_filter,omitempty"`
	LabelFilters   []*Filter       `protobuf:"bytes,2,rep,name=label_filters,json=labelFilters,proto3" json:"label_filters,omitempty"`
	RelationFilter *RelationFilter `protobuf:"bytes,3,opt,name=relation_filter,json=relationFilter,proto3" json:"relation_filter,omitempty"`
	ObjectTypes    []Object_Type   `` /* 129-byte string literal not displayed */
}

func (*Filters) Descriptor added in v0.7.42 

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

func (*Filters) GetKindFilter added in v0.7.66 

func (m *Filters) GetKindFilter() *Filter

func (*Filters) GetLabelFilters added in v0.7.42 

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

func (*Filters) GetObjectTypes added in v0.7.65 

func (m *Filters) GetObjectTypes() []Object_Type

func (*Filters) GetRelationFilter added in v0.7.64 

func (m *Filters) GetRelationFilter() *RelationFilter

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 represents a client-assigned unique identifier.

func MultiRelationID added in v0.7.80 

func MultiRelationID(srcID ID, relationKind ID, tgtID ID, discriminant uint8) ID

MultiRelationID creates a unique relationship ID from the specified source, kind and target IDs, and also from an additional discriminant to allow for multiples of same kinds of relations between the same two objects.

func RelationID added in v0.7.80 

func RelationID(srcID ID, relationKind ID, tgtID ID) ID

RelationID creates a unique relationship ID from the specified source, kind and target IDs

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"`
	SortOrder SortOrder `protobuf:"varint,2,opt,name=sort_order,json=sortOrder,proto3,enum=onos.topo.SortOrder" json:"sort_order,omitempty"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetFilters added in v0.7.42 

func (m *ListRequest) GetFilters() *Filters

func (*ListRequest) GetSortOrder added in v0.7.79 

func (m *ListRequest) GetSortOrder() SortOrder

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 MHORanFunction added in v0.7.77 

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

func (*MHORanFunction) Descriptor added in v0.7.77 

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

func (*MHORanFunction) GetID added in v0.7.77 

func (m *MHORanFunction) GetID() string

func (*MHORanFunction) GetReportStyles added in v0.7.77 

func (m *MHORanFunction) GetReportStyles() []*MHOReportStyle

func (*MHORanFunction) Marshal added in v0.7.77 

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

func (*MHORanFunction) MarshalTo added in v0.7.77 

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

func (*MHORanFunction) MarshalToSizedBuffer added in v0.7.77 

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

func (*MHORanFunction) ProtoMessage added in v0.7.77 

func (*MHORanFunction) ProtoMessage()

func (*MHORanFunction) Reset added in v0.7.77 

func (m *MHORanFunction) Reset()

func (*MHORanFunction) Size added in v0.7.77 

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

func (*MHORanFunction) String added in v0.7.77 

func (m *MHORanFunction) String() string

func (*MHORanFunction) Unmarshal added in v0.7.77 

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

func (*MHORanFunction) XXX_DiscardUnknown added in v0.7.77 

func (m *MHORanFunction) XXX_DiscardUnknown()

func (*MHORanFunction) XXX_Marshal added in v0.7.77 

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

func (*MHORanFunction) XXX_Merge added in v0.7.77 

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

func (*MHORanFunction) XXX_Size added in v0.7.77 

func (m *MHORanFunction) XXX_Size() int

func (*MHORanFunction) XXX_Unmarshal added in v0.7.77 

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

type MHOReportStyle added in v0.7.77 

type MHOReportStyle 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 (*MHOReportStyle) Descriptor added in v0.7.77 

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

func (*MHOReportStyle) GetName added in v0.7.77 

func (m *MHOReportStyle) GetName() string

func (*MHOReportStyle) GetType added in v0.7.77 

func (m *MHOReportStyle) GetType() int32

func (*MHOReportStyle) Marshal added in v0.7.77 

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

func (*MHOReportStyle) MarshalTo added in v0.7.77 

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

func (*MHOReportStyle) MarshalToSizedBuffer added in v0.7.77 

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

func (*MHOReportStyle) ProtoMessage added in v0.7.77 

func (*MHOReportStyle) ProtoMessage()

func (*MHOReportStyle) Reset added in v0.7.77 

func (m *MHOReportStyle) Reset()

func (*MHOReportStyle) Size added in v0.7.77 

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

func (*MHOReportStyle) String added in v0.7.77 

func (m *MHOReportStyle) String() string

func (*MHOReportStyle) Unmarshal added in v0.7.77 

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

func (*MHOReportStyle) XXX_DiscardUnknown added in v0.7.77 

func (m *MHOReportStyle) XXX_DiscardUnknown()

func (*MHOReportStyle) XXX_Marshal added in v0.7.77 

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

func (*MHOReportStyle) XXX_Merge added in v0.7.77 

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

func (*MHOReportStyle) XXX_Size added in v0.7.77 

func (m *MHOReportStyle) XXX_Size() int

func (*MHOReportStyle) XXX_Unmarshal added in v0.7.77 

func (m *MHOReportStyle) 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 {
	UUID     UUID        `protobuf:"bytes,9,opt,name=uuid,proto3,casttype=UUID" json:"uuid,omitempty"`
	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) GetUUID added in v0.7.85 

func (m *Object) GetUUID() UUID

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

TODO: Deprecate! Use language specific constant definitions instead. Kinds of RAN entities 

const (
	RANEntityKinds_E2NODE RANEntityKinds = 0
	RANEntityKinds_E2CELL RANEntityKinds = 1
	RANEntityKinds_E2T    RANEntityKinds = 3
)

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

TODO: Deprecate! Use language specific constant definitions instead. 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 RelationFilter added in v0.7.64 

type RelationFilter struct {
	SrcId        string              `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"`
	RelationKind string              `protobuf:"bytes,2,opt,name=relation_kind,json=relationKind,proto3" json:"relation_kind,omitempty"`
	TargetKind   string              `protobuf:"bytes,3,opt,name=target_kind,json=targetKind,proto3" json:"target_kind,omitempty"`
	Scope        RelationFilterScope `protobuf:"varint,4,opt,name=scope,proto3,enum=onos.topo.RelationFilterScope" json:"scope,omitempty"`
}

Filter for targets of given relation kinds and given source ids; optionally, filters by specified target kind

func (*RelationFilter) Descriptor added in v0.7.64 

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

func (*RelationFilter) GetRelationKind added in v0.7.64 

func (m *RelationFilter) GetRelationKind() string

func (*RelationFilter) GetScope added in v0.7.81 

func (m *RelationFilter) GetScope() RelationFilterScope

func (*RelationFilter) GetSrcId added in v0.7.64 

func (m *RelationFilter) GetSrcId() string

func (*RelationFilter) GetTargetKind added in v0.7.64 

func (m *RelationFilter) GetTargetKind() string

func (*RelationFilter) Marshal added in v0.7.64 

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

func (*RelationFilter) MarshalTo added in v0.7.64 

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

func (*RelationFilter) MarshalToSizedBuffer added in v0.7.64 

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

func (*RelationFilter) ProtoMessage added in v0.7.64 

func (*RelationFilter) ProtoMessage()

func (*RelationFilter) Reset added in v0.7.64 

func (m *RelationFilter) Reset()

func (*RelationFilter) Size added in v0.7.64 

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

func (*RelationFilter) String added in v0.7.64 

func (m *RelationFilter) String() string

func (*RelationFilter) Unmarshal added in v0.7.64 

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

func (*RelationFilter) XXX_DiscardUnknown added in v0.7.64 

func (m *RelationFilter) XXX_DiscardUnknown()

func (*RelationFilter) XXX_Marshal added in v0.7.64 

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

func (*RelationFilter) XXX_Merge added in v0.7.64 

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

func (*RelationFilter) XXX_Size added in v0.7.64 

func (m *RelationFilter) XXX_Size() int

func (*RelationFilter) XXX_Unmarshal added in v0.7.64 

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

type RelationFilterScope added in v0.7.81 

type RelationFilterScope int32
const (
	RelationFilterScope_TARGET_ONLY       RelationFilterScope = 0
	RelationFilterScope_ALL               RelationFilterScope = 1
	RelationFilterScope_SOURCE_AND_TARGET RelationFilterScope = 2
)

func (RelationFilterScope) EnumDescriptor added in v0.7.81 

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

func (RelationFilterScope) String added in v0.7.81 

func (x RelationFilterScope) String() string

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 SortOrder added in v0.7.79 

type SortOrder int32
const (
	SortOrder_UNORDERED  SortOrder = 0
	SortOrder_ASCENDING  SortOrder = 1
	SortOrder_DESCENDING SortOrder = 2
)

func (SortOrder) EnumDescriptor added in v0.7.79 

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

func (SortOrder) String added in v0.7.79 

func (x SortOrder) 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 UUID added in v0.7.85 

type UUID string

UUID represents a system-assigned unique identifier of a topology object.

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.