Documentation ¶
Index ¶
- Variables
- func RegisterTrafficServer(s *grpc.Server, srv TrafficServer)
- type ListRoutesRequest
- func (*ListRoutesRequest) Descriptor() ([]byte, []int)
- func (m *ListRoutesRequest) GetNoReplay() bool
- func (m *ListRoutesRequest) GetNoSubscribe() bool
- func (m *ListRoutesRequest) Marshal() (dAtA []byte, err error)
- func (m *ListRoutesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListRoutesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListRoutesRequest) ProtoMessage()
- func (m *ListRoutesRequest) Reset()
- func (m *ListRoutesRequest) Size() (n int)
- func (m *ListRoutesRequest) String() string
- func (m *ListRoutesRequest) Unmarshal(dAtA []byte) error
- func (m *ListRoutesRequest) XXX_DiscardUnknown()
- func (m *ListRoutesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRoutesRequest) XXX_Merge(src proto.Message)
- func (m *ListRoutesRequest) XXX_Size() int
- func (m *ListRoutesRequest) XXX_Unmarshal(b []byte) error
- type ListRoutesResponse
- func (*ListRoutesResponse) Descriptor() ([]byte, []int)
- func (m *ListRoutesResponse) GetRoute() *types.Route
- func (m *ListRoutesResponse) GetType() Type
- func (m *ListRoutesResponse) Marshal() (dAtA []byte, err error)
- func (m *ListRoutesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListRoutesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListRoutesResponse) ProtoMessage()
- func (m *ListRoutesResponse) Reset()
- func (m *ListRoutesResponse) Size() (n int)
- func (m *ListRoutesResponse) String() string
- func (m *ListRoutesResponse) Unmarshal(dAtA []byte) error
- func (m *ListRoutesResponse) XXX_DiscardUnknown()
- func (m *ListRoutesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRoutesResponse) XXX_Merge(src proto.Message)
- func (m *ListRoutesResponse) XXX_Size() int
- func (m *ListRoutesResponse) XXX_Unmarshal(b []byte) error
- type ListUesRequest
- func (*ListUesRequest) Descriptor() ([]byte, []int)
- func (m *ListUesRequest) Marshal() (dAtA []byte, err error)
- func (m *ListUesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListUesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListUesRequest) ProtoMessage()
- func (m *ListUesRequest) Reset()
- func (m *ListUesRequest) Size() (n int)
- func (m *ListUesRequest) String() string
- func (m *ListUesRequest) Unmarshal(dAtA []byte) error
- func (m *ListUesRequest) XXX_DiscardUnknown()
- func (m *ListUesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListUesRequest) XXX_Merge(src proto.Message)
- func (m *ListUesRequest) XXX_Size() int
- func (m *ListUesRequest) XXX_Unmarshal(b []byte) error
- type ListUesResponse
- func (*ListUesResponse) Descriptor() ([]byte, []int)
- func (m *ListUesResponse) GetUe() *types.Ue
- func (m *ListUesResponse) Marshal() (dAtA []byte, err error)
- func (m *ListUesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListUesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListUesResponse) ProtoMessage()
- func (m *ListUesResponse) Reset()
- func (m *ListUesResponse) Size() (n int)
- func (m *ListUesResponse) String() string
- func (m *ListUesResponse) Unmarshal(dAtA []byte) error
- func (m *ListUesResponse) XXX_DiscardUnknown()
- func (m *ListUesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListUesResponse) XXX_Merge(src proto.Message)
- func (m *ListUesResponse) XXX_Size() int
- func (m *ListUesResponse) XXX_Unmarshal(b []byte) error
- type MapLayoutRequest
- func (*MapLayoutRequest) Descriptor() ([]byte, []int)
- func (m *MapLayoutRequest) Marshal() (dAtA []byte, err error)
- func (m *MapLayoutRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MapLayoutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MapLayoutRequest) ProtoMessage()
- func (m *MapLayoutRequest) Reset()
- func (m *MapLayoutRequest) Size() (n int)
- func (m *MapLayoutRequest) String() string
- func (m *MapLayoutRequest) Unmarshal(dAtA []byte) error
- func (m *MapLayoutRequest) XXX_DiscardUnknown()
- func (m *MapLayoutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MapLayoutRequest) XXX_Merge(src proto.Message)
- func (m *MapLayoutRequest) XXX_Size() int
- func (m *MapLayoutRequest) XXX_Unmarshal(b []byte) error
- type ResetMetricsMsg
- func (*ResetMetricsMsg) Descriptor() ([]byte, []int)
- func (m *ResetMetricsMsg) Marshal() (dAtA []byte, err error)
- func (m *ResetMetricsMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *ResetMetricsMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResetMetricsMsg) ProtoMessage()
- func (m *ResetMetricsMsg) Reset()
- func (m *ResetMetricsMsg) Size() (n int)
- func (m *ResetMetricsMsg) String() string
- func (m *ResetMetricsMsg) Unmarshal(dAtA []byte) error
- func (m *ResetMetricsMsg) XXX_DiscardUnknown()
- func (m *ResetMetricsMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResetMetricsMsg) XXX_Merge(src proto.Message)
- func (m *ResetMetricsMsg) XXX_Size() int
- func (m *ResetMetricsMsg) XXX_Unmarshal(b []byte) error
- type SetNumberUEsRequest
- func (*SetNumberUEsRequest) Descriptor() ([]byte, []int)
- func (m *SetNumberUEsRequest) GetNumber() uint32
- func (m *SetNumberUEsRequest) Marshal() (dAtA []byte, err error)
- func (m *SetNumberUEsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetNumberUEsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetNumberUEsRequest) ProtoMessage()
- func (m *SetNumberUEsRequest) Reset()
- func (m *SetNumberUEsRequest) Size() (n int)
- func (m *SetNumberUEsRequest) String() string
- func (m *SetNumberUEsRequest) Unmarshal(dAtA []byte) error
- func (m *SetNumberUEsRequest) XXX_DiscardUnknown()
- func (m *SetNumberUEsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetNumberUEsRequest) XXX_Merge(src proto.Message)
- func (m *SetNumberUEsRequest) XXX_Size() int
- func (m *SetNumberUEsRequest) XXX_Unmarshal(b []byte) error
- type SetNumberUEsResponse
- func (*SetNumberUEsResponse) Descriptor() ([]byte, []int)
- func (m *SetNumberUEsResponse) GetNumber() uint32
- func (m *SetNumberUEsResponse) Marshal() (dAtA []byte, err error)
- func (m *SetNumberUEsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetNumberUEsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetNumberUEsResponse) ProtoMessage()
- func (m *SetNumberUEsResponse) Reset()
- func (m *SetNumberUEsResponse) Size() (n int)
- func (m *SetNumberUEsResponse) String() string
- func (m *SetNumberUEsResponse) Unmarshal(dAtA []byte) error
- func (m *SetNumberUEsResponse) XXX_DiscardUnknown()
- func (m *SetNumberUEsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetNumberUEsResponse) XXX_Merge(src proto.Message)
- func (m *SetNumberUEsResponse) XXX_Size() int
- func (m *SetNumberUEsResponse) XXX_Unmarshal(b []byte) error
- type TrafficClient
- type TrafficServer
- type Traffic_ListRoutesClient
- type Traffic_ListRoutesServer
- type Traffic_ListUesClient
- type Traffic_ListUesServer
- type Traffic_WatchUesClient
- type Traffic_WatchUesServer
- type Type
- type UnimplementedTrafficServer
- func (*UnimplementedTrafficServer) GetMapLayout(ctx context.Context, req *MapLayoutRequest) (*types.MapLayout, error)
- func (*UnimplementedTrafficServer) ListRoutes(req *ListRoutesRequest, srv Traffic_ListRoutesServer) error
- func (*UnimplementedTrafficServer) ListUes(req *ListUesRequest, srv Traffic_ListUesServer) error
- func (*UnimplementedTrafficServer) ResetMetrics(ctx context.Context, req *ResetMetricsMsg) (*ResetMetricsMsg, error)
- func (*UnimplementedTrafficServer) SetNumberUEs(ctx context.Context, req *SetNumberUEsRequest) (*SetNumberUEsResponse, error)
- func (*UnimplementedTrafficServer) WatchUes(req *WatchUesRequest, srv Traffic_WatchUesServer) error
- type UpdateType
- type WatchUesRequest
- func (*WatchUesRequest) Descriptor() ([]byte, []int)
- func (m *WatchUesRequest) GetNoReplay() bool
- func (m *WatchUesRequest) GetNoSubscribe() bool
- func (m *WatchUesRequest) Marshal() (dAtA []byte, err error)
- func (m *WatchUesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchUesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchUesRequest) ProtoMessage()
- func (m *WatchUesRequest) Reset()
- func (m *WatchUesRequest) Size() (n int)
- func (m *WatchUesRequest) String() string
- func (m *WatchUesRequest) Unmarshal(dAtA []byte) error
- func (m *WatchUesRequest) XXX_DiscardUnknown()
- func (m *WatchUesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchUesRequest) XXX_Merge(src proto.Message)
- func (m *WatchUesRequest) XXX_Size() int
- func (m *WatchUesRequest) XXX_Unmarshal(b []byte) error
- type WatchUesResponse
- func (*WatchUesResponse) Descriptor() ([]byte, []int)
- func (m *WatchUesResponse) GetType() Type
- func (m *WatchUesResponse) GetUe() *types.Ue
- func (m *WatchUesResponse) GetUpdateType() UpdateType
- func (m *WatchUesResponse) Marshal() (dAtA []byte, err error)
- func (m *WatchUesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchUesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchUesResponse) ProtoMessage()
- func (m *WatchUesResponse) Reset()
- func (m *WatchUesResponse) Size() (n int)
- func (m *WatchUesResponse) String() string
- func (m *WatchUesResponse) Unmarshal(dAtA []byte) error
- func (m *WatchUesResponse) XXX_DiscardUnknown()
- func (m *WatchUesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchUesResponse) XXX_Merge(src proto.Message)
- func (m *WatchUesResponse) XXX_Size() int
- func (m *WatchUesResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthTrafficsim = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTrafficsim = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTrafficsim = fmt.Errorf("proto: unexpected end of group") )
View Source
var Type_name = map[int32]string{
0: "NONE",
1: "ADDED",
2: "UPDATED",
3: "REMOVED",
}
View Source
var Type_value = map[string]int32{
"NONE": 0,
"ADDED": 1,
"UPDATED": 2,
"REMOVED": 3,
}
View Source
var UpdateType_name = map[int32]string{
0: "NOUPDATETYPE",
1: "POSITION",
2: "TOWER",
3: "HANDOVER",
}
View Source
var UpdateType_value = map[string]int32{
"NOUPDATETYPE": 0,
"POSITION": 1,
"TOWER": 2,
"HANDOVER": 3,
}
Functions ¶
func RegisterTrafficServer ¶
func RegisterTrafficServer(s *grpc.Server, srv TrafficServer)
Types ¶
type ListRoutesRequest ¶
type ListRoutesRequest struct { NoReplay bool `protobuf:"varint,1,opt,name=no_replay,json=noReplay,proto3" json:"no_replay,omitempty"` NoSubscribe bool `protobuf:"varint,2,opt,name=no_subscribe,json=noSubscribe,proto3" json:"no_subscribe,omitempty"` }
func (*ListRoutesRequest) Descriptor ¶
func (*ListRoutesRequest) Descriptor() ([]byte, []int)
func (*ListRoutesRequest) GetNoReplay ¶
func (m *ListRoutesRequest) GetNoReplay() bool
func (*ListRoutesRequest) GetNoSubscribe ¶
func (m *ListRoutesRequest) GetNoSubscribe() bool
func (*ListRoutesRequest) Marshal ¶
func (m *ListRoutesRequest) Marshal() (dAtA []byte, err error)
func (*ListRoutesRequest) MarshalTo ¶
func (m *ListRoutesRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListRoutesRequest) MarshalToSizedBuffer ¶
func (m *ListRoutesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListRoutesRequest) ProtoMessage ¶
func (*ListRoutesRequest) ProtoMessage()
func (*ListRoutesRequest) Reset ¶
func (m *ListRoutesRequest) Reset()
func (*ListRoutesRequest) Size ¶
func (m *ListRoutesRequest) Size() (n int)
func (*ListRoutesRequest) String ¶
func (m *ListRoutesRequest) String() string
func (*ListRoutesRequest) Unmarshal ¶
func (m *ListRoutesRequest) Unmarshal(dAtA []byte) error
func (*ListRoutesRequest) XXX_DiscardUnknown ¶
func (m *ListRoutesRequest) XXX_DiscardUnknown()
func (*ListRoutesRequest) XXX_Marshal ¶
func (m *ListRoutesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRoutesRequest) XXX_Merge ¶
func (m *ListRoutesRequest) XXX_Merge(src proto.Message)
func (*ListRoutesRequest) XXX_Size ¶
func (m *ListRoutesRequest) XXX_Size() int
func (*ListRoutesRequest) XXX_Unmarshal ¶
func (m *ListRoutesRequest) XXX_Unmarshal(b []byte) error
type ListRoutesResponse ¶
type ListRoutesResponse struct { // route is the route change on which the event occurred Route *types.Route `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"` // type is a qualification of the type of change being made Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=onos.ransim.trafficsim.Type" json:"type,omitempty"` }
func (*ListRoutesResponse) Descriptor ¶
func (*ListRoutesResponse) Descriptor() ([]byte, []int)
func (*ListRoutesResponse) GetRoute ¶
func (m *ListRoutesResponse) GetRoute() *types.Route
func (*ListRoutesResponse) GetType ¶
func (m *ListRoutesResponse) GetType() Type
func (*ListRoutesResponse) Marshal ¶
func (m *ListRoutesResponse) Marshal() (dAtA []byte, err error)
func (*ListRoutesResponse) MarshalTo ¶
func (m *ListRoutesResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListRoutesResponse) MarshalToSizedBuffer ¶
func (m *ListRoutesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListRoutesResponse) ProtoMessage ¶
func (*ListRoutesResponse) ProtoMessage()
func (*ListRoutesResponse) Reset ¶
func (m *ListRoutesResponse) Reset()
func (*ListRoutesResponse) Size ¶
func (m *ListRoutesResponse) Size() (n int)
func (*ListRoutesResponse) String ¶
func (m *ListRoutesResponse) String() string
func (*ListRoutesResponse) Unmarshal ¶
func (m *ListRoutesResponse) Unmarshal(dAtA []byte) error
func (*ListRoutesResponse) XXX_DiscardUnknown ¶
func (m *ListRoutesResponse) XXX_DiscardUnknown()
func (*ListRoutesResponse) XXX_Marshal ¶
func (m *ListRoutesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRoutesResponse) XXX_Merge ¶
func (m *ListRoutesResponse) XXX_Merge(src proto.Message)
func (*ListRoutesResponse) XXX_Size ¶
func (m *ListRoutesResponse) XXX_Size() int
func (*ListRoutesResponse) XXX_Unmarshal ¶
func (m *ListRoutesResponse) XXX_Unmarshal(b []byte) error
type ListUesRequest ¶
type ListUesRequest struct { }
func (*ListUesRequest) Descriptor ¶
func (*ListUesRequest) Descriptor() ([]byte, []int)
func (*ListUesRequest) Marshal ¶
func (m *ListUesRequest) Marshal() (dAtA []byte, err error)
func (*ListUesRequest) MarshalToSizedBuffer ¶
func (m *ListUesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListUesRequest) ProtoMessage ¶
func (*ListUesRequest) ProtoMessage()
func (*ListUesRequest) Reset ¶
func (m *ListUesRequest) Reset()
func (*ListUesRequest) Size ¶
func (m *ListUesRequest) Size() (n int)
func (*ListUesRequest) String ¶
func (m *ListUesRequest) String() string
func (*ListUesRequest) Unmarshal ¶
func (m *ListUesRequest) Unmarshal(dAtA []byte) error
func (*ListUesRequest) XXX_DiscardUnknown ¶
func (m *ListUesRequest) XXX_DiscardUnknown()
func (*ListUesRequest) XXX_Marshal ¶
func (m *ListUesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListUesRequest) XXX_Merge ¶
func (m *ListUesRequest) XXX_Merge(src proto.Message)
func (*ListUesRequest) XXX_Size ¶
func (m *ListUesRequest) XXX_Size() int
func (*ListUesRequest) XXX_Unmarshal ¶
func (m *ListUesRequest) XXX_Unmarshal(b []byte) error
type ListUesResponse ¶
type ListUesResponse struct { // Ue is the UserEquipment change on which the event occurred Ue *types.Ue `protobuf:"bytes,1,opt,name=ue,proto3" json:"ue,omitempty"` }
func (*ListUesResponse) Descriptor ¶
func (*ListUesResponse) Descriptor() ([]byte, []int)
func (*ListUesResponse) GetUe ¶
func (m *ListUesResponse) GetUe() *types.Ue
func (*ListUesResponse) Marshal ¶
func (m *ListUesResponse) Marshal() (dAtA []byte, err error)
func (*ListUesResponse) MarshalToSizedBuffer ¶
func (m *ListUesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListUesResponse) ProtoMessage ¶
func (*ListUesResponse) ProtoMessage()
func (*ListUesResponse) Reset ¶
func (m *ListUesResponse) Reset()
func (*ListUesResponse) Size ¶
func (m *ListUesResponse) Size() (n int)
func (*ListUesResponse) String ¶
func (m *ListUesResponse) String() string
func (*ListUesResponse) Unmarshal ¶
func (m *ListUesResponse) Unmarshal(dAtA []byte) error
func (*ListUesResponse) XXX_DiscardUnknown ¶
func (m *ListUesResponse) XXX_DiscardUnknown()
func (*ListUesResponse) XXX_Marshal ¶
func (m *ListUesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListUesResponse) XXX_Merge ¶
func (m *ListUesResponse) XXX_Merge(src proto.Message)
func (*ListUesResponse) XXX_Size ¶
func (m *ListUesResponse) XXX_Size() int
func (*ListUesResponse) XXX_Unmarshal ¶
func (m *ListUesResponse) XXX_Unmarshal(b []byte) error
type MapLayoutRequest ¶
type MapLayoutRequest struct { }
func (*MapLayoutRequest) Descriptor ¶
func (*MapLayoutRequest) Descriptor() ([]byte, []int)
func (*MapLayoutRequest) Marshal ¶
func (m *MapLayoutRequest) Marshal() (dAtA []byte, err error)
func (*MapLayoutRequest) MarshalToSizedBuffer ¶
func (m *MapLayoutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MapLayoutRequest) ProtoMessage ¶
func (*MapLayoutRequest) ProtoMessage()
func (*MapLayoutRequest) Reset ¶
func (m *MapLayoutRequest) Reset()
func (*MapLayoutRequest) Size ¶
func (m *MapLayoutRequest) Size() (n int)
func (*MapLayoutRequest) String ¶
func (m *MapLayoutRequest) String() string
func (*MapLayoutRequest) Unmarshal ¶
func (m *MapLayoutRequest) Unmarshal(dAtA []byte) error
func (*MapLayoutRequest) XXX_DiscardUnknown ¶
func (m *MapLayoutRequest) XXX_DiscardUnknown()
func (*MapLayoutRequest) XXX_Marshal ¶
func (m *MapLayoutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MapLayoutRequest) XXX_Merge ¶
func (m *MapLayoutRequest) XXX_Merge(src proto.Message)
func (*MapLayoutRequest) XXX_Size ¶
func (m *MapLayoutRequest) XXX_Size() int
func (*MapLayoutRequest) XXX_Unmarshal ¶
func (m *MapLayoutRequest) XXX_Unmarshal(b []byte) error
type ResetMetricsMsg ¶
type ResetMetricsMsg struct { }
func (*ResetMetricsMsg) Descriptor ¶
func (*ResetMetricsMsg) Descriptor() ([]byte, []int)
func (*ResetMetricsMsg) Marshal ¶
func (m *ResetMetricsMsg) Marshal() (dAtA []byte, err error)
func (*ResetMetricsMsg) MarshalToSizedBuffer ¶
func (m *ResetMetricsMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResetMetricsMsg) ProtoMessage ¶
func (*ResetMetricsMsg) ProtoMessage()
func (*ResetMetricsMsg) Reset ¶
func (m *ResetMetricsMsg) Reset()
func (*ResetMetricsMsg) Size ¶
func (m *ResetMetricsMsg) Size() (n int)
func (*ResetMetricsMsg) String ¶
func (m *ResetMetricsMsg) String() string
func (*ResetMetricsMsg) Unmarshal ¶
func (m *ResetMetricsMsg) Unmarshal(dAtA []byte) error
func (*ResetMetricsMsg) XXX_DiscardUnknown ¶
func (m *ResetMetricsMsg) XXX_DiscardUnknown()
func (*ResetMetricsMsg) XXX_Marshal ¶
func (m *ResetMetricsMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResetMetricsMsg) XXX_Merge ¶
func (m *ResetMetricsMsg) XXX_Merge(src proto.Message)
func (*ResetMetricsMsg) XXX_Size ¶
func (m *ResetMetricsMsg) XXX_Size() int
func (*ResetMetricsMsg) XXX_Unmarshal ¶
func (m *ResetMetricsMsg) XXX_Unmarshal(b []byte) error
type SetNumberUEsRequest ¶
type SetNumberUEsRequest struct {
Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
}
func (*SetNumberUEsRequest) Descriptor ¶
func (*SetNumberUEsRequest) Descriptor() ([]byte, []int)
func (*SetNumberUEsRequest) GetNumber ¶
func (m *SetNumberUEsRequest) GetNumber() uint32
func (*SetNumberUEsRequest) Marshal ¶
func (m *SetNumberUEsRequest) Marshal() (dAtA []byte, err error)
func (*SetNumberUEsRequest) MarshalTo ¶
func (m *SetNumberUEsRequest) MarshalTo(dAtA []byte) (int, error)
func (*SetNumberUEsRequest) MarshalToSizedBuffer ¶
func (m *SetNumberUEsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetNumberUEsRequest) ProtoMessage ¶
func (*SetNumberUEsRequest) ProtoMessage()
func (*SetNumberUEsRequest) Reset ¶
func (m *SetNumberUEsRequest) Reset()
func (*SetNumberUEsRequest) Size ¶
func (m *SetNumberUEsRequest) Size() (n int)
func (*SetNumberUEsRequest) String ¶
func (m *SetNumberUEsRequest) String() string
func (*SetNumberUEsRequest) Unmarshal ¶
func (m *SetNumberUEsRequest) Unmarshal(dAtA []byte) error
func (*SetNumberUEsRequest) XXX_DiscardUnknown ¶
func (m *SetNumberUEsRequest) XXX_DiscardUnknown()
func (*SetNumberUEsRequest) XXX_Marshal ¶
func (m *SetNumberUEsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetNumberUEsRequest) XXX_Merge ¶
func (m *SetNumberUEsRequest) XXX_Merge(src proto.Message)
func (*SetNumberUEsRequest) XXX_Size ¶
func (m *SetNumberUEsRequest) XXX_Size() int
func (*SetNumberUEsRequest) XXX_Unmarshal ¶
func (m *SetNumberUEsRequest) XXX_Unmarshal(b []byte) error
type SetNumberUEsResponse ¶
type SetNumberUEsResponse struct {
Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
}
func (*SetNumberUEsResponse) Descriptor ¶
func (*SetNumberUEsResponse) Descriptor() ([]byte, []int)
func (*SetNumberUEsResponse) GetNumber ¶
func (m *SetNumberUEsResponse) GetNumber() uint32
func (*SetNumberUEsResponse) Marshal ¶
func (m *SetNumberUEsResponse) Marshal() (dAtA []byte, err error)
func (*SetNumberUEsResponse) MarshalTo ¶
func (m *SetNumberUEsResponse) MarshalTo(dAtA []byte) (int, error)
func (*SetNumberUEsResponse) MarshalToSizedBuffer ¶
func (m *SetNumberUEsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetNumberUEsResponse) ProtoMessage ¶
func (*SetNumberUEsResponse) ProtoMessage()
func (*SetNumberUEsResponse) Reset ¶
func (m *SetNumberUEsResponse) Reset()
func (*SetNumberUEsResponse) Size ¶
func (m *SetNumberUEsResponse) Size() (n int)
func (*SetNumberUEsResponse) String ¶
func (m *SetNumberUEsResponse) String() string
func (*SetNumberUEsResponse) Unmarshal ¶
func (m *SetNumberUEsResponse) Unmarshal(dAtA []byte) error
func (*SetNumberUEsResponse) XXX_DiscardUnknown ¶
func (m *SetNumberUEsResponse) XXX_DiscardUnknown()
func (*SetNumberUEsResponse) XXX_Marshal ¶
func (m *SetNumberUEsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetNumberUEsResponse) XXX_Merge ¶
func (m *SetNumberUEsResponse) XXX_Merge(src proto.Message)
func (*SetNumberUEsResponse) XXX_Size ¶
func (m *SetNumberUEsResponse) XXX_Size() int
func (*SetNumberUEsResponse) XXX_Unmarshal ¶
func (m *SetNumberUEsResponse) XXX_Unmarshal(b []byte) error
type TrafficClient ¶
type TrafficClient interface { GetMapLayout(ctx context.Context, in *MapLayoutRequest, opts ...grpc.CallOption) (*types.MapLayout, error) ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (Traffic_ListRoutesClient, error) ListUes(ctx context.Context, in *ListUesRequest, opts ...grpc.CallOption) (Traffic_ListUesClient, error) WatchUes(ctx context.Context, in *WatchUesRequest, opts ...grpc.CallOption) (Traffic_WatchUesClient, error) SetNumberUEs(ctx context.Context, in *SetNumberUEsRequest, opts ...grpc.CallOption) (*SetNumberUEsResponse, error) ResetMetrics(ctx context.Context, in *ResetMetricsMsg, opts ...grpc.CallOption) (*ResetMetricsMsg, error) }
TrafficClient is the client API for Traffic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTrafficClient ¶
func NewTrafficClient(cc *grpc.ClientConn) TrafficClient
type TrafficServer ¶
type TrafficServer interface { GetMapLayout(context.Context, *MapLayoutRequest) (*types.MapLayout, error) ListRoutes(*ListRoutesRequest, Traffic_ListRoutesServer) error ListUes(*ListUesRequest, Traffic_ListUesServer) error WatchUes(*WatchUesRequest, Traffic_WatchUesServer) error SetNumberUEs(context.Context, *SetNumberUEsRequest) (*SetNumberUEsResponse, error) ResetMetrics(context.Context, *ResetMetricsMsg) (*ResetMetricsMsg, error) }
TrafficServer is the server API for Traffic service.
type Traffic_ListRoutesClient ¶
type Traffic_ListRoutesClient interface { Recv() (*ListRoutesResponse, error) grpc.ClientStream }
type Traffic_ListRoutesServer ¶
type Traffic_ListRoutesServer interface { Send(*ListRoutesResponse) error grpc.ServerStream }
type Traffic_ListUesClient ¶
type Traffic_ListUesClient interface { Recv() (*ListUesResponse, error) grpc.ClientStream }
type Traffic_ListUesServer ¶
type Traffic_ListUesServer interface { Send(*ListUesResponse) error grpc.ServerStream }
type Traffic_WatchUesClient ¶
type Traffic_WatchUesClient interface { Recv() (*WatchUesResponse, error) grpc.ClientStream }
type Traffic_WatchUesServer ¶
type Traffic_WatchUesServer interface { Send(*WatchUesResponse) error grpc.ServerStream }
type Type ¶
type Type int32
Change event type
const ( // NONE indicates this response does not represent a modification of the Change Type_NONE Type = 0 // ADDED is an event which occurs when a Change is added to the topology Type_ADDED Type = 1 // UPDATED is an event which occurs when a Change is updated Type_UPDATED Type = 2 // REMOVED is an event which occurs when a Change is removed from the configuration Type_REMOVED Type = 3 )
func (Type) EnumDescriptor ¶
type UnimplementedTrafficServer ¶
type UnimplementedTrafficServer struct { }
UnimplementedTrafficServer can be embedded to have forward compatible implementations.
func (*UnimplementedTrafficServer) GetMapLayout ¶
func (*UnimplementedTrafficServer) GetMapLayout(ctx context.Context, req *MapLayoutRequest) (*types.MapLayout, error)
func (*UnimplementedTrafficServer) ListRoutes ¶
func (*UnimplementedTrafficServer) ListRoutes(req *ListRoutesRequest, srv Traffic_ListRoutesServer) error
func (*UnimplementedTrafficServer) ListUes ¶
func (*UnimplementedTrafficServer) ListUes(req *ListUesRequest, srv Traffic_ListUesServer) error
func (*UnimplementedTrafficServer) ResetMetrics ¶
func (*UnimplementedTrafficServer) ResetMetrics(ctx context.Context, req *ResetMetricsMsg) (*ResetMetricsMsg, error)
func (*UnimplementedTrafficServer) SetNumberUEs ¶
func (*UnimplementedTrafficServer) SetNumberUEs(ctx context.Context, req *SetNumberUEsRequest) (*SetNumberUEsResponse, error)
func (*UnimplementedTrafficServer) WatchUes ¶
func (*UnimplementedTrafficServer) WatchUes(req *WatchUesRequest, srv Traffic_WatchUesServer) error
type UpdateType ¶
type UpdateType int32
In the case of an update this helps qualify the update type - add items as necessary
const ( UpdateType_NOUPDATETYPE UpdateType = 0 // POSITION An update in position of UE only, without a change in the Tower affinity UpdateType_POSITION UpdateType = 1 // TOWER An update in non-serving tower affinity (and also position) of UE UpdateType_TOWER UpdateType = 2 // HANDOVER An update of the serving tower UpdateType_HANDOVER UpdateType = 3 )
func (UpdateType) EnumDescriptor ¶
func (UpdateType) EnumDescriptor() ([]byte, []int)
func (UpdateType) String ¶
func (x UpdateType) String() string
type WatchUesRequest ¶
type WatchUesRequest struct { NoReplay bool `protobuf:"varint,1,opt,name=no_replay,json=noReplay,proto3" json:"no_replay,omitempty"` NoSubscribe bool `protobuf:"varint,2,opt,name=no_subscribe,json=noSubscribe,proto3" json:"no_subscribe,omitempty"` }
func (*WatchUesRequest) Descriptor ¶
func (*WatchUesRequest) Descriptor() ([]byte, []int)
func (*WatchUesRequest) GetNoReplay ¶
func (m *WatchUesRequest) GetNoReplay() bool
func (*WatchUesRequest) GetNoSubscribe ¶
func (m *WatchUesRequest) GetNoSubscribe() bool
func (*WatchUesRequest) Marshal ¶
func (m *WatchUesRequest) Marshal() (dAtA []byte, err error)
func (*WatchUesRequest) MarshalToSizedBuffer ¶
func (m *WatchUesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WatchUesRequest) ProtoMessage ¶
func (*WatchUesRequest) ProtoMessage()
func (*WatchUesRequest) Reset ¶
func (m *WatchUesRequest) Reset()
func (*WatchUesRequest) Size ¶
func (m *WatchUesRequest) Size() (n int)
func (*WatchUesRequest) String ¶
func (m *WatchUesRequest) String() string
func (*WatchUesRequest) Unmarshal ¶
func (m *WatchUesRequest) Unmarshal(dAtA []byte) error
func (*WatchUesRequest) XXX_DiscardUnknown ¶
func (m *WatchUesRequest) XXX_DiscardUnknown()
func (*WatchUesRequest) XXX_Marshal ¶
func (m *WatchUesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchUesRequest) XXX_Merge ¶
func (m *WatchUesRequest) XXX_Merge(src proto.Message)
func (*WatchUesRequest) XXX_Size ¶
func (m *WatchUesRequest) XXX_Size() int
func (*WatchUesRequest) XXX_Unmarshal ¶
func (m *WatchUesRequest) XXX_Unmarshal(b []byte) error
type WatchUesResponse ¶
type WatchUesResponse struct { // Ue is the UserEquipment change on which the event occurred Ue *types.Ue `protobuf:"bytes,1,opt,name=ue,proto3" json:"ue,omitempty"` // type is a qualification of the type of change being made Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=onos.ransim.trafficsim.Type" json:"type,omitempty"` // update_type is a qualification of the type of UE change UpdateType UpdateType `` /* 131-byte string literal not displayed */ }
func (*WatchUesResponse) Descriptor ¶
func (*WatchUesResponse) Descriptor() ([]byte, []int)
func (*WatchUesResponse) GetType ¶
func (m *WatchUesResponse) GetType() Type
func (*WatchUesResponse) GetUe ¶
func (m *WatchUesResponse) GetUe() *types.Ue
func (*WatchUesResponse) GetUpdateType ¶
func (m *WatchUesResponse) GetUpdateType() UpdateType
func (*WatchUesResponse) Marshal ¶
func (m *WatchUesResponse) Marshal() (dAtA []byte, err error)
func (*WatchUesResponse) MarshalToSizedBuffer ¶
func (m *WatchUesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WatchUesResponse) ProtoMessage ¶
func (*WatchUesResponse) ProtoMessage()
func (*WatchUesResponse) Reset ¶
func (m *WatchUesResponse) Reset()
func (*WatchUesResponse) Size ¶
func (m *WatchUesResponse) Size() (n int)
func (*WatchUesResponse) String ¶
func (m *WatchUesResponse) String() string
func (*WatchUesResponse) Unmarshal ¶
func (m *WatchUesResponse) Unmarshal(dAtA []byte) error
func (*WatchUesResponse) XXX_DiscardUnknown ¶
func (m *WatchUesResponse) XXX_DiscardUnknown()
func (*WatchUesResponse) XXX_Marshal ¶
func (m *WatchUesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchUesResponse) XXX_Merge ¶
func (m *WatchUesResponse) XXX_Merge(src proto.Message)
func (*WatchUesResponse) XXX_Size ¶
func (m *WatchUesResponse) XXX_Size() int
func (*WatchUesResponse) XXX_Unmarshal ¶
func (m *WatchUesResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.