endpoint

package
v0.8.34 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package endpoint is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEndpoint        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEndpoint          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEndpoint = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EventType_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	3: "REMOVED",
}
View Source 
var EventType_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"REMOVED": 3,
}

Functions

func RegisterE2RegistryServiceServer 

func RegisterE2RegistryServiceServer(s *grpc.Server, srv E2RegistryServiceServer)

Types

type AddTerminationRequest 

type AddTerminationRequest struct {
	Endpoint *TerminationEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
}

AddTerminationRequest is a request for adding a new termination point

func (*AddTerminationRequest) Descriptor 

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

func (*AddTerminationRequest) GetEndpoint 

func (m *AddTerminationRequest) GetEndpoint() *TerminationEndpoint

func (*AddTerminationRequest) Marshal 

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

func (*AddTerminationRequest) MarshalTo 

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

func (*AddTerminationRequest) MarshalToSizedBuffer 

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

func (*AddTerminationRequest) ProtoMessage 

func (*AddTerminationRequest) ProtoMessage()

func (*AddTerminationRequest) Reset 

func (m *AddTerminationRequest) Reset()

func (*AddTerminationRequest) Size 

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

func (*AddTerminationRequest) String 

func (m *AddTerminationRequest) String() string

func (*AddTerminationRequest) Unmarshal 

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

func (*AddTerminationRequest) XXX_DiscardUnknown 

func (m *AddTerminationRequest) XXX_DiscardUnknown()

func (*AddTerminationRequest) XXX_Marshal 

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

func (*AddTerminationRequest) XXX_Merge 

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

func (*AddTerminationRequest) XXX_Size 

func (m *AddTerminationRequest) XXX_Size() int

func (*AddTerminationRequest) XXX_Unmarshal 

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

type AddTerminationResponse 

type AddTerminationResponse struct {
}

AddTerminationResponse is a response to adding a new termination point

func (*AddTerminationResponse) Descriptor 

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

func (*AddTerminationResponse) Marshal 

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

func (*AddTerminationResponse) MarshalTo 

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

func (*AddTerminationResponse) MarshalToSizedBuffer 

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

func (*AddTerminationResponse) ProtoMessage 

func (*AddTerminationResponse) ProtoMessage()

func (*AddTerminationResponse) Reset 

func (m *AddTerminationResponse) Reset()

func (*AddTerminationResponse) Size 

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

func (*AddTerminationResponse) String 

func (m *AddTerminationResponse) String() string

func (*AddTerminationResponse) Unmarshal 

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

func (*AddTerminationResponse) XXX_DiscardUnknown 

func (m *AddTerminationResponse) XXX_DiscardUnknown()

func (*AddTerminationResponse) XXX_Marshal 

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

func (*AddTerminationResponse) XXX_Merge 

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

func (*AddTerminationResponse) XXX_Size 

func (m *AddTerminationResponse) XXX_Size() int

func (*AddTerminationResponse) XXX_Unmarshal 

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

type E2RegistryServiceClient 

type E2RegistryServiceClient interface {
	// AddTermination registers new E2 termination end-point.
	AddTermination(ctx context.Context, in *AddTerminationRequest, opts ...grpc.CallOption) (*AddTerminationResponse, error)
	// GetTermination retrieves information about a specific end-point
	GetTermination(ctx context.Context, in *GetTerminationRequest, opts ...grpc.CallOption) (*GetTerminationResponse, error)
	// RemoveTermination removes the specified E2 termination end-point.
	RemoveTermination(ctx context.Context, in *RemoveTerminationRequest, opts ...grpc.CallOption) (*RemoveTerminationResponse, error)
	// ListTerminations returns the list of currently registered E2 terminations.
	ListTerminations(ctx context.Context, in *ListTerminationsRequest, opts ...grpc.CallOption) (*ListTerminationsResponse, error)
	// WatchTerminations returns a stream of changes in the set of available E2 terminations.
	WatchTerminations(ctx context.Context, in *WatchTerminationsRequest, opts ...grpc.CallOption) (E2RegistryService_WatchTerminationsClient, error)
}

