admin

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: 12 Imported by: 2

Documentation

Overview

Package admin is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAdmin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdmin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var E2NodeConnectionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "G_NB",
	2: "E_NB",
	3: "ENG_MB",
	4: "NGE_NB",
}
View Source 
var E2NodeConnectionType_value = map[string]int32{
	"UNKNOWN": 0,
	"G_NB":    1,
	"E_NB":    2,
	"ENG_MB":  3,
	"NGE_NB":  4,
}

Functions

func RegisterE2TAdminServiceServer 

func RegisterE2TAdminServiceServer(s *grpc.Server, srv E2TAdminServiceServer)

Types

type DropE2NodeConnectionsRequest 

type DropE2NodeConnectionsRequest struct {
	Connections []*ListE2NodeConnectionsResponse `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
}

DropE2NodeConnectionsRequest carries drop connection request

func (*DropE2NodeConnectionsRequest) Descriptor 

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

func (*DropE2NodeConnectionsRequest) GetConnections 

func (m *DropE2NodeConnectionsRequest) GetConnections() []*ListE2NodeConnectionsResponse

func (*DropE2NodeConnectionsRequest) Marshal 

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

func (*DropE2NodeConnectionsRequest) MarshalTo 

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

func (*DropE2NodeConnectionsRequest) MarshalToSizedBuffer 

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

func (*DropE2NodeConnectionsRequest) ProtoMessage 

func (*DropE2NodeConnectionsRequest) ProtoMessage()

func (*DropE2NodeConnectionsRequest) Reset 

func (m *DropE2NodeConnectionsRequest) Reset()

func (*DropE2NodeConnectionsRequest) Size 

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

func (*DropE2NodeConnectionsRequest) String 

func (m *DropE2NodeConnectionsRequest) String() string

func (*DropE2NodeConnectionsRequest) Unmarshal 

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

func (*DropE2NodeConnectionsRequest) XXX_DiscardUnknown 

func (m *DropE2NodeConnectionsRequest) XXX_DiscardUnknown()

func (*DropE2NodeConnectionsRequest) XXX_Marshal 

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

func (*DropE2NodeConnectionsRequest) XXX_Merge 

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

func (*DropE2NodeConnectionsRequest) XXX_Size 

func (m *DropE2NodeConnectionsRequest) XXX_Size() int

func (*DropE2NodeConnectionsRequest) XXX_Unmarshal 

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

type DropE2NodeConnectionsResponse 

type DropE2NodeConnectionsResponse struct {
	Success []bool `protobuf:"varint,1,rep,packed,name=success,proto3" json:"success,omitempty"`
}

DropE2NodeConnectionsResponse carries drop connection response

func (*DropE2NodeConnectionsResponse) Descriptor 

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

func (*DropE2NodeConnectionsResponse) GetSuccess 

func (m *DropE2NodeConnectionsResponse) GetSuccess() []bool

func (*DropE2NodeConnectionsResponse) Marshal 

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

func (*DropE2NodeConnectionsResponse) MarshalTo 

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

func (*DropE2NodeConnectionsResponse) MarshalToSizedBuffer 

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

func (*DropE2NodeConnectionsResponse) ProtoMessage 

func (*DropE2NodeConnectionsResponse) ProtoMessage()

func (*DropE2NodeConnectionsResponse) Reset 

func (m *DropE2NodeConnectionsResponse) Reset()

func (*DropE2NodeConnectionsResponse) Size 

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

func (*DropE2NodeConnectionsResponse) String 

func (m *DropE2NodeConnectionsResponse) String() string

func (*DropE2NodeConnectionsResponse) Unmarshal 

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

func (*DropE2NodeConnectionsResponse) XXX_DiscardUnknown 

func (m *DropE2NodeConnectionsResponse) XXX_DiscardUnknown()

func (*DropE2NodeConnectionsResponse) XXX_Marshal 

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

func (*DropE2NodeConnectionsResponse) XXX_Merge 

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

func (*DropE2NodeConnectionsResponse) XXX_Size 

func (m *DropE2NodeConnectionsResponse) XXX_Size() int

func (*DropE2NodeConnectionsResponse) XXX_Unmarshal 

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

type E2NodeConnectionType 

type E2NodeConnectionType int32

E2NodeConnectionType specifies the type of an E2 connection 

const (
	E2NodeConnectionType_UNKNOWN E2NodeConnectionType = 0
	E2NodeConnectionType_G_NB    E2NodeConnectionType = 1
	E2NodeConnectionType_E_NB    E2NodeConnectionType = 2
	E2NodeConnectionType_ENG_MB  E2NodeConnectionType = 3
	E2NodeConnectionType_NGE_NB  E2NodeConnectionType = 4
)

func (E2NodeConnectionType) EnumDescriptor 

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

func (E2NodeConnectionType) String 

func (x E2NodeConnectionType) String() string

type E2TAdminServiceClient 

type E2TAdminServiceClient interface {
	// UploadRegisterServiceModel uploads and adds the model plugin to the list of supported models.
	// The file is serialized in to Chunks of less than 4MB so as not to break the
	// gRPC byte array limit
	UploadRegisterServiceModel(ctx context.Context, opts ...grpc.CallOption) (E2TAdminService_UploadRegisterServiceModelClient, error)
	// ListRegisteredServiceModels returns a stream of registered service models.
	ListRegisteredServiceModels(ctx context.Context, in *ListRegisteredServiceModelsRequest, opts ...grpc.CallOption) (E2TAdminService_ListRegisteredServiceModelsClient, error)
	// ListE2NodeConnections returns a stream of existing SCTP connections.
	ListE2NodeConnections(ctx context.Context, in *ListE2NodeConnectionsRequest, opts ...grpc.CallOption) (E2TAdminService_ListE2NodeConnectionsClient, error)
	// DropE2NodeConnections drops the specified E2 node SCTP connections
	DropE2NodeConnections(ctx context.Context, in *DropE2NodeConnectionsRequest, opts ...grpc.CallOption) (*DropE2NodeConnectionsResponse, error)
}

E2TAdminServiceClient is the client API for E2TAdminService service.

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

func NewE2TAdminServiceClient 

func NewE2TAdminServiceClient(cc *grpc.ClientConn) E2TAdminServiceClient

type E2TAdminServiceServer 

type E2TAdminServiceServer interface {
	// UploadRegisterServiceModel uploads and adds the model plugin to the list of supported models.
	// The file is serialized in to Chunks of less than 4MB so as not to break the
	// gRPC byte array limit
	UploadRegisterServiceModel(E2TAdminService_UploadRegisterServiceModelServer) error
	// ListRegisteredServiceModels returns a stream of registered service models.
	ListRegisteredServiceModels(*ListRegisteredServiceModelsRequest, E2TAdminService_ListRegisteredServiceModelsServer) error
	// ListE2NodeConnections returns a stream of existing SCTP connections.
	ListE2NodeConnections(*ListE2NodeConnectionsRequest, E2TAdminService_ListE2NodeConnectionsServer) error
	// DropE2NodeConnections drops the specified E2 node SCTP connections
	DropE2NodeConnections(context.Context, *DropE2NodeConnectionsRequest) (*DropE2NodeConnectionsResponse, error)
}

E2TAdminServiceServer is the server API for E2TAdminService service.

type E2TAdminService_ListE2NodeConnectionsClient 

type E2TAdminService_ListE2NodeConnectionsClient interface {
	Recv() (*ListE2NodeConnectionsResponse, error)
	grpc.ClientStream
}

type E2TAdminService_ListE2NodeConnectionsServer 

type E2TAdminService_ListE2NodeConnectionsServer interface {
	Send(*ListE2NodeConnectionsResponse) error
	grpc.ServerStream
}

type E2TAdminService_ListRegisteredServiceModelsClient 

type E2TAdminService_ListRegisteredServiceModelsClient interface {
	Recv() (*ListRegisteredServiceModelsResponse, error)
	grpc.ClientStream
}

type E2TAdminService_ListRegisteredServiceModelsServer 

type E2TAdminService_ListRegisteredServiceModelsServer interface {
	Send(*ListRegisteredServiceModelsResponse) error
	grpc.ServerStream
}

type E2TAdminService_UploadRegisterServiceModelClient 

type E2TAdminService_UploadRegisterServiceModelClient interface {
	Send(*UploadRegisterServiceModelRequest) error
	CloseAndRecv() (*UploadRegisterServiceModelResponse, error)
	grpc.ClientStream
}

type E2TAdminService_UploadRegisterServiceModelServer 

type E2TAdminService_UploadRegisterServiceModelServer interface {
	SendAndClose(*UploadRegisterServiceModelResponse) error
	Recv() (*UploadRegisterServiceModelRequest, error)
	grpc.ServerStream
}

type ListE2NodeConnectionsRequest 

type ListE2NodeConnectionsRequest struct {
}

ListE2NodeConnectionsRequest carries request for a list of E2 node SCTP connections.

func (*ListE2NodeConnectionsRequest) Descriptor 

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

func (*ListE2NodeConnectionsRequest) Marshal 

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

func (*ListE2NodeConnectionsRequest) MarshalTo 

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

func (*ListE2NodeConnectionsRequest) MarshalToSizedBuffer 

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

func (*ListE2NodeConnectionsRequest) ProtoMessage 

func (*ListE2NodeConnectionsRequest) ProtoMessage()

func (*ListE2NodeConnectionsRequest) Reset 

func (m *ListE2NodeConnectionsRequest) Reset()

func (*ListE2NodeConnectionsRequest) Size 

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

func (*ListE2NodeConnectionsRequest) String 

func (m *ListE2NodeConnectionsRequest) String() string

func (*ListE2NodeConnectionsRequest) Unmarshal 

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

func (*ListE2NodeConnectionsRequest) XXX_DiscardUnknown 

func (m *ListE2NodeConnectionsRequest) XXX_DiscardUnknown()

func (*ListE2NodeConnectionsRequest) XXX_Marshal 

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

func (*ListE2NodeConnectionsRequest) XXX_Merge 

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

func (*ListE2NodeConnectionsRequest) XXX_Size 

func (m *ListE2NodeConnectionsRequest) XXX_Size() int

func (*ListE2NodeConnectionsRequest) XXX_Unmarshal 

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

type ListE2NodeConnectionsResponse 

type ListE2NodeConnectionsResponse struct {
	Id             string               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	RemoteIp       []string             `protobuf:"bytes,1,rep,name=remote_ip,json=remoteIp,proto3" json:"remote_ip,omitempty"`
	RemotePort     uint32               `protobuf:"varint,2,opt,name=remote_port,json=remotePort,proto3" json:"remote_port,omitempty"`
	NodeId         string               `protobuf:"bytes,7,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	PlmnId         string               `protobuf:"bytes,4,opt,name=plmn_id,json=plmnId,proto3" json:"plmn_id,omitempty"`
	ConnectionType E2NodeConnectionType `` /* 145-byte string literal not displayed */
	RanFunctions   []*RANFunction       `protobuf:"bytes,6,rep,name=ran_functions,json=ranFunctions,proto3" json:"ran_functions,omitempty"`
	AgeMs          int32                `protobuf:"varint,8,opt,name=age_ms,json=ageMs,proto3" json:"age_ms,omitempty"`
}

