rsm

package
v0.8.4 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2021 License: Apache-2.0 Imports: 9 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRsm        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRsm          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRsm = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SchedulerType_name = map[int32]string{
	0: "SCHEDULER_TYPE_ROUND_ROBIN",
	1: "SCHEDULER_TYPE_PROPORTIONALLY_FAIR",
	2: "SCHEDULER_TYPE_QOS_BASED",
}
View Source 
var SchedulerType_value = map[string]int32{
	"SCHEDULER_TYPE_ROUND_ROBIN":         0,
	"SCHEDULER_TYPE_PROPORTIONALLY_FAIR": 1,
	"SCHEDULER_TYPE_QOS_BASED":           2,
}
View Source 
var SliceType_name = map[int32]string{
	0: "SLICE_TYPE_DL_SLICE",
	1: "SLICE_TYPE_UL_SLICE",
}
View Source 
var SliceType_value = map[string]int32{
	"SLICE_TYPE_DL_SLICE": 0,
	"SLICE_TYPE_UL_SLICE": 1,
}
View Source 
var UeIdType_name = map[int32]string{
	0: "UE_ID_TYPE_CU_UE_F1_AP_ID",
	1: "UE_ID_TYPE_DU_UE_F1_AP_ID",
	2: "UE_ID_TYPE_RAN_UE_NGAP_ID",
	3: "UE_ID_TYPE_AMF_UE_NGAP_ID",
	4: "UE_ID_TYPE_ENB_UE_S1_AP_ID",
}
View Source 
var UeIdType_value = map[string]int32{
	"UE_ID_TYPE_CU_UE_F1_AP_ID":  0,
	"UE_ID_TYPE_DU_UE_F1_AP_ID":  1,
	"UE_ID_TYPE_RAN_UE_NGAP_ID":  2,
	"UE_ID_TYPE_AMF_UE_NGAP_ID":  3,
	"UE_ID_TYPE_ENB_UE_S1_AP_ID": 4,
}

Functions

func RegisterRsmServer 

func RegisterRsmServer(s *grpc.Server, srv RsmServer)

Types

type Ack 

type Ack struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Cause   string `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
}

func (*Ack) Descriptor 

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

func (*Ack) GetCause 

func (m *Ack) GetCause() string

func (*Ack) GetSuccess 

func (m *Ack) GetSuccess() bool

func (*Ack) Marshal 

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

func (*Ack) MarshalTo 

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

func (*Ack) MarshalToSizedBuffer 

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

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) Size 

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

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) Unmarshal 

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

func (*Ack) XXX_DiscardUnknown 

func (m *Ack) XXX_DiscardUnknown()

func (*Ack) XXX_Marshal 

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

func (*Ack) XXX_Merge 

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

func (*Ack) XXX_Size 

func (m *Ack) XXX_Size() int

func (*Ack) XXX_Unmarshal 

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

type CreateSliceRequest 

type CreateSliceRequest struct {
	E2NodeId      string        `protobuf:"bytes,1,opt,name=e2_node_id,json=e2NodeId,proto3" json:"e2_node_id,omitempty"`
	SliceId       string        `protobuf:"bytes,2,opt,name=slice_id,json=sliceId,proto3" json:"slice_id,omitempty"`
	SchedulerType SchedulerType `` /* 129-byte string literal not displayed */
	Weight        string        `protobuf:"bytes,4,opt,name=weight,proto3" json:"weight,omitempty"`
	SliceType     SliceType     `protobuf:"varint,5,opt,name=sliceType,proto3,enum=onos.rsm.SliceType" json:"sliceType,omitempty"`
}

func (*CreateSliceRequest) Descriptor 

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

func (*CreateSliceRequest) GetE2NodeId 

func (m *CreateSliceRequest) GetE2NodeId() string

func (*CreateSliceRequest) GetSchedulerType 

func (m *CreateSliceRequest) GetSchedulerType() SchedulerType

func (*CreateSliceRequest) GetSliceId 

func (m *CreateSliceRequest) GetSliceId() string

func (*CreateSliceRequest) GetSliceType added in v0.7.98 

func (m *CreateSliceRequest) GetSliceType() SliceType

func (*CreateSliceRequest) GetWeight 

func (m *CreateSliceRequest) GetWeight() string

func (*CreateSliceRequest) Marshal 

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

func (*CreateSliceRequest) MarshalTo 

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

func (*CreateSliceRequest) MarshalToSizedBuffer 

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

func (*CreateSliceRequest) ProtoMessage 

func (*CreateSliceRequest) ProtoMessage()

func (*CreateSliceRequest) Reset 

func (m *CreateSliceRequest) Reset()

func (*CreateSliceRequest) Size 

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

func (*CreateSliceRequest) String 

func (m *CreateSliceRequest) String() string

func (*CreateSliceRequest) Unmarshal 

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

func (*CreateSliceRequest) XXX_DiscardUnknown 

func (m *CreateSliceRequest) XXX_DiscardUnknown()

func (*CreateSliceRequest) XXX_Marshal 

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

func (*CreateSliceRequest) XXX_Merge 

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

func (*CreateSliceRequest) XXX_Size 

func (m *CreateSliceRequest) XXX_Size() int

func (*CreateSliceRequest) XXX_Unmarshal 

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

type CreateSliceResponse 

type CreateSliceResponse struct {
	Ack *Ack `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"`
}

