v1beta1

Documentation

Index

• func NewProxyService(clientConn *grpc.ClientConn) northbound.Service
• type ProxyServer
  • func (s *ProxyServer) Control(ctx context.Context, request *e2api.ControlRequest) (*e2api.ControlResponse, error)
  • func (s *ProxyServer) Subscribe(request *e2api.SubscribeRequest, ...) error
  • func (s *ProxyServer) Unsubscribe(ctx context.Context, request *e2api.UnsubscribeRequest) (*e2api.UnsubscribeResponse, error)
• type SubscriptionService
  • func (s SubscriptionService) Register(r *grpc.Server)

Functions

func NewProxyService

func NewProxyService(clientConn *grpc.ClientConn) northbound.Service

NewProxyService creates a new E2T control and subscription proxy service

Types

type ProxyServer

type ProxyServer struct {
	// contains filtered or unexported fields
}

ProxyServer implements the gRPC service for E2 Subscription related functions.

func (*ProxyServer) Control

func (s *ProxyServer) Control(ctx context.Context, request *e2api.ControlRequest) (*e2api.ControlResponse, error)

func (*ProxyServer) Subscribe

func (s *ProxyServer) Subscribe(request *e2api.SubscribeRequest, server e2api.SubscriptionService_SubscribeServer) error

func (*ProxyServer) Unsubscribe

func (s *ProxyServer) Unsubscribe(ctx context.Context, request *e2api.UnsubscribeRequest) (*e2api.UnsubscribeResponse, error)

type SubscriptionService

type SubscriptionService struct {
	northbound.Service
	// contains filtered or unexported fields
}

SubscriptionService is a Service implementation for E2 Subscription service.

func (SubscriptionService) Register

func (s SubscriptionService) Register(r *grpc.Server)

Register registers the SubscriptionService with the gRPC server.