E2RegistryServiceClient is the client API for E2RegistryService service.

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

func NewE2RegistryServiceClient 

func NewE2RegistryServiceClient(cc *grpc.ClientConn) E2RegistryServiceClient

type E2RegistryServiceServer 

type E2RegistryServiceServer interface {
	// AddTermination registers new E2 termination end-point.
	AddTermination(context.Context, *AddTerminationRequest) (*AddTerminationResponse, error)
	// GetTermination retrieves information about a specific end-point
	GetTermination(context.Context, *GetTerminationRequest) (*GetTerminationResponse, error)
	// RemoveTermination removes the specified E2 termination end-point.
	RemoveTermination(context.Context, *RemoveTerminationRequest) (*RemoveTerminationResponse, error)
	// ListTerminations returns the list of currently registered E2 terminations.
	ListTerminations(context.Context, *ListTerminationsRequest) (*ListTerminationsResponse, error)
	// WatchTerminations returns a stream of changes in the set of available E2 terminations.
	WatchTerminations(*WatchTerminationsRequest, E2RegistryService_WatchTerminationsServer) error
}

E2RegistryServiceServer is the server API for E2RegistryService service.

type E2RegistryService_WatchTerminationsClient 

type E2RegistryService_WatchTerminationsClient interface {
	Recv() (*WatchTerminationsResponse, error)
	grpc.ClientStream
}

type E2RegistryService_WatchTerminationsServer 

type E2RegistryService_WatchTerminationsServer interface {
	Send(*WatchTerminationsResponse) error
	grpc.ServerStream
}

type Event 

type Event struct {
	Type     EventType           `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2sub.endpoint.EventType" json:"type,omitempty"`
	Endpoint TerminationEndpoint `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint"`
}

Event is an end-point event

func (*Event) Descriptor 

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

func (*Event) GetEndpoint 

func (m *Event) GetEndpoint() TerminationEndpoint

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventType 

type EventType int32

Type of change 