func (*CreateSliceResponse) Descriptor 

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

func (*CreateSliceResponse) GetAck 

func (m *CreateSliceResponse) GetAck() *Ack

func (*CreateSliceResponse) Marshal 

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

func (*CreateSliceResponse) MarshalTo 

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

func (*CreateSliceResponse) MarshalToSizedBuffer 

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

func (*CreateSliceResponse) ProtoMessage 

func (*CreateSliceResponse) ProtoMessage()

func (*CreateSliceResponse) Reset 

func (m *CreateSliceResponse) Reset()

func (*CreateSliceResponse) Size 

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

func (*CreateSliceResponse) String 

func (m *CreateSliceResponse) String() string

func (*CreateSliceResponse) Unmarshal 

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

func (*CreateSliceResponse) XXX_DiscardUnknown 

func (m *CreateSliceResponse) XXX_DiscardUnknown()

func (*CreateSliceResponse) XXX_Marshal 

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

func (*CreateSliceResponse) XXX_Merge 

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

func (*CreateSliceResponse) XXX_Size 

func (m *CreateSliceResponse) XXX_Size() int

func (*CreateSliceResponse) XXX_Unmarshal 

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

type DeleteSliceRequest 

type DeleteSliceRequest struct {
	E2NodeId  string    `protobuf:"bytes,1,opt,name=e2_node_id,json=e2NodeId,proto3" json:"e2_node_id,omitempty"`
	SliceId   string    `protobuf:"bytes,2,opt,name=slice_id,json=sliceId,proto3" json:"slice_id,omitempty"`
	SliceType SliceType `protobuf:"varint,3,opt,name=sliceType,proto3,enum=onos.rsm.SliceType" json:"sliceType,omitempty"`
}

func (*DeleteSliceRequest) Descriptor 

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

func (*DeleteSliceRequest) GetE2NodeId 

func (m *DeleteSliceRequest) GetE2NodeId() string

func (*DeleteSliceRequest) GetSliceId 

func (m *DeleteSliceRequest) GetSliceId() string

func (*DeleteSliceRequest) GetSliceType added in v0.7.98 

func (m *DeleteSliceRequest) GetSliceType() SliceType

func (*DeleteSliceRequest) Marshal 

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

func (*DeleteSliceRequest) MarshalTo 

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

func (*DeleteSliceRequest) MarshalToSizedBuffer 

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

func (*DeleteSliceRequest) ProtoMessage 

func (*DeleteSliceRequest) ProtoMessage()

func (*DeleteSliceRequest) Reset 

