Documentation
¶
Index ¶
- func DeserializePath(b []byte) (*table.Path, error)
- func RegisterRIBSApiServer(s *grpc.Server, srv RIBSApiServer)
- func RegisterRIBSCoreApiServer(s *grpc.Server, srv RIBSCoreApiServer)
- func SerializePath(path *table.Path) ([]byte, error)
- type GetNexthopMapRequest
- func (*GetNexthopMapRequest) Descriptor() ([]byte, []int)
- func (*GetNexthopMapRequest) ProtoMessage()
- func (m *GetNexthopMapRequest) Reset()
- func (m *GetNexthopMapRequest) String() string
- func (m *GetNexthopMapRequest) XXX_DiscardUnknown()
- func (m *GetNexthopMapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNexthopMapRequest) XXX_Merge(src proto.Message)
- func (m *GetNexthopMapRequest) XXX_Size() int
- func (m *GetNexthopMapRequest) XXX_Unmarshal(b []byte) error
- type GetNexthopsRequest
- func (*GetNexthopsRequest) Descriptor() ([]byte, []int)
- func (*GetNexthopsRequest) ProtoMessage()
- func (m *GetNexthopsRequest) Reset()
- func (m *GetNexthopsRequest) String() string
- func (m *GetNexthopsRequest) XXX_DiscardUnknown()
- func (m *GetNexthopsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNexthopsRequest) XXX_Merge(src proto.Message)
- func (m *GetNexthopsRequest) XXX_Size() int
- func (m *GetNexthopsRequest) XXX_Unmarshal(b []byte) error
- type GetRicsRequest
- func (*GetRicsRequest) Descriptor() ([]byte, []int)
- func (*GetRicsRequest) ProtoMessage()
- func (m *GetRicsRequest) Reset()
- func (m *GetRicsRequest) String() string
- func (m *GetRicsRequest) XXX_DiscardUnknown()
- func (m *GetRicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRicsRequest) XXX_Merge(src proto.Message)
- func (m *GetRicsRequest) XXX_Size() int
- func (m *GetRicsRequest) XXX_Unmarshal(b []byte) error
- type ModRibReply
- func (*ModRibReply) Descriptor() ([]byte, []int)
- func (*ModRibReply) ProtoMessage()
- func (m *ModRibReply) Reset()
- func (m *ModRibReply) String() string
- func (m *ModRibReply) XXX_DiscardUnknown()
- func (m *ModRibReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModRibReply) XXX_Merge(src proto.Message)
- func (m *ModRibReply) XXX_Size() int
- func (m *ModRibReply) XXX_Unmarshal(b []byte) error
- type MonitorRibRequest
- func (*MonitorRibRequest) Descriptor() ([]byte, []int)
- func (m *MonitorRibRequest) GetNId() uint32
- func (m *MonitorRibRequest) GetRt() string
- func (*MonitorRibRequest) ProtoMessage()
- func (m *MonitorRibRequest) Reset()
- func (m *MonitorRibRequest) String() string
- func (m *MonitorRibRequest) XXX_DiscardUnknown()
- func (m *MonitorRibRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitorRibRequest) XXX_Merge(src proto.Message)
- func (m *MonitorRibRequest) XXX_Size() int
- func (m *MonitorRibRequest) XXX_Unmarshal(b []byte) error
- type Nexthop
- func (*Nexthop) Descriptor() ([]byte, []int)
- func (m *Nexthop) GetAddr() string
- func (m *Nexthop) GetRt() string
- func (m *Nexthop) GetSrcId() string
- func (*Nexthop) ProtoMessage()
- func (m *Nexthop) Reset()
- func (m *Nexthop) String() string
- func (m *Nexthop) XXX_DiscardUnknown()
- func (m *Nexthop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Nexthop) XXX_Merge(src proto.Message)
- func (m *Nexthop) XXX_Size() int
- func (m *Nexthop) XXX_Unmarshal(b []byte) error
- type NexthopMap
- func (*NexthopMap) Descriptor() ([]byte, []int)
- func (m *NexthopMap) GetKey() string
- func (m *NexthopMap) GetVal() string
- func (*NexthopMap) ProtoMessage()
- func (m *NexthopMap) Reset()
- func (m *NexthopMap) String() string
- func (m *NexthopMap) XXX_DiscardUnknown()
- func (m *NexthopMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NexthopMap) XXX_Merge(src proto.Message)
- func (m *NexthopMap) XXX_Size() int
- func (m *NexthopMap) XXX_Unmarshal(b []byte) error
- type Path
- func (*Path) Descriptor() ([]byte, []int)
- func (m *Path) GetNexthop() string
- func (m *Path) GetPrefix() string
- func (*Path) ProtoMessage()
- func (m *Path) Reset()
- func (m *Path) String() string
- func (m *Path) XXX_DiscardUnknown()
- func (m *Path) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Path) XXX_Merge(src proto.Message)
- func (m *Path) XXX_Size() int
- func (m *Path) XXX_Unmarshal(b []byte) error
- type RIBSApiClient
- type RIBSApiServer
- type RIBSApi_GetNexthopMapClient
- type RIBSApi_GetNexthopMapServer
- type RIBSApi_GetNexthopsClient
- type RIBSApi_GetNexthopsServer
- type RIBSApi_GetRicsClient
- type RIBSApi_GetRicsServer
- type RIBSCoreApiClient
- type RIBSCoreApiServer
- type RIBSCoreApi_MonitorRibClient
- type RIBSCoreApi_MonitorRibServer
- type RibUpdate
- func (*RibUpdate) Descriptor() ([]byte, []int)
- func (m *RibUpdate) GetPaths() [][]byte
- func (m *RibUpdate) GetPrefix() string
- func (m *RibUpdate) GetRt() string
- func (*RibUpdate) ProtoMessage()
- func (m *RibUpdate) Reset()
- func (m *RibUpdate) String() string
- func (r *RibUpdate) ToNative() (*ribsmsg.RibUpdate, error)
- func (m *RibUpdate) XXX_DiscardUnknown()
- func (m *RibUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RibUpdate) XXX_Merge(src proto.Message)
- func (m *RibUpdate) XXX_Size() int
- func (m *RibUpdate) XXX_Unmarshal(b []byte) error
- type RicEntry
- func (*RicEntry) Descriptor() ([]byte, []int)
- func (m *RicEntry) GetAddr() string
- func (m *RicEntry) GetKey() string
- func (m *RicEntry) GetLabel() uint32
- func (m *RicEntry) GetNId() uint32
- func (m *RicEntry) GetPort() uint32
- func (m *RicEntry) GetRd() string
- func (m *RicEntry) GetRt() string
- func (*RicEntry) ProtoMessage()
- func (m *RicEntry) Reset()
- func (m *RicEntry) String() string
- func (m *RicEntry) XXX_DiscardUnknown()
- func (m *RicEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RicEntry) XXX_Merge(src proto.Message)
- func (m *RicEntry) XXX_Size() int
- func (m *RicEntry) XXX_Unmarshal(b []byte) error
- type SyncRibReply
- func (*SyncRibReply) Descriptor() ([]byte, []int)
- func (*SyncRibReply) ProtoMessage()
- func (m *SyncRibReply) Reset()
- func (m *SyncRibReply) String() string
- func (m *SyncRibReply) XXX_DiscardUnknown()
- func (m *SyncRibReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRibReply) XXX_Merge(src proto.Message)
- func (m *SyncRibReply) XXX_Size() int
- func (m *SyncRibReply) XXX_Unmarshal(b []byte) error
- type SyncRibRequest
- func (*SyncRibRequest) Descriptor() ([]byte, []int)
- func (m *SyncRibRequest) GetRt() string
- func (*SyncRibRequest) ProtoMessage()
- func (m *SyncRibRequest) Reset()
- func (m *SyncRibRequest) String() string
- func (m *SyncRibRequest) XXX_DiscardUnknown()
- func (m *SyncRibRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRibRequest) XXX_Merge(src proto.Message)
- func (m *SyncRibRequest) XXX_Size() int
- func (m *SyncRibRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedRIBSApiServer
- func (*UnimplementedRIBSApiServer) GetNexthopMap(req *GetNexthopMapRequest, srv RIBSApi_GetNexthopMapServer) error
- func (*UnimplementedRIBSApiServer) GetNexthops(req *GetNexthopsRequest, srv RIBSApi_GetNexthopsServer) error
- func (*UnimplementedRIBSApiServer) GetRics(req *GetRicsRequest, srv RIBSApi_GetRicsServer) error
- type UnimplementedRIBSCoreApiServer
- func (*UnimplementedRIBSCoreApiServer) ModRib(ctx context.Context, req *RibUpdate) (*ModRibReply, error)
- func (*UnimplementedRIBSCoreApiServer) MonitorRib(req *MonitorRibRequest, srv RIBSCoreApi_MonitorRibServer) error
- func (*UnimplementedRIBSCoreApiServer) SyncRib(ctx context.Context, req *SyncRibRequest) (*SyncRibReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterRIBSApiServer ¶
func RegisterRIBSApiServer(s *grpc.Server, srv RIBSApiServer)
func RegisterRIBSCoreApiServer ¶
func RegisterRIBSCoreApiServer(s *grpc.Server, srv RIBSCoreApiServer)
Types ¶
type GetNexthopMapRequest ¶
type GetNexthopMapRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetNexthopMapRequest) Descriptor ¶
func (*GetNexthopMapRequest) Descriptor() ([]byte, []int)
func (*GetNexthopMapRequest) ProtoMessage ¶
func (*GetNexthopMapRequest) ProtoMessage()
func (*GetNexthopMapRequest) Reset ¶
func (m *GetNexthopMapRequest) Reset()
func (*GetNexthopMapRequest) String ¶
func (m *GetNexthopMapRequest) String() string
func (*GetNexthopMapRequest) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *GetNexthopMapRequest) XXX_DiscardUnknown()
func (*GetNexthopMapRequest) XXX_Marshal ¶ added in v0.3.1
func (m *GetNexthopMapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetNexthopMapRequest) XXX_Merge ¶ added in v0.3.1
func (m *GetNexthopMapRequest) XXX_Merge(src proto.Message)
func (*GetNexthopMapRequest) XXX_Size ¶ added in v0.3.1
func (m *GetNexthopMapRequest) XXX_Size() int
func (*GetNexthopMapRequest) XXX_Unmarshal ¶ added in v0.3.1
func (m *GetNexthopMapRequest) XXX_Unmarshal(b []byte) error
type GetNexthopsRequest ¶
type GetNexthopsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetNexthopsRequest) Descriptor ¶
func (*GetNexthopsRequest) Descriptor() ([]byte, []int)
func (*GetNexthopsRequest) ProtoMessage ¶
func (*GetNexthopsRequest) ProtoMessage()
func (*GetNexthopsRequest) Reset ¶
func (m *GetNexthopsRequest) Reset()
func (*GetNexthopsRequest) String ¶
func (m *GetNexthopsRequest) String() string
func (*GetNexthopsRequest) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *GetNexthopsRequest) XXX_DiscardUnknown()
func (*GetNexthopsRequest) XXX_Marshal ¶ added in v0.3.1
func (m *GetNexthopsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetNexthopsRequest) XXX_Merge ¶ added in v0.3.1
func (m *GetNexthopsRequest) XXX_Merge(src proto.Message)
func (*GetNexthopsRequest) XXX_Size ¶ added in v0.3.1
func (m *GetNexthopsRequest) XXX_Size() int
func (*GetNexthopsRequest) XXX_Unmarshal ¶ added in v0.3.1
func (m *GetNexthopsRequest) XXX_Unmarshal(b []byte) error
type GetRicsRequest ¶
type GetRicsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRicsRequest) Descriptor ¶
func (*GetRicsRequest) Descriptor() ([]byte, []int)
func (*GetRicsRequest) ProtoMessage ¶
func (*GetRicsRequest) ProtoMessage()
func (*GetRicsRequest) Reset ¶
func (m *GetRicsRequest) Reset()
func (*GetRicsRequest) String ¶
func (m *GetRicsRequest) String() string
func (*GetRicsRequest) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *GetRicsRequest) XXX_DiscardUnknown()
func (*GetRicsRequest) XXX_Marshal ¶ added in v0.3.1
func (m *GetRicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRicsRequest) XXX_Merge ¶ added in v0.3.1
func (m *GetRicsRequest) XXX_Merge(src proto.Message)
func (*GetRicsRequest) XXX_Size ¶ added in v0.3.1
func (m *GetRicsRequest) XXX_Size() int
func (*GetRicsRequest) XXX_Unmarshal ¶ added in v0.3.1
func (m *GetRicsRequest) XXX_Unmarshal(b []byte) error
type ModRibReply ¶
type ModRibReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModRibReply) Descriptor ¶
func (*ModRibReply) Descriptor() ([]byte, []int)
func (*ModRibReply) ProtoMessage ¶
func (*ModRibReply) ProtoMessage()
func (*ModRibReply) Reset ¶
func (m *ModRibReply) Reset()
func (*ModRibReply) String ¶
func (m *ModRibReply) String() string
func (*ModRibReply) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *ModRibReply) XXX_DiscardUnknown()
func (*ModRibReply) XXX_Marshal ¶ added in v0.3.1
func (m *ModRibReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModRibReply) XXX_Merge ¶ added in v0.3.1
func (m *ModRibReply) XXX_Merge(src proto.Message)
func (*ModRibReply) XXX_Size ¶ added in v0.3.1
func (m *ModRibReply) XXX_Size() int
func (*ModRibReply) XXX_Unmarshal ¶ added in v0.3.1
func (m *ModRibReply) XXX_Unmarshal(b []byte) error
type MonitorRibRequest ¶
type MonitorRibRequest struct { Rt string `protobuf:"bytes,1,opt,name=rt,proto3" json:"rt,omitempty"` NId uint32 `protobuf:"varint,2,opt,name=n_id,json=nId,proto3" json:"n_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitorRibRequest) Descriptor ¶
func (*MonitorRibRequest) Descriptor() ([]byte, []int)
func (*MonitorRibRequest) GetNId ¶
func (m *MonitorRibRequest) GetNId() uint32
func (*MonitorRibRequest) GetRt ¶
func (m *MonitorRibRequest) GetRt() string
func (*MonitorRibRequest) ProtoMessage ¶
func (*MonitorRibRequest) ProtoMessage()
func (*MonitorRibRequest) Reset ¶
func (m *MonitorRibRequest) Reset()
func (*MonitorRibRequest) String ¶
func (m *MonitorRibRequest) String() string
func (*MonitorRibRequest) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *MonitorRibRequest) XXX_DiscardUnknown()
func (*MonitorRibRequest) XXX_Marshal ¶ added in v0.3.1
func (m *MonitorRibRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitorRibRequest) XXX_Merge ¶ added in v0.3.1
func (m *MonitorRibRequest) XXX_Merge(src proto.Message)
func (*MonitorRibRequest) XXX_Size ¶ added in v0.3.1
func (m *MonitorRibRequest) XXX_Size() int
func (*MonitorRibRequest) XXX_Unmarshal ¶ added in v0.3.1
func (m *MonitorRibRequest) XXX_Unmarshal(b []byte) error
type Nexthop ¶
type Nexthop struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` Rt string `protobuf:"bytes,2,opt,name=rt,proto3" json:"rt,omitempty"` SrcId string `protobuf:"bytes,3,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewNexthopFromNative ¶
func (*Nexthop) Descriptor ¶
func (*Nexthop) ProtoMessage ¶
func (*Nexthop) ProtoMessage()
func (*Nexthop) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *Nexthop) XXX_DiscardUnknown()
func (*Nexthop) XXX_Marshal ¶ added in v0.3.1
func (*Nexthop) XXX_Unmarshal ¶ added in v0.3.1
type NexthopMap ¶
type NexthopMap struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Val string `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewNexthopMapFromNative ¶
func NewNexthopMapFromNative(key string, val string) *NexthopMap
func (*NexthopMap) Descriptor ¶
func (*NexthopMap) Descriptor() ([]byte, []int)
func (*NexthopMap) GetKey ¶
func (m *NexthopMap) GetKey() string
func (*NexthopMap) GetVal ¶
func (m *NexthopMap) GetVal() string
func (*NexthopMap) ProtoMessage ¶
func (*NexthopMap) ProtoMessage()
func (*NexthopMap) Reset ¶
func (m *NexthopMap) Reset()
func (*NexthopMap) String ¶
func (m *NexthopMap) String() string
func (*NexthopMap) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *NexthopMap) XXX_DiscardUnknown()
func (*NexthopMap) XXX_Marshal ¶ added in v0.3.1
func (m *NexthopMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NexthopMap) XXX_Merge ¶ added in v0.3.1
func (m *NexthopMap) XXX_Merge(src proto.Message)
func (*NexthopMap) XXX_Size ¶ added in v0.3.1
func (m *NexthopMap) XXX_Size() int
func (*NexthopMap) XXX_Unmarshal ¶ added in v0.3.1
func (m *NexthopMap) XXX_Unmarshal(b []byte) error
type Path ¶
type Path struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Nexthop string `protobuf:"bytes,2,opt,name=nexthop,proto3" json:"nexthop,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPathFromNative ¶
func (*Path) Descriptor ¶
func (*Path) GetNexthop ¶
func (*Path) ProtoMessage ¶
func (*Path) ProtoMessage()
func (*Path) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *Path) XXX_DiscardUnknown()
func (*Path) XXX_Marshal ¶ added in v0.3.1
func (*Path) XXX_Unmarshal ¶ added in v0.3.1
type RIBSApiClient ¶
type RIBSApiClient interface { GetRics(ctx context.Context, in *GetRicsRequest, opts ...grpc.CallOption) (RIBSApi_GetRicsClient, error) GetNexthops(ctx context.Context, in *GetNexthopsRequest, opts ...grpc.CallOption) (RIBSApi_GetNexthopsClient, error) GetNexthopMap(ctx context.Context, in *GetNexthopMapRequest, opts ...grpc.CallOption) (RIBSApi_GetNexthopMapClient, error) }
RIBSApiClient is the client API for RIBSApi service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRIBSApiClient ¶
func NewRIBSApiClient(cc *grpc.ClientConn) RIBSApiClient
type RIBSApiServer ¶
type RIBSApiServer interface { GetRics(*GetRicsRequest, RIBSApi_GetRicsServer) error GetNexthops(*GetNexthopsRequest, RIBSApi_GetNexthopsServer) error GetNexthopMap(*GetNexthopMapRequest, RIBSApi_GetNexthopMapServer) error }
RIBSApiServer is the server API for RIBSApi service.
type RIBSApi_GetNexthopMapClient ¶
type RIBSApi_GetNexthopMapClient interface { Recv() (*NexthopMap, error) grpc.ClientStream }
type RIBSApi_GetNexthopMapServer ¶
type RIBSApi_GetNexthopMapServer interface { Send(*NexthopMap) error grpc.ServerStream }
type RIBSApi_GetNexthopsClient ¶
type RIBSApi_GetNexthopsClient interface { Recv() (*Nexthop, error) grpc.ClientStream }
type RIBSApi_GetNexthopsServer ¶
type RIBSApi_GetNexthopsServer interface { Send(*Nexthop) error grpc.ServerStream }
type RIBSApi_GetRicsClient ¶
type RIBSApi_GetRicsClient interface { Recv() (*RicEntry, error) grpc.ClientStream }
type RIBSApi_GetRicsServer ¶
type RIBSApi_GetRicsServer interface { Send(*RicEntry) error grpc.ServerStream }
type RIBSCoreApiClient ¶
type RIBSCoreApiClient interface { ModRib(ctx context.Context, in *RibUpdate, opts ...grpc.CallOption) (*ModRibReply, error) MonitorRib(ctx context.Context, in *MonitorRibRequest, opts ...grpc.CallOption) (RIBSCoreApi_MonitorRibClient, error) SyncRib(ctx context.Context, in *SyncRibRequest, opts ...grpc.CallOption) (*SyncRibReply, error) }
RIBSCoreApiClient is the client API for RIBSCoreApi service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRIBSCoreApiClient ¶
func NewRIBSCoreApiClient(cc *grpc.ClientConn) RIBSCoreApiClient
type RIBSCoreApiServer ¶
type RIBSCoreApiServer interface { ModRib(context.Context, *RibUpdate) (*ModRibReply, error) MonitorRib(*MonitorRibRequest, RIBSCoreApi_MonitorRibServer) error SyncRib(context.Context, *SyncRibRequest) (*SyncRibReply, error) }
RIBSCoreApiServer is the server API for RIBSCoreApi service.
type RIBSCoreApi_MonitorRibClient ¶
type RIBSCoreApi_MonitorRibClient interface { Recv() (*RibUpdate, error) grpc.ClientStream }
type RIBSCoreApi_MonitorRibServer ¶
type RIBSCoreApi_MonitorRibServer interface { Send(*RibUpdate) error grpc.ServerStream }
type RibUpdate ¶
type RibUpdate struct { Rt string `protobuf:"bytes,1,opt,name=rt,proto3" json:"rt,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` Paths [][]byte `protobuf:"bytes,3,rep,name=paths,proto3" json:"paths,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewRibUpdateFromNative ¶
func (*RibUpdate) Descriptor ¶
func (*RibUpdate) ProtoMessage ¶
func (*RibUpdate) ProtoMessage()
func (*RibUpdate) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *RibUpdate) XXX_DiscardUnknown()
func (*RibUpdate) XXX_Marshal ¶ added in v0.3.1
func (*RibUpdate) XXX_Unmarshal ¶ added in v0.3.1
type RicEntry ¶
type RicEntry struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` NId uint32 `protobuf:"varint,2,opt,name=n_id,json=nId,proto3" json:"n_id,omitempty"` Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"` Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"` Rt string `protobuf:"bytes,5,opt,name=rt,proto3" json:"rt,omitempty"` Rd string `protobuf:"bytes,6,opt,name=rd,proto3" json:"rd,omitempty"` Label uint32 `protobuf:"varint,7,opt,name=label,proto3" json:"label,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RicEntry) Descriptor ¶
func (*RicEntry) ProtoMessage ¶
func (*RicEntry) ProtoMessage()
func (*RicEntry) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *RicEntry) XXX_DiscardUnknown()
func (*RicEntry) XXX_Marshal ¶ added in v0.3.1
func (*RicEntry) XXX_Unmarshal ¶ added in v0.3.1
type SyncRibReply ¶
type SyncRibReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncRibReply) Descriptor ¶
func (*SyncRibReply) Descriptor() ([]byte, []int)
func (*SyncRibReply) ProtoMessage ¶
func (*SyncRibReply) ProtoMessage()
func (*SyncRibReply) Reset ¶
func (m *SyncRibReply) Reset()
func (*SyncRibReply) String ¶
func (m *SyncRibReply) String() string
func (*SyncRibReply) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *SyncRibReply) XXX_DiscardUnknown()
func (*SyncRibReply) XXX_Marshal ¶ added in v0.3.1
func (m *SyncRibReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRibReply) XXX_Merge ¶ added in v0.3.1
func (m *SyncRibReply) XXX_Merge(src proto.Message)
func (*SyncRibReply) XXX_Size ¶ added in v0.3.1
func (m *SyncRibReply) XXX_Size() int
func (*SyncRibReply) XXX_Unmarshal ¶ added in v0.3.1
func (m *SyncRibReply) XXX_Unmarshal(b []byte) error
type SyncRibRequest ¶
type SyncRibRequest struct { Rt string `protobuf:"bytes,1,opt,name=rt,proto3" json:"rt,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncRibRequest) Descriptor ¶
func (*SyncRibRequest) Descriptor() ([]byte, []int)
func (*SyncRibRequest) GetRt ¶
func (m *SyncRibRequest) GetRt() string
func (*SyncRibRequest) ProtoMessage ¶
func (*SyncRibRequest) ProtoMessage()
func (*SyncRibRequest) Reset ¶
func (m *SyncRibRequest) Reset()
func (*SyncRibRequest) String ¶
func (m *SyncRibRequest) String() string
func (*SyncRibRequest) XXX_DiscardUnknown ¶ added in v0.3.1
func (m *SyncRibRequest) XXX_DiscardUnknown()
func (*SyncRibRequest) XXX_Marshal ¶ added in v0.3.1
func (m *SyncRibRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRibRequest) XXX_Merge ¶ added in v0.3.1
func (m *SyncRibRequest) XXX_Merge(src proto.Message)
func (*SyncRibRequest) XXX_Size ¶ added in v0.3.1
func (m *SyncRibRequest) XXX_Size() int
func (*SyncRibRequest) XXX_Unmarshal ¶ added in v0.3.1
func (m *SyncRibRequest) XXX_Unmarshal(b []byte) error
type UnimplementedRIBSApiServer ¶ added in v0.4.0
type UnimplementedRIBSApiServer struct { }
UnimplementedRIBSApiServer can be embedded to have forward compatible implementations.
func (*UnimplementedRIBSApiServer) GetNexthopMap ¶ added in v0.4.0
func (*UnimplementedRIBSApiServer) GetNexthopMap(req *GetNexthopMapRequest, srv RIBSApi_GetNexthopMapServer) error
func (*UnimplementedRIBSApiServer) GetNexthops ¶ added in v0.4.0
func (*UnimplementedRIBSApiServer) GetNexthops(req *GetNexthopsRequest, srv RIBSApi_GetNexthopsServer) error
func (*UnimplementedRIBSApiServer) GetRics ¶ added in v0.4.0
func (*UnimplementedRIBSApiServer) GetRics(req *GetRicsRequest, srv RIBSApi_GetRicsServer) error
type UnimplementedRIBSCoreApiServer ¶ added in v0.4.0
type UnimplementedRIBSCoreApiServer struct { }
UnimplementedRIBSCoreApiServer can be embedded to have forward compatible implementations.
func (*UnimplementedRIBSCoreApiServer) ModRib ¶ added in v0.4.0
func (*UnimplementedRIBSCoreApiServer) ModRib(ctx context.Context, req *RibUpdate) (*ModRibReply, error)
func (*UnimplementedRIBSCoreApiServer) MonitorRib ¶ added in v0.4.0
func (*UnimplementedRIBSCoreApiServer) MonitorRib(req *MonitorRibRequest, srv RIBSCoreApi_MonitorRibServer) error
func (*UnimplementedRIBSCoreApiServer) SyncRib ¶ added in v0.4.0
func (*UnimplementedRIBSCoreApiServer) SyncRib(ctx context.Context, req *SyncRibRequest) (*SyncRibReply, error)