package admin

import (
	context "context"
	fmt "fmt"
	proto "github.com/gogo/protobuf/proto"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	math "math"
)

var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

const _ = proto.GoGoProtoPackageIsVersion3 

type E2NodeConnectionType int32

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
)

var E2NodeConnectionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "G_NB",
	2: "E_NB",
	3: "ENG_MB",
	4: "NGE_NB",
}

var E2NodeConnectionType_value = map[string]int32{
	"UNKNOWN": 0,
	"G_NB":    1,
	"E_NB":    2,
	"ENG_MB":  3,
	"NGE_NB":  4,
}

func (x E2NodeConnectionType) String() string {
	return proto.EnumName(E2NodeConnectionType_name, int32(x))
}

func (E2NodeConnectionType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{0}
}

type UploadRegisterServiceModelRequest struct {

	SoFile string `protobuf:"bytes,1,opt,name=so_file,json=soFile,proto3" json:"so_file,omitempty"`

	Content              []byte   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UploadRegisterServiceModelRequest) Reset()         { *m = UploadRegisterServiceModelRequest{} }
func (m *UploadRegisterServiceModelRequest) String() string { return proto.CompactTextString(m) }
func (*UploadRegisterServiceModelRequest) ProtoMessage()    {}
func (*UploadRegisterServiceModelRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{0}
}
func (m *UploadRegisterServiceModelRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UploadRegisterServiceModelRequest.Unmarshal(m, b)
}
func (m *UploadRegisterServiceModelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UploadRegisterServiceModelRequest.Marshal(b, m, deterministic)
}
func (m *UploadRegisterServiceModelRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UploadRegisterServiceModelRequest.Merge(m, src)
}
func (m *UploadRegisterServiceModelRequest) XXX_Size() int {
	return xxx_messageInfo_UploadRegisterServiceModelRequest.Size(m)
}
func (m *UploadRegisterServiceModelRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_UploadRegisterServiceModelRequest.DiscardUnknown(m)
}

var xxx_messageInfo_UploadRegisterServiceModelRequest proto.InternalMessageInfo

func (m *UploadRegisterServiceModelRequest) GetSoFile() string {
	if m != nil {
		return m.SoFile
	}
	return ""
}

func (m *UploadRegisterServiceModelRequest) GetContent() []byte {
	if m != nil {
		return m.Content
	}
	return nil
}

type UploadRegisterServiceModelResponse struct {

	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UploadRegisterServiceModelResponse) Reset()         { *m = UploadRegisterServiceModelResponse{} }
func (m *UploadRegisterServiceModelResponse) String() string { return proto.CompactTextString(m) }
func (*UploadRegisterServiceModelResponse) ProtoMessage()    {}
func (*UploadRegisterServiceModelResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{1}
}
func (m *UploadRegisterServiceModelResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UploadRegisterServiceModelResponse.Unmarshal(m, b)
}
func (m *UploadRegisterServiceModelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UploadRegisterServiceModelResponse.Marshal(b, m, deterministic)
}
func (m *UploadRegisterServiceModelResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UploadRegisterServiceModelResponse.Merge(m, src)
}
func (m *UploadRegisterServiceModelResponse) XXX_Size() int {
	return xxx_messageInfo_UploadRegisterServiceModelResponse.Size(m)
}
func (m *UploadRegisterServiceModelResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_UploadRegisterServiceModelResponse.DiscardUnknown(m)
}

var xxx_messageInfo_UploadRegisterServiceModelResponse proto.InternalMessageInfo

func (m *UploadRegisterServiceModelResponse) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *UploadRegisterServiceModelResponse) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

type ListRegisteredServiceModelsResponse struct {

	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListRegisteredServiceModelsResponse) Reset()         { *m = ListRegisteredServiceModelsResponse{} }
func (m *ListRegisteredServiceModelsResponse) String() string { return proto.CompactTextString(m) }
func (*ListRegisteredServiceModelsResponse) ProtoMessage()    {}
func (*ListRegisteredServiceModelsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{2}
}
func (m *ListRegisteredServiceModelsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListRegisteredServiceModelsResponse.Unmarshal(m, b)
}
func (m *ListRegisteredServiceModelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListRegisteredServiceModelsResponse.Marshal(b, m, deterministic)
}
func (m *ListRegisteredServiceModelsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListRegisteredServiceModelsResponse.Merge(m, src)
}
func (m *ListRegisteredServiceModelsResponse) XXX_Size() int {
	return xxx_messageInfo_ListRegisteredServiceModelsResponse.Size(m)
}
func (m *ListRegisteredServiceModelsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListRegisteredServiceModelsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListRegisteredServiceModelsResponse proto.InternalMessageInfo

func (m *ListRegisteredServiceModelsResponse) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *ListRegisteredServiceModelsResponse) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