ListE2NodeConnectionsResponse carries information about the SCTP connection to the remote E2 node.

func (*ListE2NodeConnectionsResponse) Descriptor 

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

func (*ListE2NodeConnectionsResponse) GetAgeMs added in v0.7.72 

func (m *ListE2NodeConnectionsResponse) GetAgeMs() int32

func (*ListE2NodeConnectionsResponse) GetConnectionType 

func (m *ListE2NodeConnectionsResponse) GetConnectionType() E2NodeConnectionType

func (*ListE2NodeConnectionsResponse) GetId 

func (m *ListE2NodeConnectionsResponse) GetId() string

func (*ListE2NodeConnectionsResponse) GetNodeId added in v0.7.72 

func (m *ListE2NodeConnectionsResponse) GetNodeId() string

func (*ListE2NodeConnectionsResponse) GetPlmnId 

func (m *ListE2NodeConnectionsResponse) GetPlmnId() string

func (*ListE2NodeConnectionsResponse) GetRanFunctions added in v0.7.23 

func (m *ListE2NodeConnectionsResponse) GetRanFunctions() []*RANFunction

func (*ListE2NodeConnectionsResponse) GetRemoteIp 

func (m *ListE2NodeConnectionsResponse) GetRemoteIp() []string

func (*ListE2NodeConnectionsResponse) GetRemotePort 