const (
	EventType_NONE    EventType = 0
	EventType_ADDED   EventType = 1
	EventType_REMOVED EventType = 3
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type GetTerminationRequest 

type GetTerminationRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

GetTerminationRequest is a request for getting existing termination point

func (*GetTerminationRequest) Descriptor 

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

func (*GetTerminationRequest) GetID 

func (m *GetTerminationRequest) GetID() ID

func (*GetTerminationRequest) Marshal 

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

func (*GetTerminationRequest) MarshalTo 

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

func (*GetTerminationRequest) MarshalToSizedBuffer 

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

func (*GetTerminationRequest) ProtoMessage 

func (*GetTerminationRequest) ProtoMessage()

func (*GetTerminationRequest) Reset 

func (m *GetTerminationRequest) Reset()

func (*GetTerminationRequest) Size 

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

func (*GetTerminationRequest) String 

func (m *GetTerminationRequest) String() string

func (*GetTerminationRequest) Unmarshal 

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

func (*GetTerminationRequest) XXX_DiscardUnknown 

func (m *GetTerminationRequest) XXX_DiscardUnknown()

func (*GetTerminationRequest) XXX_Marshal 

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

func (*GetTerminationRequest) XXX_Merge 

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

func (*GetTerminationRequest) XXX_Size 

func (m *GetTerminationRequest) XXX_Size() int

func (*GetTerminationRequest) XXX_Unmarshal 

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

type GetTerminationResponse 

type GetTerminationResponse struct {
	Endpoint *TerminationEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
}

GetTerminationResponse is a response with invormation about a requested termination point

func (*GetTerminationResponse) Descriptor 

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

func (*GetTerminationResponse) GetEndpoint 

func (m *GetTerminationResponse) GetEndpoint() *TerminationEndpoint

func (*GetTerminationResponse) Marshal 

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

func (*GetTerminationResponse) MarshalTo 

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

func (*GetTerminationResponse) MarshalToSizedBuffer 

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

func (*GetTerminationResponse) ProtoMessage 

func (*GetTerminationResponse) ProtoMessage()

func (*GetTerminationResponse) Reset 

func (m *GetTerminationResponse) Reset()

func (*GetTerminationResponse) Size 

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

func (*GetTerminationResponse) String 

func (m *GetTerminationResponse) String() string

func (*GetTerminationResponse) Unmarshal 

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

func (*GetTerminationResponse) XXX_DiscardUnknown 

func (m *GetTerminationResponse) XXX_DiscardUnknown()

func (*GetTerminationResponse) XXX_Marshal 

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

func (*GetTerminationResponse) XXX_Merge 

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

func (*GetTerminationResponse) XXX_Size 

func (m *GetTerminationResponse) XXX_Size() int

func (*GetTerminationResponse) XXX_Unmarshal 

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

type ID 

type ID string

ID is a device ID

type IP 

type IP string

IP is an IP address encoded as a string

type ListTerminationsRequest 

type ListTerminationsRequest struct {
}

ListTerminationsRequest is a request to list all available E2 terminations

func (*ListTerminationsRequest) Descriptor 

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

func (*ListTerminationsRequest) Marshal 

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

func (*ListTerminationsRequest) MarshalTo 

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

func (*ListTerminationsRequest) MarshalToSizedBuffer 

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

func (*ListTerminationsRequest) ProtoMessage 

func (*ListTerminationsRequest) ProtoMessage()

func (*ListTerminationsRequest) Reset 

func (m *ListTerminationsRequest) Reset()

func (*ListTerminationsRequest) Size 

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

func (*ListTerminationsRequest) String 

func (m *ListTerminationsRequest) String() string

func (*ListTerminationsRequest) Unmarshal 

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

func (*ListTerminationsRequest) XXX_DiscardUnknown 

func (m *ListTerminationsRequest) XXX_DiscardUnknown()

func (*ListTerminationsRequest) XXX_Marshal 

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

func (*ListTerminationsRequest) XXX_Merge 

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

func (*ListTerminationsRequest) XXX_Size 

func (m *ListTerminationsRequest) XXX_Size() int

func (*ListTerminationsRequest) XXX_Unmarshal 

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

type ListTerminationsResponse 

type ListTerminationsResponse struct {
	Endpoints []TerminationEndpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints"`
}

ListTerminationsResponse is a response to list all available E2 terminations

func (*ListTerminationsResponse) Descriptor 

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

func (*ListTerminationsResponse) GetEndpoints 

func (m *ListTerminationsResponse) GetEndpoints() []TerminationEndpoint

func (*ListTerminationsResponse) Marshal 

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

func (*ListTerminationsResponse) MarshalTo 

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

func (*ListTerminationsResponse) MarshalToSizedBuffer 

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

func (*ListTerminationsResponse) ProtoMessage 

func (*ListTerminationsResponse) ProtoMessage()

func (*ListTerminationsResponse) Reset 

func (m *ListTerminationsResponse) Reset()

func (*ListTerminationsResponse) Size 

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

func (*ListTerminationsResponse) String 

func (m *ListTerminationsResponse) String() string

func (*ListTerminationsResponse) Unmarshal 

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

func (*ListTerminationsResponse) XXX_DiscardUnknown 

func (m *ListTerminationsResponse) XXX_DiscardUnknown()

func (*ListTerminationsResponse) XXX_Marshal 

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

func (*ListTerminationsResponse) XXX_Merge 

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

func (*ListTerminationsResponse) XXX_Size 

func (m *ListTerminationsResponse) XXX_Size() int

func (*ListTerminationsResponse) XXX_Unmarshal 

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

type MockE2RegistryServiceClient added in v0.6.11 

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

MockE2RegistryServiceClient is a mock of E2RegistryServiceClient interface

func NewMockE2RegistryServiceClient added in v0.6.11 

func NewMockE2RegistryServiceClient(ctrl *gomock.Controller) *MockE2RegistryServiceClient

NewMockE2RegistryServiceClient creates a new mock instance

func (*MockE2RegistryServiceClient) AddTermination added in v0.6.11 

func (m *MockE2RegistryServiceClient) AddTermination(ctx context.Context, in *AddTerminationRequest, opts ...grpc.CallOption) (*AddTerminationResponse, error)

AddTermination mocks base method

func (*MockE2RegistryServiceClient) EXPECT added in v0.6.11 

func (m *MockE2RegistryServiceClient) EXPECT() *MockE2RegistryServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2RegistryServiceClient) GetTermination added in v0.6.11 