type ListRegisteredServiceModelsRequest struct {

	ModelName string `protobuf:"bytes,1,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`

	ModelVersion         string   `protobuf:"bytes,2,opt,name=model_version,json=modelVersion,proto3" json:"model_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListRegisteredServiceModelsRequest) Reset()         { *m = ListRegisteredServiceModelsRequest{} }
func (m *ListRegisteredServiceModelsRequest) String() string { return proto.CompactTextString(m) }
func (*ListRegisteredServiceModelsRequest) ProtoMessage()    {}
func (*ListRegisteredServiceModelsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{3}
}
func (m *ListRegisteredServiceModelsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListRegisteredServiceModelsRequest.Unmarshal(m, b)
}
func (m *ListRegisteredServiceModelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListRegisteredServiceModelsRequest.Marshal(b, m, deterministic)
}
func (m *ListRegisteredServiceModelsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListRegisteredServiceModelsRequest.Merge(m, src)
}
func (m *ListRegisteredServiceModelsRequest) XXX_Size() int {
	return xxx_messageInfo_ListRegisteredServiceModelsRequest.Size(m)
}
func (m *ListRegisteredServiceModelsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListRegisteredServiceModelsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListRegisteredServiceModelsRequest proto.InternalMessageInfo

func (m *ListRegisteredServiceModelsRequest) GetModelName() string {
	if m != nil {
		return m.ModelName
	}
	return ""
}

func (m *ListRegisteredServiceModelsRequest) GetModelVersion() string {
	if m != nil {
		return m.ModelVersion
	}
	return ""
}

type ListE2NodeConnectionsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListE2NodeConnectionsRequest) Reset()         { *m = ListE2NodeConnectionsRequest{} }
func (m *ListE2NodeConnectionsRequest) String() string { return proto.CompactTextString(m) }
func (*ListE2NodeConnectionsRequest) ProtoMessage()    {}
func (*ListE2NodeConnectionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{4}
}
func (m *ListE2NodeConnectionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListE2NodeConnectionsRequest.Unmarshal(m, b)
}
func (m *ListE2NodeConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListE2NodeConnectionsRequest.Marshal(b, m, deterministic)
}
func (m *ListE2NodeConnectionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListE2NodeConnectionsRequest.Merge(m, src)
}
func (m *ListE2NodeConnectionsRequest) XXX_Size() int {
	return xxx_messageInfo_ListE2NodeConnectionsRequest.Size(m)
}
func (m *ListE2NodeConnectionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListE2NodeConnectionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListE2NodeConnectionsRequest proto.InternalMessageInfo

type ListE2NodeConnectionsResponse struct {
	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"`
	Id                   string               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	PlmnId               string               `protobuf:"bytes,4,opt,name=plmn_id,json=plmnId,proto3" json:"plmn_id,omitempty"`
	ConnectionType       E2NodeConnectionType `protobuf:"varint,5,opt,name=connection_type,json=connectionType,proto3,enum=e2t.admin.E2NodeConnectionType" json:"connection_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (m *ListE2NodeConnectionsResponse) Reset()         { *m = ListE2NodeConnectionsResponse{} }
func (m *ListE2NodeConnectionsResponse) String() string { return proto.CompactTextString(m) }
func (*ListE2NodeConnectionsResponse) ProtoMessage()    {}
func (*ListE2NodeConnectionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{5}
}
func (m *ListE2NodeConnectionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListE2NodeConnectionsResponse.Unmarshal(m, b)
}
func (m *ListE2NodeConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListE2NodeConnectionsResponse.Marshal(b, m, deterministic)
}
func (m *ListE2NodeConnectionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListE2NodeConnectionsResponse.Merge(m, src)
}
func (m *ListE2NodeConnectionsResponse) XXX_Size() int {
	return xxx_messageInfo_ListE2NodeConnectionsResponse.Size(m)
}
func (m *ListE2NodeConnectionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListE2NodeConnectionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListE2NodeConnectionsResponse proto.InternalMessageInfo

func (m *ListE2NodeConnectionsResponse) GetRemoteIp() []string {
	if m != nil {
		return m.RemoteIp
	}
	return nil
}

func (m *ListE2NodeConnectionsResponse) GetRemotePort() uint32 {
	if m != nil {
		return m.RemotePort
	}
	return 0
}

func (m *ListE2NodeConnectionsResponse) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ListE2NodeConnectionsResponse) GetPlmnId() string {
	if m != nil {
		return m.PlmnId
	}
	return ""
}

func (m *ListE2NodeConnectionsResponse) GetConnectionType() E2NodeConnectionType {
	if m != nil {
		return m.ConnectionType
	}
	return E2NodeConnectionType_UNKNOWN
}

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

func (m *DropE2NodeConnectionsRequest) Reset()         { *m = DropE2NodeConnectionsRequest{} }
func (m *DropE2NodeConnectionsRequest) String() string { return proto.CompactTextString(m) }
func (*DropE2NodeConnectionsRequest) ProtoMessage()    {}
func (*DropE2NodeConnectionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{6}
}
func (m *DropE2NodeConnectionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DropE2NodeConnectionsRequest.Unmarshal(m, b)
}
func (m *DropE2NodeConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DropE2NodeConnectionsRequest.Marshal(b, m, deterministic)
}
func (m *DropE2NodeConnectionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DropE2NodeConnectionsRequest.Merge(m, src)
}
func (m *DropE2NodeConnectionsRequest) XXX_Size() int {
	return xxx_messageInfo_DropE2NodeConnectionsRequest.Size(m)
}
func (m *DropE2NodeConnectionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DropE2NodeConnectionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DropE2NodeConnectionsRequest proto.InternalMessageInfo

func (m *DropE2NodeConnectionsRequest) GetConnections() []*ListE2NodeConnectionsResponse {
	if m != nil {
		return m.Connections
	}
	return nil
}

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

func (m *DropE2NodeConnectionsResponse) Reset()         { *m = DropE2NodeConnectionsResponse{} }
func (m *DropE2NodeConnectionsResponse) String() string { return proto.CompactTextString(m) }
func (*DropE2NodeConnectionsResponse) ProtoMessage()    {}
func (*DropE2NodeConnectionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{7}
}
func (m *DropE2NodeConnectionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DropE2NodeConnectionsResponse.Unmarshal(m, b)
}
func (m *DropE2NodeConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DropE2NodeConnectionsResponse.Marshal(b, m, deterministic)
}
func (m *DropE2NodeConnectionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DropE2NodeConnectionsResponse.Merge(m, src)
}
func (m *DropE2NodeConnectionsResponse) XXX_Size() int {
	return xxx_messageInfo_DropE2NodeConnectionsResponse.Size(m)
}
func (m *DropE2NodeConnectionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DropE2NodeConnectionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DropE2NodeConnectionsResponse proto.InternalMessageInfo

func (m *DropE2NodeConnectionsResponse) GetSuccess() []bool {
	if m != nil {
		return m.Success
	}
	return nil
}

func init() {
	proto.RegisterEnum("e2t.admin.E2NodeConnectionType", E2NodeConnectionType_name, E2NodeConnectionType_value)
	proto.RegisterType((*UploadRegisterServiceModelRequest)(nil), "e2t.admin.UploadRegisterServiceModelRequest")
	proto.RegisterType((*UploadRegisterServiceModelResponse)(nil), "e2t.admin.UploadRegisterServiceModelResponse")
	proto.RegisterType((*ListRegisteredServiceModelsResponse)(nil), "e2t.admin.ListRegisteredServiceModelsResponse")
	proto.RegisterType((*ListRegisteredServiceModelsRequest)(nil), "e2t.admin.ListRegisteredServiceModelsRequest")
	proto.RegisterType((*ListE2NodeConnectionsRequest)(nil), "e2t.admin.ListE2NodeConnectionsRequest")
	proto.RegisterType((*ListE2NodeConnectionsResponse)(nil), "e2t.admin.ListE2NodeConnectionsResponse")
	proto.RegisterType((*DropE2NodeConnectionsRequest)(nil), "e2t.admin.DropE2NodeConnectionsRequest")
	proto.RegisterType((*DropE2NodeConnectionsResponse)(nil), "e2t.admin.DropE2NodeConnectionsResponse")
}

func init() { proto.RegisterFile("api/e2t/admin.proto", fileDescriptor_afe9bc7e3181af1e) }

var fileDescriptor_afe9bc7e3181af1e = []byte{

	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x54, 0x5f, 0x6f, 0xd3, 0x3e,
	0x14, 0xfd, 0xa5, 0xed, 0xaf, 0x6d, 0x6e, 0xd7, 0x3f, 0x32, 0x4c, 0x44, 0xdd, 0xca, 0x4a, 0xf6,
	0x40, 0x84, 0x58, 0x37, 0x85, 0x27, 0x1e, 0x29, 0x94, 0x32, 0x60, 0x19, 0xf2, 0xfe, 0x20, 0xf1,
	0x12, 0x95, 0xe4, 0x02, 0x9e, 0xd2, 0xd8, 0xc4, 0xde, 0xa4, 0x09, 0x89, 0xcf, 0xc8, 0xc7, 0xe0,
	0x63, 0xa0, 0xc4, 0xcd, 0x68, 0xa7, 0x36, 0xab, 0x78, 0xbb, 0xf7, 0xda, 0x3e, 0xc7, 0xe7, 0xde,
	0x63, 0xc3, 0xbd, 0x89, 0x60, 0xfb, 0xe8, 0xaa, 0xfd, 0x49, 0x38, 0x65, 0xf1, 0x40, 0x24, 0x5c,
	0x71, 0x62, 0xa2, 0xab, 0x06, 0x59, 0xc1, 0x3e, 0x87, 0x47, 0x67, 0x22, 0xe2, 0x93, 0x90, 0xe2,
	0x57, 0x26, 0x15, 0x26, 0x27, 0x98, 0x5c, 0xb1, 0x00, 0x8f, 0x78, 0x88, 0x11, 0xc5, 0xef, 0x97,
	0x28, 0x15, 0x79, 0x00, 0x35, 0xc9, 0xfd, 0x2f, 0x2c, 0x42, 0xcb, 0xe8, 0x1b, 0x8e, 0x49, 0xab,
	0x92, 0xbf, 0x66, 0x11, 0x12, 0x0b, 0x6a, 0x01, 0x8f, 0x15, 0xc6, 0xca, 0x2a, 0xf5, 0x0d, 0x67,
	0x83, 0xe6, 0xa9, 0x4d, 0xc1, 0x2e, 0xc2, 0x95, 0x82, 0xc7, 0x12, 0x09, 0x81, 0x4a, 0x3c, 0x99,
	0xe6, 0xa8, 0x59, 0x9c, 0x62, 0x5e, 0x61, 0x22, 0x19, 0x8f, 0x33, 0x4c, 0x93, 0xe6, 0xa9, 0x7d,
	0x02, 0xbb, 0xef, 0x99, 0x54, 0x39, 0x22, 0x86, 0xf3, 0x98, 0xf2, 0x1f, 0x41, 0xbf, 0x81, 0x5d,
	0x08, 0xaa, 0x3b, 0xd0, 0x03, 0x98, 0xa6, 0x05, 0x7f, 0x0e, 0xd9, 0xcc, 0x2a, 0x5e, 0x0a, 0xbf,
	0x0b, 0x4d, 0xbd, 0xbc, 0x48, 0xb2, 0x91, 0x15, 0xcf, 0x67, 0x4c, 0x0f, 0x61, 0x3b, 0x65, 0x1a,
	0xb9, 0x1e, 0x0f, 0xf1, 0x25, 0x8f, 0x63, 0x0c, 0x14, 0xe3, 0x71, 0xce, 0x61, 0xff, 0x32, 0xa0,
	0xb7, 0x62, 0xc3, 0x4c, 0xd9, 0x16, 0x98, 0x09, 0x4e, 0xb9, 0x42, 0x9f, 0x09, 0xcb, 0xe8, 0x97,
	0x1d, 0x93, 0xd6, 0x75, 0xe1, 0x50, 0x90, 0x1d, 0x68, 0xcc, 0x16, 0x05, 0x4f, 0xf4, 0x3c, 0x9a,
	0x14, 0x74, 0xe9, 0x03, 0x4f, 0x14, 0x69, 0x41, 0x89, 0x85, 0x56, 0x39, 0xbb, 0x59, 0x89, 0x85,
	0xe9, 0x54, 0x45, 0x34, 0x8d, 0x7d, 0x16, 0x5a, 0x15, 0x3d, 0xd5, 0x34, 0x3d, 0x0c, 0xc9, 0x1b,
	0x68, 0x07, 0x37, 0xec, 0xbe, 0xba, 0x16, 0x68, 0xfd, 0xdf, 0x37, 0x9c, 0x96, 0xbb, 0x33, 0xb8,
	0x31, 0xce, 0xe0, 0xf6, 0x2d, 0x4f, 0xaf, 0x05, 0xd2, 0x56, 0xb0, 0x90, 0xdb, 0x17, 0xb0, 0xfd,
	0x2a, 0xe1, 0x62, 0x95, 0x64, 0xf2, 0x16, 0x1a, 0x7f, 0x4f, 0xc8, 0x4c, 0x52, 0xc3, 0x75, 0xe6,
	0x58, 0x0a, 0xfb, 0x41, 0xe7, 0x0f, 0xdb, 0xcf, 0xa1, 0xb7, 0x82, 0x6b, 0xd6, 0x3d, 0x0b, 0x6a,
	0xf2, 0x32, 0x08, 0x50, 0x6a, 0xa2, 0x3a, 0xcd, 0xd3, 0x27, 0xc7, 0x70, 0x7f, 0x99, 0x1c, 0xd2,
	0x80, 0xda, 0x99, 0xf7, 0xce, 0x3b, 0xfe, 0xe8, 0x75, 0xfe, 0x23, 0x75, 0xa8, 0x8c, 0x7d, 0x6f,
	0xd8, 0x31, 0xd2, 0x68, 0x94, 0x46, 0x25, 0x02, 0x50, 0x1d, 0x79, 0x63, 0xff, 0x68, 0xd8, 0x29,
	0xa7, 0xb1, 0x37, 0xce, 0xea, 0x15, 0xf7, 0x77, 0x19, 0xda, 0x23, 0xf7, 0xf4, 0x45, 0xaa, 0x61,
	0xe6, 0x27, 0xf2, 0x03, 0xba, 0xab, 0x5f, 0x04, 0x79, 0x3a, 0x27, 0xfa, 0xce, 0x07, 0xd9, 0xdd,
	0x5b, 0x73, 0xb7, 0x56, 0xee, 0x18, 0xe4, 0x27, 0x6c, 0x15, 0xb8, 0x9c, 0xec, 0xdd, 0x6a, 0x79,
	0xf1, 0x6b, 0xe8, 0x0e, 0xd6, 0xdd, 0xae, 0xf9, 0x0f, 0x0c, 0x12, 0xc1, 0xe6, 0xd2, 0x51, 0x92,
	0xc7, 0x77, 0x0f, 0x5b, 0x73, 0xae, 0xed, 0x8a, 0x03, 0x83, 0x5c, 0xc0, 0xe6, 0x52, 0x2b, 0x2c,
	0xb0, 0x15, 0x19, 0x73, 0x81, 0xad, 0xd0, 0x55, 0xc3, 0xf6, 0xa7, 0xe6, 0xc2, 0x17, 0xfb, 0xb9,
	0x9a, 0xfd, 0xb1, 0xcf, 0xfe, 0x04, 0x00, 0x00, 0xff, 0xff, 0x33, 0x43, 0xb1, 0xea, 0x7a, 0x05,
	0x00, 0x00,
}

var _ context.Context
var _ grpc.ClientConn

const _ = grpc.SupportPackageIsVersion4

type E2TAdminServiceClient interface {

	UploadRegisterServiceModel(ctx context.Context, opts ...grpc.CallOption) (E2TAdminService_UploadRegisterServiceModelClient, error)

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

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

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

type e2TAdminServiceClient struct {
	cc *grpc.ClientConn
}

func NewE2TAdminServiceClient(cc *grpc.ClientConn) E2TAdminServiceClient {
	return &e2TAdminServiceClient{cc}
}

func (c *e2TAdminServiceClient) UploadRegisterServiceModel(ctx context.Context, opts ...grpc.CallOption) (E2TAdminService_UploadRegisterServiceModelClient, error) {
	stream, err := c.cc.NewStream(ctx, &_E2TAdminService_serviceDesc.Streams[0], "/e2t.admin.E2TAdminService/UploadRegisterServiceModel", opts...)
	if err != nil {
		return nil, err
	}
	x := &e2TAdminServiceUploadRegisterServiceModelClient{stream}
	return x, nil
}

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

type e2TAdminServiceUploadRegisterServiceModelClient struct {
	grpc.ClientStream
}

func (x *e2TAdminServiceUploadRegisterServiceModelClient) Send(m *UploadRegisterServiceModelRequest) error {
	return x.ClientStream.SendMsg(m)
}

func (x *e2TAdminServiceUploadRegisterServiceModelClient) CloseAndRecv() (*UploadRegisterServiceModelResponse, error) {
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	m := new(UploadRegisterServiceModelResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *e2TAdminServiceClient) ListRegisteredServiceModels(ctx context.Context, in *ListRegisteredServiceModelsRequest, opts ...grpc.CallOption) (E2TAdminService_ListRegisteredServiceModelsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_E2TAdminService_serviceDesc.Streams[1], "/e2t.admin.E2TAdminService/ListRegisteredServiceModels", opts...)
	if err != nil {
		return nil, err
	}
	x := &e2TAdminServiceListRegisteredServiceModelsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

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

type e2TAdminServiceListRegisteredServiceModelsClient struct {
	grpc.ClientStream
}

func (x *e2TAdminServiceListRegisteredServiceModelsClient) Recv() (*ListRegisteredServiceModelsResponse, error) {
	m := new(ListRegisteredServiceModelsResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *e2TAdminServiceClient) ListE2NodeConnections(ctx context.Context, in *ListE2NodeConnectionsRequest, opts ...grpc.CallOption) (E2TAdminService_ListE2NodeConnectionsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_E2TAdminService_serviceDesc.Streams[2], "/e2t.admin.E2TAdminService/ListE2NodeConnections", opts...)
	if err != nil {
		return nil, err
	}
	x := &e2TAdminServiceListE2NodeConnectionsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

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

type e2TAdminServiceListE2NodeConnectionsClient struct {
	grpc.ClientStream
}

func (x *e2TAdminServiceListE2NodeConnectionsClient) Recv() (*ListE2NodeConnectionsResponse, error) {
	m := new(ListE2NodeConnectionsResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *e2TAdminServiceClient) DropE2NodeConnections(ctx context.Context, in *DropE2NodeConnectionsRequest, opts ...grpc.CallOption) (*DropE2NodeConnectionsResponse, error) {
	out := new(DropE2NodeConnectionsResponse)
	err := c.cc.Invoke(ctx, "/e2t.admin.E2TAdminService/DropE2NodeConnections", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

type E2TAdminServiceServer interface {

	UploadRegisterServiceModel(E2TAdminService_UploadRegisterServiceModelServer) error

	ListRegisteredServiceModels(*ListRegisteredServiceModelsRequest, E2TAdminService_ListRegisteredServiceModelsServer) error

	ListE2NodeConnections(*ListE2NodeConnectionsRequest, E2TAdminService_ListE2NodeConnectionsServer) error

	DropE2NodeConnections(context.Context, *DropE2NodeConnectionsRequest) (*DropE2NodeConnectionsResponse, error)
}

type UnimplementedE2TAdminServiceServer struct {
}

func (*UnimplementedE2TAdminServiceServer) UploadRegisterServiceModel(srv E2TAdminService_UploadRegisterServiceModelServer) error {
	return status.Errorf(codes.Unimplemented, "method UploadRegisterServiceModel not implemented")
}
func (*UnimplementedE2TAdminServiceServer) ListRegisteredServiceModels(req *ListRegisteredServiceModelsRequest, srv E2TAdminService_ListRegisteredServiceModelsServer) error {
	return status.Errorf(codes.Unimplemented, "method ListRegisteredServiceModels not implemented")
}
func (*UnimplementedE2TAdminServiceServer) ListE2NodeConnections(req *ListE2NodeConnectionsRequest, srv E2TAdminService_ListE2NodeConnectionsServer) error {
	return status.Errorf(codes.Unimplemented, "method ListE2NodeConnections not implemented")
}
func (*UnimplementedE2TAdminServiceServer) DropE2NodeConnections(ctx context.Context, req *DropE2NodeConnectionsRequest) (*DropE2NodeConnectionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DropE2NodeConnections not implemented")
}

func RegisterE2TAdminServiceServer(s *grpc.Server, srv E2TAdminServiceServer) {
	s.RegisterService(&_E2TAdminService_serviceDesc, srv)
}

func _E2TAdminService_UploadRegisterServiceModel_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(E2TAdminServiceServer).UploadRegisterServiceModel(&e2TAdminServiceUploadRegisterServiceModelServer{stream})
}

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

type e2TAdminServiceUploadRegisterServiceModelServer struct {
	grpc.ServerStream
}

func (x *e2TAdminServiceUploadRegisterServiceModelServer) SendAndClose(m *UploadRegisterServiceModelResponse) error {
	return x.ServerStream.SendMsg(m)
}

func (x *e2TAdminServiceUploadRegisterServiceModelServer) Recv() (*UploadRegisterServiceModelRequest, error) {
	m := new(UploadRegisterServiceModelRequest)
	if err := x.ServerStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func _E2TAdminService_ListRegisteredServiceModels_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ListRegisteredServiceModelsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(E2TAdminServiceServer).ListRegisteredServiceModels(m, &e2TAdminServiceListRegisteredServiceModelsServer{stream})
}

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

type e2TAdminServiceListRegisteredServiceModelsServer struct {
	grpc.ServerStream
}

func (x *e2TAdminServiceListRegisteredServiceModelsServer) Send(m *ListRegisteredServiceModelsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _E2TAdminService_ListE2NodeConnections_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ListE2NodeConnectionsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(E2TAdminServiceServer).ListE2NodeConnections(m, &e2TAdminServiceListE2NodeConnectionsServer{stream})
}

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

type e2TAdminServiceListE2NodeConnectionsServer struct {
	grpc.ServerStream
}

func (x *e2TAdminServiceListE2NodeConnectionsServer) Send(m *ListE2NodeConnectionsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _E2TAdminService_DropE2NodeConnections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DropE2NodeConnectionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(E2TAdminServiceServer).DropE2NodeConnections(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/e2t.admin.E2TAdminService/DropE2NodeConnections",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(E2TAdminServiceServer).DropE2NodeConnections(ctx, req.(*DropE2NodeConnectionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _E2TAdminService_serviceDesc = grpc.ServiceDesc{
	ServiceName: "e2t.admin.E2TAdminService",
	HandlerType: (*E2TAdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DropE2NodeConnections",
			Handler:    _E2TAdminService_DropE2NodeConnections_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadRegisterServiceModel",
			Handler:       _E2TAdminService_UploadRegisterServiceModel_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ListRegisteredServiceModels",
			Handler:       _E2TAdminService_ListRegisteredServiceModels_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListE2NodeConnections",
			Handler:       _E2TAdminService_ListE2NodeConnections_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/e2t/admin.proto",
}
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: api/e2t/admin.proto

// Package admin defines the administrative gRPC interfaces.

package admin

import (
	context "context"
	fmt "fmt"
	proto "github.com/gogo/protobuf/proto"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package

// E2NodeConnectionType specifies the type of an E2 connection
type E2NodeConnectionType int32

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
)

var E2NodeConnectionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "G_NB",
	2: "E_NB",
	3: "ENG_MB",
	4: "NGE_NB",
}

var E2NodeConnectionType_value = map[string]int32{
	"UNKNOWN": 0,
	"G_NB":    1,
	"E_NB":    2,
	"ENG_MB":  3,
	"NGE_NB":  4,
}

func (x E2NodeConnectionType) String() string {
	return proto.EnumName(E2NodeConnectionType_name, int32(x))
}

func (E2NodeConnectionType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{0}
}

// 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.
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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UploadRegisterServiceModelRequest) Reset()         { *m = UploadRegisterServiceModelRequest{} }
func (m *UploadRegisterServiceModelRequest) String() string { return proto.CompactTextString(m) }
func (*UploadRegisterServiceModelRequest) ProtoMessage()    {}
func (*UploadRegisterServiceModelRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{0}
}
func (m *UploadRegisterServiceModelRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UploadRegisterServiceModelRequest.Unmarshal(m, b)
}
func (m *UploadRegisterServiceModelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UploadRegisterServiceModelRequest.Marshal(b, m, deterministic)
}
func (m *UploadRegisterServiceModelRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UploadRegisterServiceModelRequest.Merge(m, src)
}
func (m *UploadRegisterServiceModelRequest) XXX_Size() int {
	return xxx_messageInfo_UploadRegisterServiceModelRequest.Size(m)
}
func (m *UploadRegisterServiceModelRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_UploadRegisterServiceModelRequest.DiscardUnknown(m)
}

var xxx_messageInfo_UploadRegisterServiceModelRequest proto.InternalMessageInfo

func (m *UploadRegisterServiceModelRequest) GetSoFile() string {
	if m != nil {
		return m.SoFile
	}
	return ""
}

func (m *UploadRegisterServiceModelRequest) GetContent() []byte {
	if m != nil {
		return m.Content
	}
	return nil
}

// UploadRegisterServiceModelResponse carries status of model plugin registration.
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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UploadRegisterServiceModelResponse) Reset()         { *m = UploadRegisterServiceModelResponse{} }
func (m *UploadRegisterServiceModelResponse) String() string { return proto.CompactTextString(m) }
func (*UploadRegisterServiceModelResponse) ProtoMessage()    {}
func (*UploadRegisterServiceModelResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{1}
}
func (m *UploadRegisterServiceModelResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UploadRegisterServiceModelResponse.Unmarshal(m, b)
}
func (m *UploadRegisterServiceModelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UploadRegisterServiceModelResponse.Marshal(b, m, deterministic)
}
func (m *UploadRegisterServiceModelResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UploadRegisterServiceModelResponse.Merge(m, src)
}
func (m *UploadRegisterServiceModelResponse) XXX_Size() int {
	return xxx_messageInfo_UploadRegisterServiceModelResponse.Size(m)
}
func (m *UploadRegisterServiceModelResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_UploadRegisterServiceModelResponse.DiscardUnknown(m)
}

var xxx_messageInfo_UploadRegisterServiceModelResponse proto.InternalMessageInfo

func (m *UploadRegisterServiceModelResponse) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *UploadRegisterServiceModelResponse) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

// ListRegisteredServiceModelsResponse is general information about a service model plugin.
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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListRegisteredServiceModelsResponse) Reset()         { *m = ListRegisteredServiceModelsResponse{} }
func (m *ListRegisteredServiceModelsResponse) String() string { return proto.CompactTextString(m) }
func (*ListRegisteredServiceModelsResponse) ProtoMessage()    {}
func (*ListRegisteredServiceModelsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{2}
}
func (m *ListRegisteredServiceModelsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListRegisteredServiceModelsResponse.Unmarshal(m, b)
}
func (m *ListRegisteredServiceModelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListRegisteredServiceModelsResponse.Marshal(b, m, deterministic)
}
func (m *ListRegisteredServiceModelsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListRegisteredServiceModelsResponse.Merge(m, src)
}
func (m *ListRegisteredServiceModelsResponse) XXX_Size() int {
	return xxx_messageInfo_ListRegisteredServiceModelsResponse.Size(m)
}
func (m *ListRegisteredServiceModelsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListRegisteredServiceModelsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListRegisteredServiceModelsResponse proto.InternalMessageInfo

func (m *ListRegisteredServiceModelsResponse) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *ListRegisteredServiceModelsResponse) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

// ListRegisteredServiceModelsRequest carries data for querying registered service model plugins.
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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListRegisteredServiceModelsRequest) Reset()         { *m = ListRegisteredServiceModelsRequest{} }
func (m *ListRegisteredServiceModelsRequest) String() string { return proto.CompactTextString(m) }
func (*ListRegisteredServiceModelsRequest) ProtoMessage()    {}
func (*ListRegisteredServiceModelsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{3}
}
func (m *ListRegisteredServiceModelsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListRegisteredServiceModelsRequest.Unmarshal(m, b)
}
func (m *ListRegisteredServiceModelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListRegisteredServiceModelsRequest.Marshal(b, m, deterministic)
}
func (m *ListRegisteredServiceModelsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListRegisteredServiceModelsRequest.Merge(m, src)
}
func (m *ListRegisteredServiceModelsRequest) XXX_Size() int {
	return xxx_messageInfo_ListRegisteredServiceModelsRequest.Size(m)
}
func (m *ListRegisteredServiceModelsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListRegisteredServiceModelsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListRegisteredServiceModelsRequest proto.InternalMessageInfo

func (m *ListRegisteredServiceModelsRequest) GetModelName() string {
	if m != nil {
		return m.ModelName
	}
	return ""
}

func (m *ListRegisteredServiceModelsRequest) GetModelVersion() string {
	if m != nil {
		return m.ModelVersion
	}
	return ""
}

// ListE2NodeConnectionsRequest carries request for a list of E2 node SCTP connections.
type ListE2NodeConnectionsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListE2NodeConnectionsRequest) Reset()         { *m = ListE2NodeConnectionsRequest{} }
func (m *ListE2NodeConnectionsRequest) String() string { return proto.CompactTextString(m) }
func (*ListE2NodeConnectionsRequest) ProtoMessage()    {}
func (*ListE2NodeConnectionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{4}
}
func (m *ListE2NodeConnectionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListE2NodeConnectionsRequest.Unmarshal(m, b)
}
func (m *ListE2NodeConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListE2NodeConnectionsRequest.Marshal(b, m, deterministic)
}
func (m *ListE2NodeConnectionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListE2NodeConnectionsRequest.Merge(m, src)
}
func (m *ListE2NodeConnectionsRequest) XXX_Size() int {
	return xxx_messageInfo_ListE2NodeConnectionsRequest.Size(m)
}
func (m *ListE2NodeConnectionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListE2NodeConnectionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListE2NodeConnectionsRequest proto.InternalMessageInfo

// ListE2NodeConnectionsResponse carries information about the SCTP connection to the remote E2 node.
type ListE2NodeConnectionsResponse struct {
	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"`
	Id                   string               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	PlmnId               string               `protobuf:"bytes,4,opt,name=plmn_id,json=plmnId,proto3" json:"plmn_id,omitempty"`
	ConnectionType       E2NodeConnectionType `protobuf:"varint,5,opt,name=connection_type,json=connectionType,proto3,enum=e2t.admin.E2NodeConnectionType" json:"connection_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (m *ListE2NodeConnectionsResponse) Reset()         { *m = ListE2NodeConnectionsResponse{} }
func (m *ListE2NodeConnectionsResponse) String() string { return proto.CompactTextString(m) }
func (*ListE2NodeConnectionsResponse) ProtoMessage()    {}
func (*ListE2NodeConnectionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{5}
}
func (m *ListE2NodeConnectionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListE2NodeConnectionsResponse.Unmarshal(m, b)
}
func (m *ListE2NodeConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListE2NodeConnectionsResponse.Marshal(b, m, deterministic)
}
func (m *ListE2NodeConnectionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListE2NodeConnectionsResponse.Merge(m, src)
}
func (m *ListE2NodeConnectionsResponse) XXX_Size() int {
	return xxx_messageInfo_ListE2NodeConnectionsResponse.Size(m)
}
func (m *ListE2NodeConnectionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListE2NodeConnectionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListE2NodeConnectionsResponse proto.InternalMessageInfo

func (m *ListE2NodeConnectionsResponse) GetRemoteIp() []string {
	if m != nil {
		return m.RemoteIp
	}
	return nil
}

func (m *ListE2NodeConnectionsResponse) GetRemotePort() uint32 {
	if m != nil {
		return m.RemotePort
	}
	return 0
}

func (m *ListE2NodeConnectionsResponse) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ListE2NodeConnectionsResponse) GetPlmnId() string {
	if m != nil {
		return m.PlmnId
	}
	return ""
}

func (m *ListE2NodeConnectionsResponse) GetConnectionType() E2NodeConnectionType {
	if m != nil {
		return m.ConnectionType
	}
	return E2NodeConnectionType_UNKNOWN
}

// DropE2NodeConnectionsRequest carries drop connection request
type DropE2NodeConnectionsRequest struct {
	Connections          []*ListE2NodeConnectionsResponse `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (m *DropE2NodeConnectionsRequest) Reset()         { *m = DropE2NodeConnectionsRequest{} }
func (m *DropE2NodeConnectionsRequest) String() string { return proto.CompactTextString(m) }
func (*DropE2NodeConnectionsRequest) ProtoMessage()    {}
func (*DropE2NodeConnectionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{6}
}
func (m *DropE2NodeConnectionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DropE2NodeConnectionsRequest.Unmarshal(m, b)
}
func (m *DropE2NodeConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DropE2NodeConnectionsRequest.Marshal(b, m, deterministic)
}
func (m *DropE2NodeConnectionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DropE2NodeConnectionsRequest.Merge(m, src)
}
func (m *DropE2NodeConnectionsRequest) XXX_Size() int {
	return xxx_messageInfo_DropE2NodeConnectionsRequest.Size(m)
}
func (m *DropE2NodeConnectionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DropE2NodeConnectionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DropE2NodeConnectionsRequest proto.InternalMessageInfo

func (m *DropE2NodeConnectionsRequest) GetConnections() []*ListE2NodeConnectionsResponse {
	if m != nil {
		return m.Connections
	}
	return nil
}

// DropE2NodeConnectionsResponse carries drop connection response
type DropE2NodeConnectionsResponse struct {
	Success              []bool   `protobuf:"varint,1,rep,packed,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DropE2NodeConnectionsResponse) Reset()         { *m = DropE2NodeConnectionsResponse{} }
func (m *DropE2NodeConnectionsResponse) String() string { return proto.CompactTextString(m) }
func (*DropE2NodeConnectionsResponse) ProtoMessage()    {}
func (*DropE2NodeConnectionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_afe9bc7e3181af1e, []int{7}
}
func (m *DropE2NodeConnectionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DropE2NodeConnectionsResponse.Unmarshal(m, b)
}
func (m *DropE2NodeConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DropE2NodeConnectionsResponse.Marshal(b, m, deterministic)
}
func (m *DropE2NodeConnectionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DropE2NodeConnectionsResponse.Merge(m, src)
}
func (m *DropE2NodeConnectionsResponse) XXX_Size() int {
	return xxx_messageInfo_DropE2NodeConnectionsResponse.Size(m)
}
func (m *DropE2NodeConnectionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DropE2NodeConnectionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DropE2NodeConnectionsResponse proto.InternalMessageInfo

func (m *DropE2NodeConnectionsResponse) GetSuccess() []bool {
	if m != nil {
		return m.Success
	}
	return nil
}

func init() {
	proto.RegisterEnum("e2t.admin.E2NodeConnectionType", E2NodeConnectionType_name, E2NodeConnectionType_value)
	proto.RegisterType((*UploadRegisterServiceModelRequest)(nil), "e2t.admin.UploadRegisterServiceModelRequest")
	proto.RegisterType((*UploadRegisterServiceModelResponse)(nil), "e2t.admin.UploadRegisterServiceModelResponse")
	proto.RegisterType((*ListRegisteredServiceModelsResponse)(nil), "e2t.admin.ListRegisteredServiceModelsResponse")
	proto.RegisterType((*ListRegisteredServiceModelsRequest)(nil), "e2t.admin.ListRegisteredServiceModelsRequest")
	proto.RegisterType((*ListE2NodeConnectionsRequest)(nil), "e2t.admin.ListE2NodeConnectionsRequest")
	proto.RegisterType((*ListE2NodeConnectionsResponse)(nil), "e2t.admin.ListE2NodeConnectionsResponse")
	proto.RegisterType((*DropE2NodeConnectionsRequest)(nil), "e2t.admin.DropE2NodeConnectionsRequest")
	proto.RegisterType((*DropE2NodeConnectionsResponse)(nil), "e2t.admin.DropE2NodeConnectionsResponse")
}

func init() { proto.RegisterFile("api/e2t/admin.proto", fileDescriptor_afe9bc7e3181af1e) }

var fileDescriptor_afe9bc7e3181af1e = []byte{
	// 546 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x54, 0x5f, 0x6f, 0xd3, 0x3e,
	0x14, 0xfd, 0xa5, 0xed, 0xaf, 0x6d, 0x6e, 0xd7, 0x3f, 0x32, 0x4c, 0x44, 0xdd, 0xca, 0x4a, 0xf6,
	0x40, 0x84, 0x58, 0x37, 0x85, 0x27, 0x1e, 0x29, 0x94, 0x32, 0x60, 0x19, 0xf2, 0xfe, 0x20, 0xf1,
	0x12, 0x95, 0xe4, 0x02, 0x9e, 0xd2, 0xd8, 0xc4, 0xde, 0xa4, 0x09, 0x89, 0xcf, 0xc8, 0xc7, 0xe0,
	0x63, 0xa0, 0xc4, 0xcd, 0x68, 0xa7, 0x36, 0xab, 0x78, 0xbb, 0xf7, 0xda, 0x3e, 0xc7, 0xe7, 0xde,
	0x63, 0xc3, 0xbd, 0x89, 0x60, 0xfb, 0xe8, 0xaa, 0xfd, 0x49, 0x38, 0x65, 0xf1, 0x40, 0x24, 0x5c,
	0x71, 0x62, 0xa2, 0xab, 0x06, 0x59, 0xc1, 0x3e, 0x87, 0x47, 0x67, 0x22, 0xe2, 0x93, 0x90, 0xe2,
	0x57, 0x26, 0x15, 0x26, 0x27, 0x98, 0x5c, 0xb1, 0x00, 0x8f, 0x78, 0x88, 0x11, 0xc5, 0xef, 0x97,
	0x28, 0x15, 0x79, 0x00, 0x35, 0xc9, 0xfd, 0x2f, 0x2c, 0x42, 0xcb, 0xe8, 0x1b, 0x8e, 0x49, 0xab,
	0x92, 0xbf, 0x66, 0x11, 0x12, 0x0b, 0x6a, 0x01, 0x8f, 0x15, 0xc6, 0xca, 0x2a, 0xf5, 0x0d, 0x67,
	0x83, 0xe6, 0xa9, 0x4d, 0xc1, 0x2e, 0xc2, 0x95, 0x82, 0xc7, 0x12, 0x09, 0x81, 0x4a, 0x3c, 0x99,
	0xe6, 0xa8, 0x59, 0x9c, 0x62, 0x5e, 0x61, 0x22, 0x19, 0x8f, 0x33, 0x4c, 0x93, 0xe6, 0xa9, 0x7d,
	0x02, 0xbb, 0xef, 0x99, 0x54, 0x39, 0x22, 0x86, 0xf3, 0x98, 0xf2, 0x1f, 0x41, 0xbf, 0x81, 0x5d,
	0x08, 0xaa, 0x3b, 0xd0, 0x03, 0x98, 0xa6, 0x05, 0x7f, 0x0e, 0xd9, 0xcc, 0x2a, 0x5e, 0x0a, 0xbf,
	0x0b, 0x4d, 0xbd, 0xbc, 0x48, 0xb2, 0x91, 0x15, 0xcf, 0x67, 0x4c, 0x0f, 0x61, 0x3b, 0x65, 0x1a,
	0xb9, 0x1e, 0x0f, 0xf1, 0x25, 0x8f, 0x63, 0x0c, 0x14, 0xe3, 0x71, 0xce, 0x61, 0xff, 0x32, 0xa0,
	0xb7, 0x62, 0xc3, 0x4c, 0xd9, 0x16, 0x98, 0x09, 0x4e, 0xb9, 0x42, 0x9f, 0x09, 0xcb, 0xe8, 0x97,
	0x1d, 0x93, 0xd6, 0x75, 0xe1, 0x50, 0x90, 0x1d, 0x68, 0xcc, 0x16, 0x05, 0x4f, 0xf4, 0x3c, 0x9a,
	0x14, 0x74, 0xe9, 0x03, 0x4f, 0x14, 0x69, 0x41, 0x89, 0x85, 0x56, 0x39, 0xbb, 0x59, 0x89, 0x85,
	0xe9, 0x54, 0x45, 0x34, 0x8d, 0x7d, 0x16, 0x5a, 0x15, 0x3d, 0xd5, 0x34, 0x3d, 0x0c, 0xc9, 0x1b,
	0x68, 0x07, 0x37, 0xec, 0xbe, 0xba, 0x16, 0x68, 0xfd, 0xdf, 0x37, 0x9c, 0x96, 0xbb, 0x33, 0xb8,
	0x31, 0xce, 0xe0, 0xf6, 0x2d, 0x4f, 0xaf, 0x05, 0xd2, 0x56, 0xb0, 0x90, 0xdb, 0x17, 0xb0, 0xfd,
	0x2a, 0xe1, 0x62, 0x95, 0x64, 0xf2, 0x16, 0x1a, 0x7f, 0x4f, 0xc8, 0x4c, 0x52, 0xc3, 0x75, 0xe6,
	0x58, 0x0a, 0xfb, 0x41, 0xe7, 0x0f, 0xdb, 0xcf, 0xa1, 0xb7, 0x82, 0x6b, 0xd6, 0x3d, 0x0b, 0x6a,
	0xf2, 0x32, 0x08, 0x50, 0x6a, 0xa2, 0x3a, 0xcd, 0xd3, 0x27, 0xc7, 0x70, 0x7f, 0x99, 0x1c, 0xd2,
	0x80, 0xda, 0x99, 0xf7, 0xce, 0x3b, 0xfe, 0xe8, 0x75, 0xfe, 0x23, 0x75, 0xa8, 0x8c, 0x7d, 0x6f,
	0xd8, 0x31, 0xd2, 0x68, 0x94, 0x46, 0x25, 0x02, 0x50, 0x1d, 0x79, 0x63, 0xff, 0x68, 0xd8, 0x29,
	0xa7, 0xb1, 0x37, 0xce, 0xea, 0x15, 0xf7, 0x77, 0x19, 0xda, 0x23, 0xf7, 0xf4, 0x45, 0xaa, 0x61,
	0xe6, 0x27, 0xf2, 0x03, 0xba, 0xab, 0x5f, 0x04, 0x79, 0x3a, 0x27, 0xfa, 0xce, 0x07, 0xd9, 0xdd,
	0x5b, 0x73, 0xb7, 0x56, 0xee, 0x18, 0xe4, 0x27, 0x6c, 0x15, 0xb8, 0x9c, 0xec, 0xdd, 0x6a, 0x79,
	0xf1, 0x6b, 0xe8, 0x0e, 0xd6, 0xdd, 0xae, 0xf9, 0x0f, 0x0c, 0x12, 0xc1, 0xe6, 0xd2, 0x51, 0x92,
	0xc7, 0x77, 0x0f, 0x5b, 0x73, 0xae, 0xed, 0x8a, 0x03, 0x83, 0x5c, 0xc0, 0xe6, 0x52, 0x2b, 0x2c,
	0xb0, 0x15, 0x19, 0x73, 0x81, 0xad, 0xd0, 0x55, 0xc3, 0xf6, 0xa7, 0xe6, 0xc2, 0x17, 0xfb, 0xb9,
	0x9a, 0xfd, 0xb1, 0xcf, 0xfe, 0x04, 0x00, 0x00, 0xff, 0xff, 0x33, 0x43, 0xb1, 0xea, 0x7a, 0x05,
	0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// 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.
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)
}

type e2TAdminServiceClient struct {
	cc *grpc.ClientConn
}

func NewE2TAdminServiceClient(cc *grpc.ClientConn) E2TAdminServiceClient {
	return &e2TAdminServiceClient{cc}
}

func (c *e2TAdminServiceClient) UploadRegisterServiceModel(ctx context.Context, opts ...grpc.CallOption) (E2TAdminService_UploadRegisterServiceModelClient, error) {
	stream, err := c.cc.NewStream(ctx, &_E2TAdminService_serviceDesc.Streams[0], "/e2t.admin.E2TAdminService/UploadRegisterServiceModel", opts...)
	if err != nil {
		return nil, err
	}
	x := &e2TAdminServiceUploadRegisterServiceModelClient{stream}
	return x, nil
}

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

type e2TAdminServiceUploadRegisterServiceModelClient struct {
	grpc.ClientStream
}

func (x *e2TAdminServiceUploadRegisterServiceModelClient) Send(m *UploadRegisterServiceModelRequest) error {
	return x.ClientStream.SendMsg(m)
}

func (x *e2TAdminServiceUploadRegisterServiceModelClient) CloseAndRecv() (*UploadRegisterServiceModelResponse, error) {
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	m := new(UploadRegisterServiceModelResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *e2TAdminServiceClient) ListRegisteredServiceModels(ctx context.Context, in *ListRegisteredServiceModelsRequest, opts ...grpc.CallOption) (E2TAdminService_ListRegisteredServiceModelsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_E2TAdminService_serviceDesc.Streams[1], "/e2t.admin.E2TAdminService/ListRegisteredServiceModels", opts...)
	if err != nil {
		return nil, err
	}
	x := &e2TAdminServiceListRegisteredServiceModelsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

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

type e2TAdminServiceListRegisteredServiceModelsClient struct {
	grpc.ClientStream
}

func (x *e2TAdminServiceListRegisteredServiceModelsClient) Recv() (*ListRegisteredServiceModelsResponse, error) {
	m := new(ListRegisteredServiceModelsResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *e2TAdminServiceClient) ListE2NodeConnections(ctx context.Context, in *ListE2NodeConnectionsRequest, opts ...grpc.CallOption) (E2TAdminService_ListE2NodeConnectionsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_E2TAdminService_serviceDesc.Streams[2], "/e2t.admin.E2TAdminService/ListE2NodeConnections", opts...)
	if err != nil {
		return nil, err
	}
	x := &e2TAdminServiceListE2NodeConnectionsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

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

type e2TAdminServiceListE2NodeConnectionsClient struct {
	grpc.ClientStream
}

func (x *e2TAdminServiceListE2NodeConnectionsClient) Recv() (*ListE2NodeConnectionsResponse, error) {
	m := new(ListE2NodeConnectionsResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *e2TAdminServiceClient) DropE2NodeConnections(ctx context.Context, in *DropE2NodeConnectionsRequest, opts ...grpc.CallOption) (*DropE2NodeConnectionsResponse, error) {
	out := new(DropE2NodeConnectionsResponse)
	err := c.cc.Invoke(ctx, "/e2t.admin.E2TAdminService/DropE2NodeConnections", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// E2TAdminServiceServer is the server API for E2TAdminService service.
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)
}

// UnimplementedE2TAdminServiceServer can be embedded to have forward compatible implementations.
type UnimplementedE2TAdminServiceServer struct {
}

func (*UnimplementedE2TAdminServiceServer) UploadRegisterServiceModel(srv E2TAdminService_UploadRegisterServiceModelServer) error {
	return status.Errorf(codes.Unimplemented, "method UploadRegisterServiceModel not implemented")
}
func (*UnimplementedE2TAdminServiceServer) ListRegisteredServiceModels(req *ListRegisteredServiceModelsRequest, srv E2TAdminService_ListRegisteredServiceModelsServer) error {
	return status.Errorf(codes.Unimplemented, "method ListRegisteredServiceModels not implemented")
}
func (*UnimplementedE2TAdminServiceServer) ListE2NodeConnections(req *ListE2NodeConnectionsRequest, srv E2TAdminService_ListE2NodeConnectionsServer) error {
	return status.Errorf(codes.Unimplemented, "method ListE2NodeConnections not implemented")
}
func (*UnimplementedE2TAdminServiceServer) DropE2NodeConnections(ctx context.Context, req *DropE2NodeConnectionsRequest) (*DropE2NodeConnectionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DropE2NodeConnections not implemented")
}

func RegisterE2TAdminServiceServer(s *grpc.Server, srv E2TAdminServiceServer) {
	s.RegisterService(&_E2TAdminService_serviceDesc, srv)
}

func _E2TAdminService_UploadRegisterServiceModel_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(E2TAdminServiceServer).UploadRegisterServiceModel(&e2TAdminServiceUploadRegisterServiceModelServer{stream})
}

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

type e2TAdminServiceUploadRegisterServiceModelServer struct {
	grpc.ServerStream
}

func (x *e2TAdminServiceUploadRegisterServiceModelServer) SendAndClose(m *UploadRegisterServiceModelResponse) error {
	return x.ServerStream.SendMsg(m)
}

func (x *e2TAdminServiceUploadRegisterServiceModelServer) Recv() (*UploadRegisterServiceModelRequest, error) {
	m := new(UploadRegisterServiceModelRequest)
	if err := x.ServerStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func _E2TAdminService_ListRegisteredServiceModels_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ListRegisteredServiceModelsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(E2TAdminServiceServer).ListRegisteredServiceModels(m, &e2TAdminServiceListRegisteredServiceModelsServer{stream})
}

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

type e2TAdminServiceListRegisteredServiceModelsServer struct {
	grpc.ServerStream
}

func (x *e2TAdminServiceListRegisteredServiceModelsServer) Send(m *ListRegisteredServiceModelsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _E2TAdminService_ListE2NodeConnections_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ListE2NodeConnectionsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(E2TAdminServiceServer).ListE2NodeConnections(m, &e2TAdminServiceListE2NodeConnectionsServer{stream})
}

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

type e2TAdminServiceListE2NodeConnectionsServer struct {
	grpc.ServerStream
}

func (x *e2TAdminServiceListE2NodeConnectionsServer) Send(m *ListE2NodeConnectionsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _E2TAdminService_DropE2NodeConnections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DropE2NodeConnectionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(E2TAdminServiceServer).DropE2NodeConnections(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/e2t.admin.E2TAdminService/DropE2NodeConnections",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(E2TAdminServiceServer).DropE2NodeConnections(ctx, req.(*DropE2NodeConnectionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _E2TAdminService_serviceDesc = grpc.ServiceDesc{
	ServiceName: "e2t.admin.E2TAdminService",
	HandlerType: (*E2TAdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DropE2NodeConnections",
			Handler:    _E2TAdminService_DropE2NodeConnections_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadRegisterServiceModel",
			Handler:       _E2TAdminService_UploadRegisterServiceModel_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ListRegisteredServiceModels",
			Handler:       _E2TAdminService_ListRegisteredServiceModels_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListE2NodeConnections",
			Handler:       _E2TAdminService_ListE2NodeConnections_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/e2t/admin.proto",
}