func (m *DeleteSliceRequest) Reset()

func (*DeleteSliceRequest) Size 

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

func (*DeleteSliceRequest) String 

func (m *DeleteSliceRequest) String() string

func (*DeleteSliceRequest) Unmarshal 

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

func (*DeleteSliceRequest) XXX_DiscardUnknown 

func (m *DeleteSliceRequest) XXX_DiscardUnknown()

func (*DeleteSliceRequest) XXX_Marshal 

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

func (*DeleteSliceRequest) XXX_Merge 

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

func (*DeleteSliceRequest) XXX_Size 

func (m *DeleteSliceRequest) XXX_Size() int

func (*DeleteSliceRequest) XXX_Unmarshal 

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

type DeleteSliceResponse 

type DeleteSliceResponse struct {
	Ack *Ack `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"`
}

func (*DeleteSliceResponse) Descriptor 

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

func (*DeleteSliceResponse) GetAck 

func (m *DeleteSliceResponse) GetAck() *Ack

func (*DeleteSliceResponse) Marshal 

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

func (*DeleteSliceResponse) MarshalTo 

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

func (*DeleteSliceResponse) MarshalToSizedBuffer 

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

func (*DeleteSliceResponse) ProtoMessage 

func (*DeleteSliceResponse) ProtoMessage()

func (*DeleteSliceResponse) Reset 

func (m *DeleteSliceResponse) Reset()

func (*DeleteSliceResponse) Size 

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

func (*DeleteSliceResponse) String 

func (m *DeleteSliceResponse) String() string

func (*DeleteSliceResponse) Unmarshal 

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

func (*DeleteSliceResponse) XXX_DiscardUnknown 

func (m *DeleteSliceResponse) XXX_DiscardUnknown()

func (*DeleteSliceResponse) XXX_Marshal 

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

func (*DeleteSliceResponse) XXX_Merge 

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

func (*DeleteSliceResponse) XXX_Size 

func (m *DeleteSliceResponse) XXX_Size() int

func (*DeleteSliceResponse) XXX_Unmarshal 

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

type RsmClient 

type RsmClient interface {
	// Slice management
	CreateSlice(ctx context.Context, in *CreateSliceRequest, opts ...grpc.CallOption) (*CreateSliceResponse, error)
	UpdateSlice(ctx context.Context, in *UpdateSliceRequest, opts ...grpc.CallOption) (*UpdateSliceResponse, error)
	DeleteSlice(ctx context.Context, in *DeleteSliceRequest, opts ...grpc.CallOption) (*DeleteSliceResponse, error)
	// UE-Slice association
	SetUeSliceAssociation(ctx context.Context, in *SetUeSliceAssociationRequest, opts ...grpc.CallOption) (*SetUeSliceAssociationResponse, error)
}

RsmClient is the client API for Rsm service.

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

func NewRsmClient 

func NewRsmClient(cc *grpc.ClientConn) RsmClient

type RsmServer 

type RsmServer interface {
	// Slice management
	CreateSlice(context.Context, *CreateSliceRequest) (*CreateSliceResponse, error)
	UpdateSlice(context.Context, *UpdateSliceRequest) (*UpdateSliceResponse, error)
	DeleteSlice(context.Context, *DeleteSliceRequest) (*DeleteSliceResponse, error)
	// UE-Slice association
	SetUeSliceAssociation(context.Context, *SetUeSliceAssociationRequest) (*SetUeSliceAssociationResponse, error)
}

RsmServer is the server API for Rsm service.

type SchedulerType 

type SchedulerType int32
const (
	SchedulerType_SCHEDULER_TYPE_ROUND_ROBIN         SchedulerType = 0
	SchedulerType_SCHEDULER_TYPE_PROPORTIONALLY_FAIR SchedulerType = 1
	SchedulerType_SCHEDULER_TYPE_QOS_BASED           SchedulerType = 2
)

func (SchedulerType) EnumDescriptor 

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

func (SchedulerType) String 

func (x SchedulerType) String() string