func (m *MockE2RegistryServiceClient) GetTermination(ctx context.Context, in *GetTerminationRequest, opts ...grpc.CallOption) (*GetTerminationResponse, error)

GetTermination mocks base method

func (*MockE2RegistryServiceClient) ListTerminations added in v0.6.11 

func (m *MockE2RegistryServiceClient) ListTerminations(ctx context.Context, in *ListTerminationsRequest, opts ...grpc.CallOption) (*ListTerminationsResponse, error)

ListTerminations mocks base method

func (*MockE2RegistryServiceClient) RemoveTermination added in v0.6.11 

func (m *MockE2RegistryServiceClient) RemoveTermination(ctx context.Context, in *RemoveTerminationRequest, opts ...grpc.CallOption) (*RemoveTerminationResponse, error)

RemoveTermination mocks base method

func (*MockE2RegistryServiceClient) WatchTerminations added in v0.6.11 

func (m *MockE2RegistryServiceClient) WatchTerminations(ctx context.Context, in *WatchTerminationsRequest, opts ...grpc.CallOption) (E2RegistryService_WatchTerminationsClient, error)

WatchTerminations mocks base method

type MockE2RegistryServiceClientMockRecorder added in v0.6.11 

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

MockE2RegistryServiceClientMockRecorder is the mock recorder for MockE2RegistryServiceClient

func (*MockE2RegistryServiceClientMockRecorder) AddTermination added in v0.6.11 

