trafficsim

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: May 1, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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 ListCellsRequest added in v0.6.1 

type ListCellsRequest struct {
	// subscribe indicates whether to subscribe to events (e.g. ADD, UPDATE, and REMOVE) that occur
	// after all cells have been streamed to the client
	Subscribe bool `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// option to request only changes that happen after the call
	WithoutReplay bool `protobuf:"varint,2,opt,name=withoutReplay,proto3" json:"withoutReplay,omitempty"`
}

func (*ListCellsRequest) Descriptor added in v0.6.1 

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

func (*ListCellsRequest) GetSubscribe added in v0.6.1 

func (m *ListCellsRequest) GetSubscribe() bool

func (*ListCellsRequest) GetWithoutReplay added in v0.6.1 

func (m *ListCellsRequest) GetWithoutReplay() bool

func (*ListCellsRequest) Marshal added in v0.6.1 

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

func (*ListCellsRequest) MarshalTo added in v0.6.1 

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

func (*ListCellsRequest) MarshalToSizedBuffer added in v0.6.1 

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

func (*ListCellsRequest) ProtoMessage added in v0.6.1 

func (*ListCellsRequest) ProtoMessage()

func (*ListCellsRequest) Reset added in v0.6.1 

func (m *ListCellsRequest) Reset()

func (*ListCellsRequest) Size added in v0.6.1 

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

func (*ListCellsRequest) String added in v0.6.1 

func (m *ListCellsRequest) String() string

func (*ListCellsRequest) Unmarshal added in v0.6.1 

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

func (*ListCellsRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *ListCellsRequest) XXX_DiscardUnknown()

func (*ListCellsRequest) XXX_Marshal added in v0.6.1 

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

func (*ListCellsRequest) XXX_Merge added in v0.6.1 

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

func (*ListCellsRequest) XXX_Size added in v0.6.1 

func (m *ListCellsRequest) XXX_Size() int

func (*ListCellsRequest) XXX_Unmarshal added in v0.6.1 

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

type ListCellsResponse added in v0.6.1 

type ListCellsResponse struct {
	// cell is the cell change on which the event occurred
	Cell *types.Cell `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
	// type is a qualification of the type of change being made
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=ran.trafficsim.Type" json:"type,omitempty"`
}

func (*ListCellsResponse) Descriptor added in v0.6.1 

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

func (*ListCellsResponse) GetCell added in v0.6.1 

func (m *ListCellsResponse) GetCell() *types.Cell

func (*ListCellsResponse) GetType added in v0.6.1 

func (m *ListCellsResponse) GetType() Type

func (*ListCellsResponse) Marshal added in v0.6.1 

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

func (*ListCellsResponse) MarshalTo added in v0.6.1 

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

func (*ListCellsResponse) MarshalToSizedBuffer added in v0.6.1 

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

func (*ListCellsResponse) ProtoMessage added in v0.6.1 

func (*ListCellsResponse) ProtoMessage()

func (*ListCellsResponse) Reset added in v0.6.1 

func (m *ListCellsResponse) Reset()

func (*ListCellsResponse) Size added in v0.6.1 

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

func (*ListCellsResponse) String added in v0.6.1 

func (m *ListCellsResponse) String() string

func (*ListCellsResponse) Unmarshal added in v0.6.1 

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

func (*ListCellsResponse) XXX_DiscardUnknown added in v0.6.1 

func (m *ListCellsResponse) XXX_DiscardUnknown()

func (*ListCellsResponse) XXX_Marshal added in v0.6.1 

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

func (*ListCellsResponse) XXX_Merge added in v0.6.1 

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

func (*ListCellsResponse) XXX_Size added in v0.6.1 

func (m *ListCellsResponse) XXX_Size() int

func (*ListCellsResponse) XXX_Unmarshal added in v0.6.1 

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

type ListRoutesRequest 

type ListRoutesRequest struct {
	// subscribe indicates whether to subscribe to events (e.g. ADD, UPDATE, and REMOVE) that occur
	// after all routes have been streamed to the client
	Subscribe bool `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// option to request only changes that happen after the call
	WithoutReplay bool `protobuf:"varint,2,opt,name=withoutReplay,proto3" json:"withoutReplay,omitempty"`
}

func (*ListRoutesRequest) Descriptor 

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

func (*ListRoutesRequest) GetSubscribe 

func (m *ListRoutesRequest) GetSubscribe() bool

func (*ListRoutesRequest) GetWithoutReplay 

func (m *ListRoutesRequest) GetWithoutReplay() 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=ran.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 {
	// subscribe indicates whether to subscribe to events (e.g. ADD, UPDATE, and REMOVE) that occur
	// after all routes have been streamed to the client
	Subscribe bool `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// option to request only changes that happen after the call
	WithoutReplay bool `protobuf:"varint,2,opt,name=withoutReplay,proto3" json:"withoutReplay,omitempty"`
}