type SetUeSliceAssociationRequest 

type SetUeSliceAssociationRequest struct {
	E2NodeId  string  `protobuf:"bytes,1,opt,name=e2_node_id,json=e2NodeId,proto3" json:"e2_node_id,omitempty"`
	UeId      []*UeId `protobuf:"bytes,2,rep,name=ue_id,json=ueId,proto3" json:"ue_id,omitempty"`
	DlSliceId string  `protobuf:"bytes,3,opt,name=dl_slice_id,json=dlSliceId,proto3" json:"dl_slice_id,omitempty"`
	UlSliceId string  `protobuf:"bytes,4,opt,name=ul_slice_id,json=ulSliceId,proto3" json:"ul_slice_id,omitempty"`
	DrbId     string  `protobuf:"bytes,5,opt,name=drb_id,json=drbId,proto3" json:"drb_id,omitempty"`
}

func (*SetUeSliceAssociationRequest) Descriptor 

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

func (*SetUeSliceAssociationRequest) GetDlSliceId added in v0.7.99 

func (m *SetUeSliceAssociationRequest) GetDlSliceId() string

func (*SetUeSliceAssociationRequest) GetDrbId added in v0.7.103 

func (m *SetUeSliceAssociationRequest) GetDrbId() string

func (*SetUeSliceAssociationRequest) GetE2NodeId 

func (m *SetUeSliceAssociationRequest) GetE2NodeId() string

func (*SetUeSliceAssociationRequest) GetUeId 

func (m *SetUeSliceAssociationRequest) GetUeId() []*UeId

func (*SetUeSliceAssociationRequest) GetUlSliceId added in v0.7.99 

func (m *SetUeSliceAssociationRequest) GetUlSliceId() string

func (*SetUeSliceAssociationRequest) Marshal 

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

func (*SetUeSliceAssociationRequest) MarshalTo 

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

func (*SetUeSliceAssociationRequest) MarshalToSizedBuffer 

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

func (*SetUeSliceAssociationRequest) ProtoMessage 

func (*SetUeSliceAssociationRequest) ProtoMessage()

func (*SetUeSliceAssociationRequest) Reset 

func (m *SetUeSliceAssociationRequest) Reset()

func (*SetUeSliceAssociationRequest) Size 

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

func (*SetUeSliceAssociationRequest) String 

func (m *SetUeSliceAssociationRequest) String() string

func (*SetUeSliceAssociationRequest) Unmarshal 

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

func (*SetUeSliceAssociationRequest) XXX_DiscardUnknown 

func (m *SetUeSliceAssociationRequest) XXX_DiscardUnknown()

func (*SetUeSliceAssociationRequest) XXX_Marshal 

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

func (*SetUeSliceAssociationRequest) XXX_Merge 

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

func (*SetUeSliceAssociationRequest) XXX_Size 

func (m *SetUeSliceAssociationRequest) XXX_Size() int

func (*SetUeSliceAssociationRequest) XXX_Unmarshal 

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

type SetUeSliceAssociationResponse 

type SetUeSliceAssociationResponse struct {
	Ack                    *Ack   `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"`
	AssignedUeSliceAssocId string `` /* 133-byte string literal not displayed */
}

func (*SetUeSliceAssociationResponse) Descriptor 

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

func (*SetUeSliceAssociationResponse) GetAck 

func (m *SetUeSliceAssociationResponse) GetAck() *Ack

func (*SetUeSliceAssociationResponse) GetAssignedUeSliceAssocId 

func (m *SetUeSliceAssociationResponse) GetAssignedUeSliceAssocId() string

func (*SetUeSliceAssociationResponse) Marshal 

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

func (*SetUeSliceAssociationResponse) MarshalTo 

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

func (*SetUeSliceAssociationResponse) MarshalToSizedBuffer 

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

func (*SetUeSliceAssociationResponse) ProtoMessage 

func (*SetUeSliceAssociationResponse) ProtoMessage()