func (mr *MockE2RegistryServiceClientMockRecorder) AddTermination(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddTermination indicates an expected call of AddTermination

func (*MockE2RegistryServiceClientMockRecorder) GetTermination added in v0.6.11 

func (mr *MockE2RegistryServiceClientMockRecorder) GetTermination(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetTermination indicates an expected call of GetTermination

func (*MockE2RegistryServiceClientMockRecorder) ListTerminations added in v0.6.11 

func (mr *MockE2RegistryServiceClientMockRecorder) ListTerminations(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListTerminations indicates an expected call of ListTerminations

func (*MockE2RegistryServiceClientMockRecorder) RemoveTermination added in v0.6.11 

func (mr *MockE2RegistryServiceClientMockRecorder) RemoveTermination(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveTermination indicates an expected call of RemoveTermination

func (*MockE2RegistryServiceClientMockRecorder) WatchTerminations added in v0.6.11 

func (mr *MockE2RegistryServiceClientMockRecorder) WatchTerminations(ctx, in interface{}, opts ...interface{}) *gomock.Call

WatchTerminations indicates an expected call of WatchTerminations

type MockE2RegistryServiceServer added in v0.6.11 

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

MockE2RegistryServiceServer is a mock of E2RegistryServiceServer interface

func NewMockE2RegistryServiceServer added in v0.6.11 

func NewMockE2RegistryServiceServer(ctrl *gomock.Controller) *MockE2RegistryServiceServer

NewMockE2RegistryServiceServer creates a new mock instance

func (*MockE2RegistryServiceServer) AddTermination added in v0.6.11 

func (m *MockE2RegistryServiceServer) AddTermination(arg0 context.Context, arg1 *AddTerminationRequest) (*AddTerminationResponse, error)

AddTermination mocks base method

func (*MockE2RegistryServiceServer) EXPECT added in v0.6.11 

func (m *MockE2RegistryServiceServer) EXPECT() *MockE2RegistryServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2RegistryServiceServer) GetTermination added in v0.6.11 

func (m *MockE2RegistryServiceServer) GetTermination(arg0 context.Context, arg1 *GetTerminationRequest) (*GetTerminationResponse, error)

GetTermination mocks base method

func (*MockE2RegistryServiceServer) ListTerminations added in v0.6.11 

func (m *MockE2RegistryServiceServer) ListTerminations(arg0 context.Context, arg1 *ListTerminationsRequest) (*ListTerminationsResponse, error)

ListTerminations mocks base method

func (*MockE2RegistryServiceServer) RemoveTermination added in v0.6.11 

func (m *MockE2RegistryServiceServer) RemoveTermination(arg0 context.Context, arg1 *RemoveTerminationRequest) (*RemoveTerminationResponse, error)

RemoveTermination mocks base method

func (*MockE2RegistryServiceServer) WatchTerminations added in v0.6.11 

func (m *MockE2RegistryServiceServer) WatchTerminations(arg0 *WatchTerminationsRequest, arg1 E2RegistryService_WatchTerminationsServer) error

WatchTerminations mocks base method

type MockE2RegistryServiceServerMockRecorder added in v0.6.11 

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

MockE2RegistryServiceServerMockRecorder is the mock recorder for MockE2RegistryServiceServer

func (*MockE2RegistryServiceServerMockRecorder) AddTermination added in v0.6.11 

func (mr *MockE2RegistryServiceServerMockRecorder) AddTermination(arg0, arg1 interface{}) *gomock.Call

AddTermination indicates an expected call of AddTermination

func (*MockE2RegistryServiceServerMockRecorder) GetTermination added in v0.6.11 

func (mr *MockE2RegistryServiceServerMockRecorder) GetTermination(arg0, arg1 interface{}) *gomock.Call

GetTermination indicates an expected call of GetTermination

func (*MockE2RegistryServiceServerMockRecorder) ListTerminations added in v0.6.11 

func (mr *MockE2RegistryServiceServerMockRecorder) ListTerminations(arg0, arg1 interface{}) *gomock.Call

ListTerminations indicates an expected call of ListTerminations

func (*MockE2RegistryServiceServerMockRecorder) RemoveTermination added in v0.6.11 

func (mr *MockE2RegistryServiceServerMockRecorder) RemoveTermination(arg0, arg1 interface{}) *gomock.Call

RemoveTermination indicates an expected call of RemoveTermination

func (*MockE2RegistryServiceServerMockRecorder) WatchTerminations added in v0.6.11 

func (mr *MockE2RegistryServiceServerMockRecorder) WatchTerminations(arg0, arg1 interface{}) *gomock.Call

WatchTerminations indicates an expected call of WatchTerminations

type MockE2RegistryService_WatchTerminationsClient added in v0.6.11 

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

MockE2RegistryService_WatchTerminationsClient is a mock of E2RegistryService_WatchTerminationsClient interface

func NewMockE2RegistryService_WatchTerminationsClient added in v0.6.11 

func NewMockE2RegistryService_WatchTerminationsClient(ctrl *gomock.Controller) *MockE2RegistryService_WatchTerminationsClient

NewMockE2RegistryService_WatchTerminationsClient creates a new mock instance

func (*MockE2RegistryService_WatchTerminationsClient) CloseSend added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsClient) CloseSend() error

CloseSend mocks base method

func (*MockE2RegistryService_WatchTerminationsClient) Context added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsClient) Context() context.Context

Context mocks base method

func (*MockE2RegistryService_WatchTerminationsClient) EXPECT added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsClient) EXPECT() *MockE2RegistryService_WatchTerminationsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2RegistryService_WatchTerminationsClient) Header added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockE2RegistryService_WatchTerminationsClient) Recv added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsClient) Recv() (*WatchTerminationsResponse, error)

Recv mocks base method

func (*MockE2RegistryService_WatchTerminationsClient) RecvMsg added in v0.6.11 