func (m *ListE2NodeConnectionsResponse) GetRemotePort() uint32

func (*ListE2NodeConnectionsResponse) Marshal 

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

func (*ListE2NodeConnectionsResponse) MarshalTo 

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

func (*ListE2NodeConnectionsResponse) MarshalToSizedBuffer 

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

func (*ListE2NodeConnectionsResponse) ProtoMessage 

func (*ListE2NodeConnectionsResponse) ProtoMessage()

func (*ListE2NodeConnectionsResponse) Reset 

func (m *ListE2NodeConnectionsResponse) Reset()

func (*ListE2NodeConnectionsResponse) Size 

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

func (*ListE2NodeConnectionsResponse) String 

func (m *ListE2NodeConnectionsResponse) String() string

func (*ListE2NodeConnectionsResponse) Unmarshal 

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

func (*ListE2NodeConnectionsResponse) XXX_DiscardUnknown 

func (m *ListE2NodeConnectionsResponse) XXX_DiscardUnknown()

func (*ListE2NodeConnectionsResponse) XXX_Marshal 

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

func (*ListE2NodeConnectionsResponse) XXX_Merge 

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

func (*ListE2NodeConnectionsResponse) XXX_Size 

func (m *ListE2NodeConnectionsResponse) XXX_Size() int

func (*ListE2NodeConnectionsResponse) XXX_Unmarshal 

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

type ListRegisteredServiceModelsRequest 