func (*SetUeSliceAssociationResponse) Reset 

func (m *SetUeSliceAssociationResponse) Reset()

func (*SetUeSliceAssociationResponse) Size 

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

func (*SetUeSliceAssociationResponse) String 

func (m *SetUeSliceAssociationResponse) String() string

func (*SetUeSliceAssociationResponse) Unmarshal 

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

func (*SetUeSliceAssociationResponse) XXX_DiscardUnknown 

func (m *SetUeSliceAssociationResponse) XXX_DiscardUnknown()

func (*SetUeSliceAssociationResponse) XXX_Marshal 

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

func (*SetUeSliceAssociationResponse) XXX_Merge 

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

func (*SetUeSliceAssociationResponse) XXX_Size 

func (m *SetUeSliceAssociationResponse) XXX_Size() int

func (*SetUeSliceAssociationResponse) XXX_Unmarshal 

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

type SliceAssocItem 

type SliceAssocItem struct {
	UeSliceAssocId string     `protobuf:"bytes,1,opt,name=ue_slice_assoc_id,json=ueSliceAssocId,proto3" json:"ue_slice_assoc_id,omitempty"`
	E2NodeId       string     `protobuf:"bytes,2,opt,name=e2_node_id,json=e2NodeId,proto3" json:"e2_node_id,omitempty"`
	UeId           []UeIdType `protobuf:"varint,3,rep,packed,name=ue_id,json=ueId,proto3,enum=onos.rsm.UeIdType" json:"ue_id,omitempty"`
	SliceId        string     `protobuf:"bytes,4,opt,name=slice_id,json=sliceId,proto3" json:"slice_id,omitempty"`
}

func (*SliceAssocItem) Descriptor 

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

func (*SliceAssocItem) GetE2NodeId 

func (m *SliceAssocItem) GetE2NodeId() string

func (*SliceAssocItem) GetSliceId 

func (m *SliceAssocItem) GetSliceId() string

func (*SliceAssocItem) GetUeId 

func (m *SliceAssocItem) GetUeId() []UeIdType

func (*SliceAssocItem) GetUeSliceAssocId 

func (m *SliceAssocItem) GetUeSliceAssocId() string

func (*SliceAssocItem) Marshal 

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

func (*SliceAssocItem) MarshalTo 

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

func (*SliceAssocItem) MarshalToSizedBuffer 

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

func (*SliceAssocItem) ProtoMessage 

func (*SliceAssocItem) ProtoMessage()

func (*SliceAssocItem) Reset 

func (m *SliceAssocItem) Reset()

func (*SliceAssocItem) Size 

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

func (*SliceAssocItem) String 

func (m *SliceAssocItem) String() string

func (*SliceAssocItem) Unmarshal 

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

func (*SliceAssocItem) XXX_DiscardUnknown 

func (m *SliceAssocItem) XXX_DiscardUnknown()

func (*SliceAssocItem) XXX_Marshal 

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

func (*SliceAssocItem) XXX_Merge 

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

func (*SliceAssocItem) XXX_Size 

func (m *SliceAssocItem) XXX_Size() int

func (*SliceAssocItem) XXX_Unmarshal 

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

type SliceItem 

type SliceItem struct {
	E2NodeId string   `protobuf:"bytes,1,opt,name=e2_node_id,json=e2NodeId,proto3" json:"e2_node_id,omitempty"`
	SliceIds []string `protobuf:"bytes,2,rep,name=slice_ids,json=sliceIds,proto3" json:"slice_ids,omitempty"`
}

func (*SliceItem) Descriptor 

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

func (*SliceItem) GetE2NodeId 

func (m *SliceItem) GetE2NodeId() string

func (*SliceItem) GetSliceIds 

func (m *SliceItem) GetSliceIds() []string

func (*SliceItem) Marshal 

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

func (*SliceItem) MarshalTo 

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

func (*SliceItem) MarshalToSizedBuffer 

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

func (*SliceItem) ProtoMessage 

func (*SliceItem) ProtoMessage()

