e2ap

package
v0.6.7 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthE2Ap        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowE2Ap          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupE2Ap = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterE2APServer 

func RegisterE2APServer(s *grpc.Server, srv E2APServer)

Types

type E2APClient 

type E2APClient interface {
	// RicSubscribe is a unary service for the RIC to subscribe to events/reports from E2 Node
	RicSubscribe(ctx context.Context, in *RicSubscriptionRequest, opts ...grpc.CallOption) (*RicSubscriptionResponse, error)
	// RicChan is a bi-directonal stream for all E2AP Control
	// and E2AP Indication messaging between RIC and E2-Node
	RicChan(ctx context.Context, opts ...grpc.CallOption) (E2AP_RicChanClient, error)
}

E2APClient is the client API for E2AP service.

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

func NewE2APClient 

func NewE2APClient(cc *grpc.ClientConn) E2APClient

type E2APServer 

type E2APServer interface {
	// RicSubscribe is a unary service for the RIC to subscribe to events/reports from E2 Node
	RicSubscribe(context.Context, *RicSubscriptionRequest) (*RicSubscriptionResponse, error)
	// RicChan is a bi-directonal stream for all E2AP Control
	// and E2AP Indication messaging between RIC and E2-Node
	RicChan(E2AP_RicChanServer) error
}

E2APServer is the server API for E2AP service.

type E2AP_RicChanClient added in v0.6.0 

type E2AP_RicChanClient interface {
	Send(*RicControlRequest) error
	Recv() (*RicIndication, error)
	grpc.ClientStream
}

type E2AP_RicChanServer added in v0.6.0 

type E2AP_RicChanServer interface {
	Send(*RicIndication) error
	Recv() (*RicControlRequest, error)
	grpc.ServerStream
}

type RicControlRequest 

type RicControlRequest struct {
	Hdr *e2sm.RicControlHeader  `protobuf:"bytes,1,opt,name=hdr,proto3" json:"hdr,omitempty"`
	Msg *e2sm.RicControlMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RicControlRequest) Descriptor 

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

func (*RicControlRequest) GetHdr 

func (m *RicControlRequest) GetHdr() *e2sm.RicControlHeader

func (*RicControlRequest) GetMsg 

func (m *RicControlRequest) GetMsg() *e2sm.RicControlMessage

func (*RicControlRequest) Marshal 

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

func (*RicControlRequest) MarshalTo 

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

func (*RicControlRequest) MarshalToSizedBuffer 

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

func (*RicControlRequest) ProtoMessage 

func (*RicControlRequest) ProtoMessage()

func (*RicControlRequest) Reset 

func (m *RicControlRequest) Reset()

func (*RicControlRequest) Size 

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

func (*RicControlRequest) String 

func (m *RicControlRequest) String() string

func (*RicControlRequest) Unmarshal 

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

func (*RicControlRequest) XXX_DiscardUnknown 

func (m *RicControlRequest) XXX_DiscardUnknown()

func (*RicControlRequest) XXX_Marshal 

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

func (*RicControlRequest) XXX_Merge 

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

func (*RicControlRequest) XXX_Size 

func (m *RicControlRequest) XXX_Size() int

func (*RicControlRequest) XXX_Unmarshal 

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

type RicIndication 

type RicIndication struct {
	Hdr *e2sm.RicIndicationHeader  `protobuf:"bytes,1,opt,name=hdr,proto3" json:"hdr,omitempty"`
	Msg *e2sm.RicIndicationMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RicIndication) Descriptor 

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

func (*RicIndication) GetHdr 

func (m *RicIndication) GetHdr() *e2sm.RicIndicationHeader

func (*RicIndication) GetMsg 

func (m *RicIndication) GetMsg() *e2sm.RicIndicationMessage

func (*RicIndication) Marshal 

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

func (*RicIndication) MarshalTo 

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

func (*RicIndication) MarshalToSizedBuffer 

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

func (*RicIndication) ProtoMessage 

func (*RicIndication) ProtoMessage()

func (*RicIndication) Reset 

func (m *RicIndication) Reset()

func (*RicIndication) Size 

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

func (*RicIndication) String 

func (m *RicIndication) String() string

func (*RicIndication) Unmarshal 

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