type ListRegisteredServiceModelsRequest struct {
	// An optional filter on the name of the model plugins to list.
	ModelName string `protobuf:"bytes,1,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// An optional filter on the version of the model plugins to list
	ModelVersion string `protobuf:"bytes,2,opt,name=model_version,json=modelVersion,proto3" json:"model_version,omitempty"`
}

ListRegisteredServiceModelsRequest carries data for querying registered service model plugins.

func (*ListRegisteredServiceModelsRequest) Descriptor 

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

func (*ListRegisteredServiceModelsRequest) GetModelName 

func (m *ListRegisteredServiceModelsRequest) GetModelName() string

func (*ListRegisteredServiceModelsRequest) GetModelVersion 

func (m *ListRegisteredServiceModelsRequest) GetModelVersion() string

func (*ListRegisteredServiceModelsRequest) Marshal 

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

func (*ListRegisteredServiceModelsRequest) MarshalTo 

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

func (*ListRegisteredServiceModelsRequest) MarshalToSizedBuffer 

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

func (*ListRegisteredServiceModelsRequest) ProtoMessage 

func (*ListRegisteredServiceModelsRequest) ProtoMessage()

func (*ListRegisteredServiceModelsRequest) Reset 

func (m *ListRegisteredServiceModelsRequest) Reset()

func (*ListRegisteredServiceModelsRequest) Size 

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

func (*ListRegisteredServiceModelsRequest) String 

func (m *ListRegisteredServiceModelsRequest) String() string

func (*ListRegisteredServiceModelsRequest) Unmarshal 

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

func (*ListRegisteredServiceModelsRequest) XXX_DiscardUnknown 

func (m *ListRegisteredServiceModelsRequest) XXX_DiscardUnknown()

func (*ListRegisteredServiceModelsRequest) XXX_Marshal 

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

func (*ListRegisteredServiceModelsRequest) XXX_Merge 

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

func (*ListRegisteredServiceModelsRequest) XXX_Size 

func (m *ListRegisteredServiceModelsRequest) XXX_Size() int

func (*ListRegisteredServiceModelsRequest) XXX_Unmarshal 

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

type ListRegisteredServiceModelsResponse 

type ListRegisteredServiceModelsResponse struct {
	// name is the name given to the service model plugin - no spaces and title case.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// version is the semantic version of the Plugin e.g. 1.0.0.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
}

ListRegisteredServiceModelsResponse is general information about a service model plugin.

func (*ListRegisteredServiceModelsResponse) Descriptor 

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

func (*ListRegisteredServiceModelsResponse) GetName 

func (m *ListRegisteredServiceModelsResponse) GetName() string

func (*ListRegisteredServiceModelsResponse) GetVersion 

func (m *ListRegisteredServiceModelsResponse) GetVersion() string

func (*ListRegisteredServiceModelsResponse) Marshal 

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

func (*ListRegisteredServiceModelsResponse) MarshalTo 

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

func (*ListRegisteredServiceModelsResponse) MarshalToSizedBuffer 

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

func (*ListRegisteredServiceModelsResponse) ProtoMessage 

func (*ListRegisteredServiceModelsResponse) ProtoMessage()

func (*ListRegisteredServiceModelsResponse) Reset 

func (m *ListRegisteredServiceModelsResponse) Reset()

func (*ListRegisteredServiceModelsResponse) Size 

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

func (*ListRegisteredServiceModelsResponse) String 

func (m *ListRegisteredServiceModelsResponse) String() string

func (*ListRegisteredServiceModelsResponse) Unmarshal 

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

func (*ListRegisteredServiceModelsResponse) XXX_DiscardUnknown 

func (m *ListRegisteredServiceModelsResponse) XXX_DiscardUnknown()

func (*ListRegisteredServiceModelsResponse) XXX_Marshal 

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

func (*ListRegisteredServiceModelsResponse) XXX_Merge 

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

func (*ListRegisteredServiceModelsResponse) XXX_Size 

func (m *ListRegisteredServiceModelsResponse) XXX_Size() int

func (*ListRegisteredServiceModelsResponse) XXX_Unmarshal 

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

type MockE2TAdminServiceClient added in v0.6.11 

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

MockE2TAdminServiceClient is a mock of E2TAdminServiceClient interface

func NewMockE2TAdminServiceClient added in v0.6.11 

func NewMockE2TAdminServiceClient(ctrl *gomock.Controller) *MockE2TAdminServiceClient

NewMockE2TAdminServiceClient creates a new mock instance

func (*MockE2TAdminServiceClient) DropE2NodeConnections added in v0.6.11 

func (m *MockE2TAdminServiceClient) DropE2NodeConnections(ctx context.Context, in *DropE2NodeConnectionsRequest, opts ...grpc.CallOption) (*DropE2NodeConnectionsResponse, error)

DropE2NodeConnections mocks base method

func (*MockE2TAdminServiceClient) EXPECT added in v0.6.11 

func (m *MockE2TAdminServiceClient) EXPECT() *MockE2TAdminServiceClientMockRecorder

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

func (*MockE2TAdminServiceClient) ListE2NodeConnections added in v0.6.11 

func (m *MockE2TAdminServiceClient) ListE2NodeConnections(ctx context.Context, in *ListE2NodeConnectionsRequest, opts ...grpc.CallOption) (E2TAdminService_ListE2NodeConnectionsClient, error)

ListE2NodeConnections mocks base method

func (*MockE2TAdminServiceClient) ListRegisteredServiceModels added in v0.6.11 

func (m *MockE2TAdminServiceClient) ListRegisteredServiceModels(ctx context.Context, in *ListRegisteredServiceModelsRequest, opts ...grpc.CallOption) (E2TAdminService_ListRegisteredServiceModelsClient, error)

ListRegisteredServiceModels mocks base method

func (*MockE2TAdminServiceClient) UploadRegisterServiceModel added in v0.6.11 

func (m *MockE2TAdminServiceClient) UploadRegisterServiceModel(ctx context.Context, opts ...grpc.CallOption) (E2TAdminService_UploadRegisterServiceModelClient, error)

UploadRegisterServiceModel mocks base method

type MockE2TAdminServiceClientMockRecorder added in v0.6.11 

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

MockE2TAdminServiceClientMockRecorder is the mock recorder for MockE2TAdminServiceClient

func (*MockE2TAdminServiceClientMockRecorder) DropE2NodeConnections added in v0.6.11 

func (mr *MockE2TAdminServiceClientMockRecorder) DropE2NodeConnections(ctx, in interface{}, opts ...interface{}) *gomock.Call

DropE2NodeConnections indicates an expected call of DropE2NodeConnections

func (*MockE2TAdminServiceClientMockRecorder) ListE2NodeConnections added in v0.6.11 

func (mr *MockE2TAdminServiceClientMockRecorder) ListE2NodeConnections(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListE2NodeConnections indicates an expected call of ListE2NodeConnections

func (*MockE2TAdminServiceClientMockRecorder) ListRegisteredServiceModels added in v0.6.11 

func (mr *MockE2TAdminServiceClientMockRecorder) ListRegisteredServiceModels(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListRegisteredServiceModels indicates an expected call of ListRegisteredServiceModels

func (*MockE2TAdminServiceClientMockRecorder) UploadRegisterServiceModel added in v0.6.11 

func (mr *MockE2TAdminServiceClientMockRecorder) UploadRegisterServiceModel(ctx interface{}, opts ...interface{}) *gomock.Call

UploadRegisterServiceModel indicates an expected call of UploadRegisterServiceModel

type MockE2TAdminServiceServer added in v0.6.11 

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

MockE2TAdminServiceServer is a mock of E2TAdminServiceServer interface

func NewMockE2TAdminServiceServer added in v0.6.11 

func NewMockE2TAdminServiceServer(ctrl *gomock.Controller) *MockE2TAdminServiceServer

NewMockE2TAdminServiceServer creates a new mock instance

func (*MockE2TAdminServiceServer) DropE2NodeConnections added in v0.6.11 

func (m *MockE2TAdminServiceServer) DropE2NodeConnections(arg0 context.Context, arg1 *DropE2NodeConnectionsRequest) (*DropE2NodeConnectionsResponse, error)

DropE2NodeConnections mocks base method

func (*MockE2TAdminServiceServer) EXPECT added in v0.6.11 

func (m *MockE2TAdminServiceServer) EXPECT() *MockE2TAdminServiceServerMockRecorder

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

func (*MockE2TAdminServiceServer) ListE2NodeConnections added in v0.6.11 

func (m *MockE2TAdminServiceServer) ListE2NodeConnections(arg0 *ListE2NodeConnectionsRequest, arg1 E2TAdminService_ListE2NodeConnectionsServer) error

ListE2NodeConnections mocks base method

func (*MockE2TAdminServiceServer) ListRegisteredServiceModels added in v0.6.11 

func (m *MockE2TAdminServiceServer) ListRegisteredServiceModels(arg0 *ListRegisteredServiceModelsRequest, arg1 E2TAdminService_ListRegisteredServiceModelsServer) error

ListRegisteredServiceModels mocks base method

func (*MockE2TAdminServiceServer) UploadRegisterServiceModel added in v0.6.11 

func (m *MockE2TAdminServiceServer) UploadRegisterServiceModel(arg0 E2TAdminService_UploadRegisterServiceModelServer) error

UploadRegisterServiceModel mocks base method

type MockE2TAdminServiceServerMockRecorder added in v0.6.11 

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

MockE2TAdminServiceServerMockRecorder is the mock recorder for MockE2TAdminServiceServer

func (*MockE2TAdminServiceServerMockRecorder) DropE2NodeConnections added in v0.6.11 

func (mr *MockE2TAdminServiceServerMockRecorder) DropE2NodeConnections(arg0, arg1 interface{}) *gomock.Call

DropE2NodeConnections indicates an expected call of DropE2NodeConnections

func (*MockE2TAdminServiceServerMockRecorder) ListE2NodeConnections added in v0.6.11 

func (mr *MockE2TAdminServiceServerMockRecorder) ListE2NodeConnections(arg0, arg1 interface{}) *gomock.Call

ListE2NodeConnections indicates an expected call of ListE2NodeConnections

func (*MockE2TAdminServiceServerMockRecorder) ListRegisteredServiceModels added in v0.6.11 

func (mr *MockE2TAdminServiceServerMockRecorder) ListRegisteredServiceModels(arg0, arg1 interface{}) *gomock.Call

ListRegisteredServiceModels indicates an expected call of ListRegisteredServiceModels

func (*MockE2TAdminServiceServerMockRecorder) UploadRegisterServiceModel added in v0.6.11 

func (mr *MockE2TAdminServiceServerMockRecorder) UploadRegisterServiceModel(arg0 interface{}) *gomock.Call

UploadRegisterServiceModel indicates an expected call of UploadRegisterServiceModel

type MockE2TAdminService_ListE2NodeConnectionsClient added in v0.6.11 

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

MockE2TAdminService_ListE2NodeConnectionsClient is a mock of E2TAdminService_ListE2NodeConnectionsClient interface

func NewMockE2TAdminService_ListE2NodeConnectionsClient added in v0.6.11 

func NewMockE2TAdminService_ListE2NodeConnectionsClient(ctrl *gomock.Controller) *MockE2TAdminService_ListE2NodeConnectionsClient

NewMockE2TAdminService_ListE2NodeConnectionsClient creates a new mock instance

func (*MockE2TAdminService_ListE2NodeConnectionsClient) CloseSend added in v0.6.11 

func (m *MockE2TAdminService_ListE2NodeConnectionsClient) CloseSend() error

CloseSend mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsClient) EXPECT added in v0.6.11 

func (m *MockE2TAdminService_ListE2NodeConnectionsClient) EXPECT() *MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder

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

func (*MockE2TAdminService_ListE2NodeConnectionsClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsClient) Recv added in v0.6.11 

func (m *MockE2TAdminService_ListE2NodeConnectionsClient) Recv() (*ListE2NodeConnectionsResponse, error)

Recv mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder added in v0.6.11 

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

MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder is the mock recorder for MockE2TAdminService_ListE2NodeConnectionsClient

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2TAdminService_ListE2NodeConnectionsClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockE2TAdminService_ListE2NodeConnectionsServer added in v0.6.11 

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

MockE2TAdminService_ListE2NodeConnectionsServer is a mock of E2TAdminService_ListE2NodeConnectionsServer interface

func NewMockE2TAdminService_ListE2NodeConnectionsServer added in v0.6.11 

func NewMockE2TAdminService_ListE2NodeConnectionsServer(ctrl *gomock.Controller) *MockE2TAdminService_ListE2NodeConnectionsServer

NewMockE2TAdminService_ListE2NodeConnectionsServer creates a new mock instance

func (*MockE2TAdminService_ListE2NodeConnectionsServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsServer) EXPECT added in v0.6.11 

func (m *MockE2TAdminService_ListE2NodeConnectionsServer) EXPECT() *MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder

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

func (*MockE2TAdminService_ListE2NodeConnectionsServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsServer) Send added in v0.6.11 

func (m *MockE2TAdminService_ListE2NodeConnectionsServer) Send(arg0 *ListE2NodeConnectionsResponse) error

Send mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockE2TAdminService_ListE2NodeConnectionsServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder added in v0.6.11 

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

MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder is the mock recorder for MockE2TAdminService_ListE2NodeConnectionsServer

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockE2TAdminService_ListE2NodeConnectionsServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type MockE2TAdminService_ListRegisteredServiceModelsClient added in v0.6.11 

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

MockE2TAdminService_ListRegisteredServiceModelsClient is a mock of E2TAdminService_ListRegisteredServiceModelsClient interface

func NewMockE2TAdminService_ListRegisteredServiceModelsClient added in v0.6.11 

func NewMockE2TAdminService_ListRegisteredServiceModelsClient(ctrl *gomock.Controller) *MockE2TAdminService_ListRegisteredServiceModelsClient

NewMockE2TAdminService_ListRegisteredServiceModelsClient creates a new mock instance

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) CloseSend added in v0.6.11 

func (m *MockE2TAdminService_ListRegisteredServiceModelsClient) CloseSend() error

CloseSend mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) EXPECT added in v0.6.11 

func (m *MockE2TAdminService_ListRegisteredServiceModelsClient) EXPECT() *MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder

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

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) Recv added in v0.6.11 

func (m *MockE2TAdminService_ListRegisteredServiceModelsClient) Recv() (*ListRegisteredServiceModelsResponse, error)

Recv mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder added in v0.6.11 

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

MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder is the mock recorder for MockE2TAdminService_ListRegisteredServiceModelsClient

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2TAdminService_ListRegisteredServiceModelsClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockE2TAdminService_ListRegisteredServiceModelsServer added in v0.6.11 

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

MockE2TAdminService_ListRegisteredServiceModelsServer is a mock of E2TAdminService_ListRegisteredServiceModelsServer interface

func NewMockE2TAdminService_ListRegisteredServiceModelsServer added in v0.6.11 

func NewMockE2TAdminService_ListRegisteredServiceModelsServer(ctrl *gomock.Controller) *MockE2TAdminService_ListRegisteredServiceModelsServer

NewMockE2TAdminService_ListRegisteredServiceModelsServer creates a new mock instance

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) EXPECT added in v0.6.11 

func (m *MockE2TAdminService_ListRegisteredServiceModelsServer) EXPECT() *MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder

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

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) Send added in v0.6.11 

func (m *MockE2TAdminService_ListRegisteredServiceModelsServer) Send(arg0 *ListRegisteredServiceModelsResponse) error

Send mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockE2TAdminService_ListRegisteredServiceModelsServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder added in v0.6.11 

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

MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder is the mock recorder for MockE2TAdminService_ListRegisteredServiceModelsServer

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockE2TAdminService_ListRegisteredServiceModelsServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type MockE2TAdminService_UploadRegisterServiceModelClient added in v0.6.11 

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

MockE2TAdminService_UploadRegisterServiceModelClient is a mock of E2TAdminService_UploadRegisterServiceModelClient interface

func NewMockE2TAdminService_UploadRegisterServiceModelClient added in v0.6.11 

func NewMockE2TAdminService_UploadRegisterServiceModelClient(ctrl *gomock.Controller) *MockE2TAdminService_UploadRegisterServiceModelClient

NewMockE2TAdminService_UploadRegisterServiceModelClient creates a new mock instance

func (*MockE2TAdminService_UploadRegisterServiceModelClient) CloseAndRecv added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelClient) CloseAndRecv() (*UploadRegisterServiceModelResponse, error)

CloseAndRecv mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) CloseSend added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelClient) CloseSend() error

CloseSend mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) EXPECT added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelClient) EXPECT() *MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder

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

func (*MockE2TAdminService_UploadRegisterServiceModelClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) Send added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelClient) Send(arg0 *UploadRegisterServiceModelRequest) error

Send mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder added in v0.6.11 

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

MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder is the mock recorder for MockE2TAdminService_UploadRegisterServiceModelClient

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) CloseAndRecv added in v0.6.11 

func (mr *MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) CloseAndRecv() *gomock.Call

CloseAndRecv indicates an expected call of CloseAndRecv

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2TAdminService_UploadRegisterServiceModelClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockE2TAdminService_UploadRegisterServiceModelServer added in v0.6.11 

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

MockE2TAdminService_UploadRegisterServiceModelServer is a mock of E2TAdminService_UploadRegisterServiceModelServer interface

func NewMockE2TAdminService_UploadRegisterServiceModelServer added in v0.6.11 

func NewMockE2TAdminService_UploadRegisterServiceModelServer(ctrl *gomock.Controller) *MockE2TAdminService_UploadRegisterServiceModelServer

NewMockE2TAdminService_UploadRegisterServiceModelServer creates a new mock instance

func (*MockE2TAdminService_UploadRegisterServiceModelServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) EXPECT added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelServer) EXPECT() *MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder

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

func (*MockE2TAdminService_UploadRegisterServiceModelServer) Recv added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelServer) Recv() (*UploadRegisterServiceModelRequest, error)

Recv mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) SendAndClose added in v0.6.11 

func (m *MockE2TAdminService_UploadRegisterServiceModelServer) SendAndClose(arg0 *UploadRegisterServiceModelResponse) error

SendAndClose mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockE2TAdminService_UploadRegisterServiceModelServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder added in v0.6.11 

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

MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder is the mock recorder for MockE2TAdminService_UploadRegisterServiceModelServer

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) SendAndClose added in v0.6.11 

func (mr *MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call

SendAndClose indicates an expected call of SendAndClose

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockE2TAdminService_UploadRegisterServiceModelServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type RANFunction added in v0.7.23 

type RANFunction struct {
	Oid           string `protobuf:"bytes,1,opt,name=oid,proto3" json:"oid,omitempty"`
	RanFunctionId string `protobuf:"bytes,2,opt,name=ran_function_id,json=ranFunctionId,proto3" json:"ran_function_id,omitempty"`
	Description   []byte `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
}