func (*ListUesRequest) Descriptor 

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

func (*ListUesRequest) GetSubscribe 

func (m *ListUesRequest) GetSubscribe() bool

func (*ListUesRequest) GetWithoutReplay 

func (m *ListUesRequest) GetWithoutReplay() bool

func (*ListUesRequest) Marshal 

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

func (*ListUesRequest) MarshalTo 

func (m *ListUesRequest) MarshalTo(dAtA []byte) (int, 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"`
	// type is a qualification of the type of change being made
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=ran.trafficsim.Type" json:"type,omitempty"`
	// update_type is a qualification of the type of UE change
	UpdateType UpdateType `protobuf:"varint,3,opt,name=update_type,json=updateType,proto3,enum=ran.trafficsim.UpdateType" json:"update_type,omitempty"`
}

func (*ListUesResponse) Descriptor 

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

func (*ListUesResponse) GetType 

func (m *ListUesResponse) GetType() Type

func (*ListUesResponse) GetUe 

func (m *ListUesResponse) GetUe() *types.Ue

func (*ListUesResponse) GetUpdateType 

func (m *ListUesResponse) GetUpdateType() UpdateType

func (*ListUesResponse) Marshal 

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

func (*ListUesResponse) MarshalTo 

func (m *ListUesResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MapLayoutRequest) MarshalTo(dAtA []byte) (int, 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 added in v0.6.0 

type ResetMetricsMsg struct {
}

func (*ResetMetricsMsg) Descriptor added in v0.6.0 

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

func (*ResetMetricsMsg) Marshal added in v0.6.0 

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

func (*ResetMetricsMsg) MarshalTo added in v0.6.0 

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

func (*ResetMetricsMsg) MarshalToSizedBuffer added in v0.6.0 

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

func (*ResetMetricsMsg) ProtoMessage added in v0.6.0 

func (*ResetMetricsMsg) ProtoMessage()

func (*ResetMetricsMsg) Reset added in v0.6.0 

func (m *ResetMetricsMsg) Reset()

func (*ResetMetricsMsg) Size added in v0.6.0 

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

func (*ResetMetricsMsg) String added in v0.6.0 

func (m *ResetMetricsMsg) String() string

func (*ResetMetricsMsg) Unmarshal added in v0.6.0 

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

func (*ResetMetricsMsg) XXX_DiscardUnknown added in v0.6.0 

func (m *ResetMetricsMsg) XXX_DiscardUnknown()

func (*ResetMetricsMsg) XXX_Marshal added in v0.6.0 

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

func (*ResetMetricsMsg) XXX_Merge added in v0.6.0 

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

func (*ResetMetricsMsg) XXX_Size added in v0.6.0 

func (m *ResetMetricsMsg) XXX_Size() int

func (*ResetMetricsMsg) XXX_Unmarshal added in v0.6.0 

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)
	ListCells(ctx context.Context, in *ListCellsRequest, opts ...grpc.CallOption) (Traffic_ListCellsClient, 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)
	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)
	ListCells(*ListCellsRequest, Traffic_ListCellsServer) error
	ListRoutes(*ListRoutesRequest, Traffic_ListRoutesServer) error
	ListUes(*ListUesRequest, Traffic_ListUesServer) error
	SetNumberUEs(context.Context, *SetNumberUEsRequest) (*SetNumberUEsResponse, error)
	ResetMetrics(context.Context, *ResetMetricsMsg) (*ResetMetricsMsg, error)
}

TrafficServer is the server API for Traffic service.

type Traffic_ListCellsClient added in v0.6.1 

type Traffic_ListCellsClient interface {
	Recv() (*ListCellsResponse, error)
	grpc.ClientStream
}

type Traffic_ListCellsServer added in v0.6.1 

type Traffic_ListCellsServer interface {
	Send(*ListCellsResponse) error
	grpc.ServerStream
}

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

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

func (Type) String 

func (x Type) String() string

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) ListCells added in v0.6.1 

func (*UnimplementedTrafficServer) ListCells(req *ListCellsRequest, srv Traffic_ListCellsServer) 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 added in v0.6.0 

func (*UnimplementedTrafficServer) ResetMetrics(ctx context.Context, req *ResetMetricsMsg) (*ResetMetricsMsg, error)

func (*UnimplementedTrafficServer) SetNumberUEs 

func (*UnimplementedTrafficServer) SetNumberUEs(ctx context.Context, req *SetNumberUEsRequest) (*SetNumberUEsResponse, 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

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.