func (m_2 *MockE2RegistryService_WatchTerminationsClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockE2RegistryService_WatchTerminationsClient) SendMsg added in v0.6.11 

func (m_2 *MockE2RegistryService_WatchTerminationsClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockE2RegistryService_WatchTerminationsClient) Trailer added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsClient) Trailer() metadata.MD

Trailer mocks base method

type MockE2RegistryService_WatchTerminationsClientMockRecorder added in v0.6.11 

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

MockE2RegistryService_WatchTerminationsClientMockRecorder is the mock recorder for MockE2RegistryService_WatchTerminationsClient

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) CloseSend added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) Context added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) Header added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) Recv added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) SendMsg added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockE2RegistryService_WatchTerminationsClientMockRecorder) Trailer added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockE2RegistryService_WatchTerminationsServer added in v0.6.11 

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

MockE2RegistryService_WatchTerminationsServer is a mock of E2RegistryService_WatchTerminationsServer interface

func NewMockE2RegistryService_WatchTerminationsServer added in v0.6.11 

func NewMockE2RegistryService_WatchTerminationsServer(ctrl *gomock.Controller) *MockE2RegistryService_WatchTerminationsServer

NewMockE2RegistryService_WatchTerminationsServer creates a new mock instance

func (*MockE2RegistryService_WatchTerminationsServer) Context added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsServer) Context() context.Context

Context mocks base method

func (*MockE2RegistryService_WatchTerminationsServer) EXPECT added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsServer) EXPECT() *MockE2RegistryService_WatchTerminationsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockE2RegistryService_WatchTerminationsServer) RecvMsg added in v0.6.11 

func (m_2 *MockE2RegistryService_WatchTerminationsServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockE2RegistryService_WatchTerminationsServer) Send added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsServer) Send(arg0 *WatchTerminationsResponse) error

Send mocks base method

func (*MockE2RegistryService_WatchTerminationsServer) SendHeader added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockE2RegistryService_WatchTerminationsServer) SendMsg added in v0.6.11 

func (m_2 *MockE2RegistryService_WatchTerminationsServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockE2RegistryService_WatchTerminationsServer) SetHeader added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockE2RegistryService_WatchTerminationsServer) SetTrailer added in v0.6.11 

func (m *MockE2RegistryService_WatchTerminationsServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockE2RegistryService_WatchTerminationsServerMockRecorder added in v0.6.11 

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

MockE2RegistryService_WatchTerminationsServerMockRecorder is the mock recorder for MockE2RegistryService_WatchTerminationsServer

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) Context added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) Send added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) SendHeader added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) SendMsg added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) SetHeader added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockE2RegistryService_WatchTerminationsServerMockRecorder) SetTrailer added in v0.6.11 