func (*SliceItem) Reset 

func (m *SliceItem) Reset()

func (*SliceItem) Size 

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

func (*SliceItem) String 

func (m *SliceItem) String() string

func (*SliceItem) Unmarshal 

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

func (*SliceItem) XXX_DiscardUnknown 

func (m *SliceItem) XXX_DiscardUnknown()

func (*SliceItem) XXX_Marshal 

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

func (*SliceItem) XXX_Merge 

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

func (*SliceItem) XXX_Size 

func (m *SliceItem) XXX_Size() int

func (*SliceItem) XXX_Unmarshal 

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

type SliceType added in v0.7.98 

type SliceType int32
const (
	SliceType_SLICE_TYPE_DL_SLICE SliceType = 0
	SliceType_SLICE_TYPE_UL_SLICE SliceType = 1
)

func (SliceType) EnumDescriptor added in v0.7.98 

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

func (SliceType) String added in v0.7.98 

func (x SliceType) String() string

type UeId 

type UeId struct {
	UeId string   `protobuf:"bytes,1,opt,name=ue_id,json=ueId,proto3" json:"ue_id,omitempty"`
	Type UeIdType `protobuf:"varint,2,opt,name=type,proto3,enum=onos.rsm.UeIdType" json:"type,omitempty"`
}

func (*UeId) Descriptor 

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

func (*UeId) GetType 

func (m *UeId) GetType() UeIdType

func (*UeId) GetUeId 

func (m *UeId) GetUeId() string

func (*UeId) Marshal 

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

func (*UeId) MarshalTo 

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

func (*UeId) MarshalToSizedBuffer 

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

func (*UeId) ProtoMessage 

func (*UeId) ProtoMessage()

func (*UeId) Reset 

func (m *UeId) Reset()

func (*UeId) Size 

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

func (*UeId) String 

func (m *UeId) String() string

func (*UeId) Unmarshal 

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

func (*UeId) XXX_DiscardUnknown 

func (m *UeId) XXX_DiscardUnknown()

func (*UeId) XXX_Marshal 

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

func (*UeId) XXX_Merge 

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

func (*UeId) XXX_Size 

func (m *UeId) XXX_Size() int

func (*UeId) XXX_Unmarshal 

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

type UeIdType 

type UeIdType int32
const (
	UeIdType_UE_ID_TYPE_CU_UE_F1_AP_ID  UeIdType = 0
	UeIdType_UE_ID_TYPE_DU_UE_F1_AP_ID  UeIdType = 1
	UeIdType_UE_ID_TYPE_RAN_UE_NGAP_ID  UeIdType = 2
	UeIdType_UE_ID_TYPE_AMF_UE_NGAP_ID  UeIdType = 3
	UeIdType_UE_ID_TYPE_ENB_UE_S1_AP_ID UeIdType = 4
)

func (UeIdType) EnumDescriptor 

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

func (UeIdType) String 

func (x UeIdType) String() string

type UnimplementedRsmServer 

type UnimplementedRsmServer struct {
}

UnimplementedRsmServer can be embedded to have forward compatible implementations.

func (*UnimplementedRsmServer) CreateSlice 

func (*UnimplementedRsmServer) CreateSlice(ctx context.Context, req *CreateSliceRequest) (*CreateSliceResponse, error)

func (*UnimplementedRsmServer) DeleteSlice 

func (*UnimplementedRsmServer) DeleteSlice(ctx context.Context, req *DeleteSliceRequest) (*DeleteSliceResponse, error)

func (*UnimplementedRsmServer) SetUeSliceAssociation 

func (*UnimplementedRsmServer) SetUeSliceAssociation(ctx context.Context, req *SetUeSliceAssociationRequest) (*SetUeSliceAssociationResponse, error)

func (*UnimplementedRsmServer) UpdateSlice 

func (*UnimplementedRsmServer) UpdateSlice(ctx context.Context, req *UpdateSliceRequest) (*UpdateSliceResponse, error)