func (*RANFunction) Descriptor added in v0.7.23 

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

func (*RANFunction) GetDescription added in v0.7.23 

func (m *RANFunction) GetDescription() []byte

func (*RANFunction) GetOid added in v0.7.23 

func (m *RANFunction) GetOid() string

func (*RANFunction) GetRanFunctionId added in v0.7.23 

func (m *RANFunction) GetRanFunctionId() string

func (*RANFunction) Marshal added in v0.7.23 

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

func (*RANFunction) MarshalTo added in v0.7.23 

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

func (*RANFunction) MarshalToSizedBuffer added in v0.7.23 

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

func (*RANFunction) ProtoMessage added in v0.7.23 

func (*RANFunction) ProtoMessage()

func (*RANFunction) Reset added in v0.7.23 

func (m *RANFunction) Reset()

func (*RANFunction) Size added in v0.7.23 

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

func (*RANFunction) String added in v0.7.23 

func (m *RANFunction) String() string

func (*RANFunction) Unmarshal added in v0.7.23 

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

func (*RANFunction) XXX_DiscardUnknown added in v0.7.23 

func (m *RANFunction) XXX_DiscardUnknown()

func (*RANFunction) XXX_Marshal added in v0.7.23 

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

func (*RANFunction) XXX_Merge added in v0.7.23 

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