func (mr *MockE2RegistryService_WatchTerminationsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type Port 

type Port int32

Port is a port number

type RemoveTerminationRequest 

type RemoveTerminationRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

RemoveTerminationRequest is a request for removing termination point

func (*RemoveTerminationRequest) Descriptor 

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

func (*RemoveTerminationRequest) GetID 

func (m *RemoveTerminationRequest) GetID() ID

func (*RemoveTerminationRequest) Marshal 

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

func (*RemoveTerminationRequest) MarshalTo 

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

func (*RemoveTerminationRequest) MarshalToSizedBuffer 

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

func (*RemoveTerminationRequest) ProtoMessage 

func (*RemoveTerminationRequest) ProtoMessage()

func (*RemoveTerminationRequest) Reset 

func (m *RemoveTerminationRequest) Reset()

func (*RemoveTerminationRequest) Size 

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

func (*RemoveTerminationRequest) String 

func (m *RemoveTerminationRequest) String() string

func (*RemoveTerminationRequest) Unmarshal 

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

func (*RemoveTerminationRequest) XXX_DiscardUnknown 

func (m *RemoveTerminationRequest) XXX_DiscardUnknown()

func (*RemoveTerminationRequest) XXX_Marshal 

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

func (*RemoveTerminationRequest) XXX_Merge 

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

func (*RemoveTerminationRequest) XXX_Size 

func (m *RemoveTerminationRequest) XXX_Size() int

func (*RemoveTerminationRequest) XXX_Unmarshal 

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

type RemoveTerminationResponse 

type RemoveTerminationResponse struct {
}

RemoveTerminationResponse is a response to removing a termination point

func (*RemoveTerminationResponse) Descriptor 

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

func (*RemoveTerminationResponse) Marshal 

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

func (*RemoveTerminationResponse) MarshalTo 

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

func (*RemoveTerminationResponse) MarshalToSizedBuffer 

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

func (*RemoveTerminationResponse) ProtoMessage 

func (*RemoveTerminationResponse) ProtoMessage()

func (*RemoveTerminationResponse) Reset 

func (m *RemoveTerminationResponse) Reset()

func (*RemoveTerminationResponse) Size 

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

func (*RemoveTerminationResponse) String 

func (m *RemoveTerminationResponse) String() string

func (*RemoveTerminationResponse) Unmarshal 

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

func (*RemoveTerminationResponse) XXX_DiscardUnknown 

func (m *RemoveTerminationResponse) XXX_DiscardUnknown()

func (*RemoveTerminationResponse) XXX_Marshal 

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

func (*RemoveTerminationResponse) XXX_Merge 

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

func (*RemoveTerminationResponse) XXX_Size 

func (m *RemoveTerminationResponse) XXX_Size() int

func (*RemoveTerminationResponse) XXX_Unmarshal 

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

type Revision 

type Revision uint64

Revision is a subscription revision

type TerminationEndpoint 

type TerminationEndpoint struct {
	ID       ID       `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
	Revision Revision `protobuf:"varint,2,opt,name=revision,proto3,casttype=Revision" json:"revision,omitempty"`
	IP       IP       `protobuf:"bytes,3,opt,name=ip,proto3,casttype=IP" json:"ip,omitempty"`
	Port     Port     `protobuf:"varint,4,opt,name=port,proto3,casttype=Port" json:"port,omitempty"`
}

Termination is a record identifying the IP address and TCP port coordinates where the E2 termination service is available.

func (*TerminationEndpoint) Descriptor 

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

func (*TerminationEndpoint) GetID 

func (m *TerminationEndpoint) GetID() ID

func (*TerminationEndpoint) GetIP 

func (m *TerminationEndpoint) GetIP() IP

func (*TerminationEndpoint) GetPort 

func (m *TerminationEndpoint) GetPort() Port

func (*TerminationEndpoint) GetRevision 

func (m *TerminationEndpoint) GetRevision() Revision

func (*TerminationEndpoint) Marshal 

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

func (*TerminationEndpoint) MarshalTo 

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

func (*TerminationEndpoint) MarshalToSizedBuffer 

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

func (*TerminationEndpoint) ProtoMessage 

func (*TerminationEndpoint) ProtoMessage()

func (*TerminationEndpoint) Reset 

func (m *TerminationEndpoint) Reset()

func (*TerminationEndpoint) Size 

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

func (*TerminationEndpoint) String 

func (m *TerminationEndpoint) String() string

func (*TerminationEndpoint) Unmarshal 

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

func (*TerminationEndpoint) XXX_DiscardUnknown 

func (m *TerminationEndpoint) XXX_DiscardUnknown()

func (*TerminationEndpoint) XXX_Marshal 

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

func (*TerminationEndpoint) XXX_Merge 

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

func (*TerminationEndpoint) XXX_Size 

func (m *TerminationEndpoint) XXX_Size() int

func (*TerminationEndpoint) XXX_Unmarshal 

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

type UnimplementedE2RegistryServiceServer 

type UnimplementedE2RegistryServiceServer struct {
}

UnimplementedE2RegistryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2RegistryServiceServer) AddTermination 

func (*UnimplementedE2RegistryServiceServer) AddTermination(ctx context.Context, req *AddTerminationRequest) (*AddTerminationResponse, error)

func (*UnimplementedE2RegistryServiceServer) GetTermination 

func (*UnimplementedE2RegistryServiceServer) GetTermination(ctx context.Context, req *GetTerminationRequest) (*GetTerminationResponse, error)

func (*UnimplementedE2RegistryServiceServer) ListTerminations 

func (*UnimplementedE2RegistryServiceServer) ListTerminations(ctx context.Context, req *ListTerminationsRequest) (*ListTerminationsResponse, error)

func (*UnimplementedE2RegistryServiceServer) RemoveTermination 

func (*UnimplementedE2RegistryServiceServer) RemoveTermination(ctx context.Context, req *RemoveTerminationRequest) (*RemoveTerminationResponse, error)

func (*UnimplementedE2RegistryServiceServer) WatchTerminations 

func (*UnimplementedE2RegistryServiceServer) WatchTerminations(req *WatchTerminationsRequest, srv E2RegistryService_WatchTerminationsServer) error

type WatchTerminationsRequest 

type WatchTerminationsRequest struct {
	Noreplay bool `protobuf:"varint,1,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
}

WatchTerminationsRequest is a request to receive a stream of all E2 termination changes.

func (*WatchTerminationsRequest) Descriptor 

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

func (*WatchTerminationsRequest) GetNoreplay 

func (m *WatchTerminationsRequest) GetNoreplay() bool

func (*WatchTerminationsRequest) Marshal 

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

func (*WatchTerminationsRequest) MarshalTo 

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

func (*WatchTerminationsRequest) MarshalToSizedBuffer 

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

func (*WatchTerminationsRequest) ProtoMessage 

func (*WatchTerminationsRequest) ProtoMessage()

func (*WatchTerminationsRequest) Reset 

func (m *WatchTerminationsRequest) Reset()

func (*WatchTerminationsRequest) Size 

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

func (*WatchTerminationsRequest) String 

func (m *WatchTerminationsRequest) String() string

func (*WatchTerminationsRequest) Unmarshal 

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

func (*WatchTerminationsRequest) XXX_DiscardUnknown 

func (m *WatchTerminationsRequest) XXX_DiscardUnknown()

func (*WatchTerminationsRequest) XXX_Marshal 

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

func (*WatchTerminationsRequest) XXX_Merge 

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

func (*WatchTerminationsRequest) XXX_Size 

func (m *WatchTerminationsRequest) XXX_Size() int

func (*WatchTerminationsRequest) XXX_Unmarshal 

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

type WatchTerminationsResponse 

type WatchTerminationsResponse struct {
	Event Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
}

WatchTerminationsResponse is a response indicating a change in the available E2 termination end-points.

func (*WatchTerminationsResponse) Descriptor 

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

func (*WatchTerminationsResponse) GetEvent 

func (m *WatchTerminationsResponse) GetEvent() Event

func (*WatchTerminationsResponse) Marshal 

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

func (*WatchTerminationsResponse) MarshalTo 

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

func (*WatchTerminationsResponse) MarshalToSizedBuffer 

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

func (*WatchTerminationsResponse) ProtoMessage 

func (*WatchTerminationsResponse) ProtoMessage()

func (*WatchTerminationsResponse) Reset 

func (m *WatchTerminationsResponse) Reset()

func (*WatchTerminationsResponse) Size 

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

func (*WatchTerminationsResponse) String 

func (m *WatchTerminationsResponse) String() string

func (*WatchTerminationsResponse) Unmarshal 

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

func (*WatchTerminationsResponse) XXX_DiscardUnknown 

func (m *WatchTerminationsResponse) XXX_DiscardUnknown()

func (*WatchTerminationsResponse) XXX_Marshal 

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

func (*WatchTerminationsResponse) XXX_Merge 

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

func (*WatchTerminationsResponse) XXX_Size 

func (m *WatchTerminationsResponse) XXX_Size() int

func (*WatchTerminationsResponse) XXX_Unmarshal 

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