type UpdateSliceRequest 

type UpdateSliceRequest struct {
	E2NodeId      string        `protobuf:"bytes,1,opt,name=e2_node_id,json=e2NodeId,proto3" json:"e2_node_id,omitempty"`
	SliceId       string        `protobuf:"bytes,2,opt,name=slice_id,json=sliceId,proto3" json:"slice_id,omitempty"`
	SchedulerType SchedulerType `` /* 129-byte string literal not displayed */
	Weight        string        `protobuf:"bytes,4,opt,name=weight,proto3" json:"weight,omitempty"`
	SliceType     SliceType     `protobuf:"varint,5,opt,name=sliceType,proto3,enum=onos.rsm.SliceType" json:"sliceType,omitempty"`
}

func (*UpdateSliceRequest) Descriptor 

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

func (*UpdateSliceRequest) GetE2NodeId 

func (m *UpdateSliceRequest) GetE2NodeId() string

func (*UpdateSliceRequest) GetSchedulerType 

func (m *UpdateSliceRequest) GetSchedulerType() SchedulerType

func (*UpdateSliceRequest) GetSliceId 

func (m *UpdateSliceRequest) GetSliceId() string

func (*UpdateSliceRequest) GetSliceType added in v0.7.98 

func (m *UpdateSliceRequest) GetSliceType() SliceType

func (*UpdateSliceRequest) GetWeight 

func (m *UpdateSliceRequest) GetWeight() string

func (*UpdateSliceRequest) Marshal 

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

func (*UpdateSliceRequest) MarshalTo 

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

func (*UpdateSliceRequest) MarshalToSizedBuffer 

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

func (*UpdateSliceRequest) ProtoMessage 

func (*UpdateSliceRequest) ProtoMessage()

func (*UpdateSliceRequest) Reset 

func (m *UpdateSliceRequest) Reset()

func (*UpdateSliceRequest) Size 

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

func (*UpdateSliceRequest) String 

func (m *UpdateSliceRequest) String() string

func (*UpdateSliceRequest) Unmarshal 

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

func (*UpdateSliceRequest) XXX_DiscardUnknown 

func (m *UpdateSliceRequest) XXX_DiscardUnknown()

func (*UpdateSliceRequest) XXX_Marshal 

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

func (*UpdateSliceRequest) XXX_Merge 

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

func (*UpdateSliceRequest) XXX_Size 

func (m *UpdateSliceRequest) XXX_Size() int

func (*UpdateSliceRequest) XXX_Unmarshal 

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

type UpdateSliceResponse 

type UpdateSliceResponse struct {
	Ack *Ack `protobuf:"bytes,1,opt,name=ack,proto3" json:"ack,omitempty"`
}

func (*UpdateSliceResponse) Descriptor 

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

func (*UpdateSliceResponse) GetAck 

func (m *UpdateSliceResponse) GetAck() *Ack

func (*UpdateSliceResponse) Marshal 

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

func (*UpdateSliceResponse) MarshalTo 

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

func (*UpdateSliceResponse) MarshalToSizedBuffer 

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

func (*UpdateSliceResponse) ProtoMessage 

func (*UpdateSliceResponse) ProtoMessage()

func (*UpdateSliceResponse) Reset 

func (m *UpdateSliceResponse) Reset()

func (*UpdateSliceResponse) Size 

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

func (*UpdateSliceResponse) String 

func (m *UpdateSliceResponse) String() string

func (*UpdateSliceResponse) Unmarshal 

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

func (*UpdateSliceResponse) XXX_DiscardUnknown 

func (m *UpdateSliceResponse) XXX_DiscardUnknown()

func (*UpdateSliceResponse) XXX_Marshal 

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

func (*UpdateSliceResponse) XXX_Merge 

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

func (*UpdateSliceResponse) XXX_Size 

func (m *UpdateSliceResponse) XXX_Size() int

func (*UpdateSliceResponse) XXX_Unmarshal 

func (m *UpdateSliceResponse) 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.