func (*RANFunction) XXX_Size added in v0.7.23 

func (m *RANFunction) XXX_Size() int

func (*RANFunction) XXX_Unmarshal added in v0.7.23 

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

type UnimplementedE2TAdminServiceServer 

type UnimplementedE2TAdminServiceServer struct {
}

UnimplementedE2TAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2TAdminServiceServer) DropE2NodeConnections 

func (*UnimplementedE2TAdminServiceServer) DropE2NodeConnections(ctx context.Context, req *DropE2NodeConnectionsRequest) (*DropE2NodeConnectionsResponse, error)

func (*UnimplementedE2TAdminServiceServer) ListE2NodeConnections 

func (*UnimplementedE2TAdminServiceServer) ListE2NodeConnections(req *ListE2NodeConnectionsRequest, srv E2TAdminService_ListE2NodeConnectionsServer) error

func (*UnimplementedE2TAdminServiceServer) ListRegisteredServiceModels 

func (*UnimplementedE2TAdminServiceServer) ListRegisteredServiceModels(req *ListRegisteredServiceModelsRequest, srv E2TAdminService_ListRegisteredServiceModelsServer) error

func (*UnimplementedE2TAdminServiceServer) UploadRegisterServiceModel 

func (*UnimplementedE2TAdminServiceServer) UploadRegisterServiceModel(srv E2TAdminService_UploadRegisterServiceModelServer) error