func (*RicIndication) XXX_DiscardUnknown 

func (m *RicIndication) XXX_DiscardUnknown()

func (*RicIndication) XXX_Marshal 

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

func (*RicIndication) XXX_Merge 

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

func (*RicIndication) XXX_Size 

func (m *RicIndication) XXX_Size() int

func (*RicIndication) XXX_Unmarshal 

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

type RicSubscriptionRequest 

type RicSubscriptionRequest struct {
	Hdr *e2sm.RicSubscriptionHeader  `protobuf:"bytes,1,opt,name=hdr,proto3" json:"hdr,omitempty"`
	Msg *e2sm.RicSubscriptionMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RicSubscriptionRequest) Descriptor 

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

func (*RicSubscriptionRequest) GetHdr added in v0.6.5 

func (m *RicSubscriptionRequest) GetHdr() *e2sm.RicSubscriptionHeader

func (*RicSubscriptionRequest) GetMsg added in v0.6.5 

func (m *RicSubscriptionRequest) GetMsg() *e2sm.RicSubscriptionMessage

func (*RicSubscriptionRequest) Marshal 

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

func (*RicSubscriptionRequest) MarshalTo 

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

func (*RicSubscriptionRequest) MarshalToSizedBuffer 

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

func (*RicSubscriptionRequest) ProtoMessage 

func (*RicSubscriptionRequest) ProtoMessage()

func (*RicSubscriptionRequest) Reset 

func (m *RicSubscriptionRequest) Reset()

func (*RicSubscriptionRequest) Size 

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

func (*RicSubscriptionRequest) String 

func (m *RicSubscriptionRequest) String() string

func (*RicSubscriptionRequest) Unmarshal 

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

func (*RicSubscriptionRequest) XXX_DiscardUnknown 

func (m *RicSubscriptionRequest) XXX_DiscardUnknown()

func (*RicSubscriptionRequest) XXX_Marshal 

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

func (*RicSubscriptionRequest) XXX_Merge 

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

func (*RicSubscriptionRequest) XXX_Size 

func (m *RicSubscriptionRequest) XXX_Size() int

func (*RicSubscriptionRequest) XXX_Unmarshal 

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

type RicSubscriptionResponse added in v0.6.5 

type RicSubscriptionResponse struct {
}

func (*RicSubscriptionResponse) Descriptor added in v0.6.5 

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

func (*RicSubscriptionResponse) Marshal added in v0.6.5 

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

func (*RicSubscriptionResponse) MarshalTo added in v0.6.5 

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

func (*RicSubscriptionResponse) MarshalToSizedBuffer added in v0.6.5 

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

func (*RicSubscriptionResponse) ProtoMessage added in v0.6.5 

func (*RicSubscriptionResponse) ProtoMessage()

func (*RicSubscriptionResponse) Reset added in v0.6.5 

func (m *RicSubscriptionResponse) Reset()

func (*RicSubscriptionResponse) Size added in v0.6.5 

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

func (*RicSubscriptionResponse) String added in v0.6.5 

func (m *RicSubscriptionResponse) String() string

func (*RicSubscriptionResponse) Unmarshal added in v0.6.5 

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

func (*RicSubscriptionResponse) XXX_DiscardUnknown added in v0.6.5 

func (m *RicSubscriptionResponse) XXX_DiscardUnknown()

func (*RicSubscriptionResponse) XXX_Marshal added in v0.6.5 

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

func (*RicSubscriptionResponse) XXX_Merge added in v0.6.5 

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

func (*RicSubscriptionResponse) XXX_Size added in v0.6.5 

func (m *RicSubscriptionResponse) XXX_Size() int

func (*RicSubscriptionResponse) XXX_Unmarshal added in v0.6.5 

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

type UnimplementedE2APServer 

type UnimplementedE2APServer struct {
}

UnimplementedE2APServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2APServer) RicChan added in v0.6.0 

func (*UnimplementedE2APServer) RicChan(srv E2AP_RicChanServer) error

func (*UnimplementedE2APServer) RicSubscribe added in v0.6.5 

func (*UnimplementedE2APServer) RicSubscribe(ctx context.Context, req *RicSubscriptionRequest) (*RicSubscriptionResponse, 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.