type UploadRegisterServiceModelRequest 

type UploadRegisterServiceModelRequest struct {
	// so_file is the name being streamed.
	SoFile string `protobuf:"bytes,1,opt,name=so_file,json=soFile,proto3" json:"so_file,omitempty"`
	// content is the bytes content.
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

UploadRegisterServiceModelRequest is for streaming a model plugin file to the server. There is a built in limit in gRPC of 4MB - plugin is usually around 20MB so break in to chunks of approx 1-2MB.

func (*UploadRegisterServiceModelRequest) Descriptor 

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

func (*UploadRegisterServiceModelRequest) GetContent 

func (m *UploadRegisterServiceModelRequest) GetContent() []byte

func (*UploadRegisterServiceModelRequest) GetSoFile 

func (m *UploadRegisterServiceModelRequest) GetSoFile() string

func (*UploadRegisterServiceModelRequest) Marshal 

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

func (*UploadRegisterServiceModelRequest) MarshalTo 

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

func (*UploadRegisterServiceModelRequest) MarshalToSizedBuffer 

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

func (*UploadRegisterServiceModelRequest) ProtoMessage 

func (*UploadRegisterServiceModelRequest) ProtoMessage()

func (*UploadRegisterServiceModelRequest) Reset 

func (m *UploadRegisterServiceModelRequest) Reset()

func (*UploadRegisterServiceModelRequest) Size 

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

func (*UploadRegisterServiceModelRequest) String 

func (m *UploadRegisterServiceModelRequest) String() string

func (*UploadRegisterServiceModelRequest) Unmarshal 

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

func (*UploadRegisterServiceModelRequest) XXX_DiscardUnknown 

func (m *UploadRegisterServiceModelRequest) XXX_DiscardUnknown()

func (*UploadRegisterServiceModelRequest) XXX_Marshal 

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

func (*UploadRegisterServiceModelRequest) XXX_Merge 

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

func (*UploadRegisterServiceModelRequest) XXX_Size 

func (m *UploadRegisterServiceModelRequest) XXX_Size() int

func (*UploadRegisterServiceModelRequest) XXX_Unmarshal 

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

type UploadRegisterServiceModelResponse 

type UploadRegisterServiceModelResponse struct {
	// name is name of the model plugin.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// version is the semantic version of the model plugin.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
}

UploadRegisterServiceModelResponse carries status of model plugin registration.

func (*UploadRegisterServiceModelResponse) Descriptor 

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

func (*UploadRegisterServiceModelResponse) GetName 

func (m *UploadRegisterServiceModelResponse) GetName() string

func (*UploadRegisterServiceModelResponse) GetVersion 

func (m *UploadRegisterServiceModelResponse) GetVersion() string

func (*UploadRegisterServiceModelResponse) Marshal 

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

func (*UploadRegisterServiceModelResponse) MarshalTo 

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

func (*UploadRegisterServiceModelResponse) MarshalToSizedBuffer 

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

func (*UploadRegisterServiceModelResponse) ProtoMessage 

func (*UploadRegisterServiceModelResponse) ProtoMessage()

func (*UploadRegisterServiceModelResponse) Reset 

func (m *UploadRegisterServiceModelResponse) Reset()

func (*UploadRegisterServiceModelResponse) Size 

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

func (*UploadRegisterServiceModelResponse) String 

func (m *UploadRegisterServiceModelResponse) String() string

func (*UploadRegisterServiceModelResponse) Unmarshal 

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

func (*UploadRegisterServiceModelResponse) XXX_DiscardUnknown 

func (m *UploadRegisterServiceModelResponse) XXX_DiscardUnknown()

func (*UploadRegisterServiceModelResponse) XXX_Marshal 

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

func (*UploadRegisterServiceModelResponse) XXX_Merge 

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

func (*UploadRegisterServiceModelResponse) XXX_Size 

func (m *UploadRegisterServiceModelResponse) XXX_Size() int

func (*UploadRegisterServiceModelResponse) XXX_Unmarshal 

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