milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
milvus/internal/proto/indexnodepb/index_node.pb.go

765 lines
28 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: index_node.proto
package indexnodepb
import (
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
commonpb "github.com/milvus-io/milvus/internal/proto/commonpb"
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.ProtoPackageIsVersion3 // please upgrade the proto package
type CreateJobRequest struct {
ClusterID int64 `protobuf:"varint,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
IndexFilePrefix string `protobuf:"bytes,2,opt,name=index_file_prefix,json=indexFilePrefix,proto3" json:"index_file_prefix,omitempty"`
BuildID int64 `protobuf:"varint,3,opt,name=buildID,proto3" json:"buildID,omitempty"`
DataPaths []string `protobuf:"bytes,4,rep,name=data_paths,json=dataPaths,proto3" json:"data_paths,omitempty"`
IndexVersion int64 `protobuf:"varint,5,opt,name=index_version,json=indexVersion,proto3" json:"index_version,omitempty"`
IndexID int64 `protobuf:"varint,6,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexName string `protobuf:"bytes,7,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
BucketName string `protobuf:"bytes,8,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
StorageAccessKey string `protobuf:"bytes,9,opt,name=storage_access_key,json=storageAccessKey,proto3" json:"storage_access_key,omitempty"`
IndexParams []*commonpb.KeyValuePair `protobuf:"bytes,10,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
TypeParams []*commonpb.KeyValuePair `protobuf:"bytes,11,rep,name=type_params,json=typeParams,proto3" json:"type_params,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CreateJobRequest) Reset() { *m = CreateJobRequest{} }
func (m *CreateJobRequest) String() string { return proto.CompactTextString(m) }
func (*CreateJobRequest) ProtoMessage() {}
func (*CreateJobRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{0}
}
func (m *CreateJobRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateJobRequest.Unmarshal(m, b)
}
func (m *CreateJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateJobRequest.Marshal(b, m, deterministic)
}
func (m *CreateJobRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CreateJobRequest.Merge(m, src)
}
func (m *CreateJobRequest) XXX_Size() int {
return xxx_messageInfo_CreateJobRequest.Size(m)
}
func (m *CreateJobRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CreateJobRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CreateJobRequest proto.InternalMessageInfo
func (m *CreateJobRequest) GetClusterID() int64 {
if m != nil {
return m.ClusterID
}
return 0
}
func (m *CreateJobRequest) GetIndexFilePrefix() string {
if m != nil {
return m.IndexFilePrefix
}
return ""
}
func (m *CreateJobRequest) GetBuildID() int64 {
if m != nil {
return m.BuildID
}
return 0
}
func (m *CreateJobRequest) GetDataPaths() []string {
if m != nil {
return m.DataPaths
}
return nil
}
func (m *CreateJobRequest) GetIndexVersion() int64 {
if m != nil {
return m.IndexVersion
}
return 0
}
func (m *CreateJobRequest) GetIndexID() int64 {
if m != nil {
return m.IndexID
}
return 0
}
func (m *CreateJobRequest) GetIndexName() string {
if m != nil {
return m.IndexName
}
return ""
}
func (m *CreateJobRequest) GetBucketName() string {
if m != nil {
return m.BucketName
}
return ""
}
func (m *CreateJobRequest) GetStorageAccessKey() string {
if m != nil {
return m.StorageAccessKey
}
return ""
}
func (m *CreateJobRequest) GetIndexParams() []*commonpb.KeyValuePair {
if m != nil {
return m.IndexParams
}
return nil
}
func (m *CreateJobRequest) GetTypeParams() []*commonpb.KeyValuePair {
if m != nil {
return m.TypeParams
}
return nil
}
type QueryJobsRequest struct {
ClusterID int64 `protobuf:"varint,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
BuildIDs []int64 `protobuf:"varint,2,rep,packed,name=buildIDs,proto3" json:"buildIDs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *QueryJobsRequest) Reset() { *m = QueryJobsRequest{} }
func (m *QueryJobsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryJobsRequest) ProtoMessage() {}
func (*QueryJobsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{1}
}
func (m *QueryJobsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_QueryJobsRequest.Unmarshal(m, b)
}
func (m *QueryJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_QueryJobsRequest.Marshal(b, m, deterministic)
}
func (m *QueryJobsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryJobsRequest.Merge(m, src)
}
func (m *QueryJobsRequest) XXX_Size() int {
return xxx_messageInfo_QueryJobsRequest.Size(m)
}
func (m *QueryJobsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryJobsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryJobsRequest proto.InternalMessageInfo
func (m *QueryJobsRequest) GetClusterID() int64 {
if m != nil {
return m.ClusterID
}
return 0
}
func (m *QueryJobsRequest) GetBuildIDs() []int64 {
if m != nil {
return m.BuildIDs
}
return nil
}
type IndexInfo struct {
BuildID int64 `protobuf:"varint,1,opt,name=buildID,proto3" json:"buildID,omitempty"`
State commonpb.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
IndexFiles []string `protobuf:"bytes,3,rep,name=index_files,json=indexFiles,proto3" json:"index_files,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *IndexInfo) Reset() { *m = IndexInfo{} }
func (m *IndexInfo) String() string { return proto.CompactTextString(m) }
func (*IndexInfo) ProtoMessage() {}
func (*IndexInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{2}
}
func (m *IndexInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_IndexInfo.Unmarshal(m, b)
}
func (m *IndexInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_IndexInfo.Marshal(b, m, deterministic)
}
func (m *IndexInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_IndexInfo.Merge(m, src)
}
func (m *IndexInfo) XXX_Size() int {
return xxx_messageInfo_IndexInfo.Size(m)
}
func (m *IndexInfo) XXX_DiscardUnknown() {
xxx_messageInfo_IndexInfo.DiscardUnknown(m)
}
var xxx_messageInfo_IndexInfo proto.InternalMessageInfo
func (m *IndexInfo) GetBuildID() int64 {
if m != nil {
return m.BuildID
}
return 0
}
func (m *IndexInfo) GetState() commonpb.IndexState {
if m != nil {
return m.State
}
return commonpb.IndexState_IndexStateNone
}
func (m *IndexInfo) GetIndexFiles() []string {
if m != nil {
return m.IndexFiles
}
return nil
}
type QueryJobsRespond struct {
Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
ClusterID int64 `protobuf:"varint,2,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
IndexInfos []*IndexInfo `protobuf:"bytes,3,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *QueryJobsRespond) Reset() { *m = QueryJobsRespond{} }
func (m *QueryJobsRespond) String() string { return proto.CompactTextString(m) }
func (*QueryJobsRespond) ProtoMessage() {}
func (*QueryJobsRespond) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{3}
}
func (m *QueryJobsRespond) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_QueryJobsRespond.Unmarshal(m, b)
}
func (m *QueryJobsRespond) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_QueryJobsRespond.Marshal(b, m, deterministic)
}
func (m *QueryJobsRespond) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryJobsRespond.Merge(m, src)
}
func (m *QueryJobsRespond) XXX_Size() int {
return xxx_messageInfo_QueryJobsRespond.Size(m)
}
func (m *QueryJobsRespond) XXX_DiscardUnknown() {
xxx_messageInfo_QueryJobsRespond.DiscardUnknown(m)
}
var xxx_messageInfo_QueryJobsRespond proto.InternalMessageInfo
func (m *QueryJobsRespond) GetStatus() *commonpb.Status {
if m != nil {
return m.Status
}
return nil
}
func (m *QueryJobsRespond) GetClusterID() int64 {
if m != nil {
return m.ClusterID
}
return 0
}
func (m *QueryJobsRespond) GetIndexInfos() []*IndexInfo {
if m != nil {
return m.IndexInfos
}
return nil
}
type DropJobsRequest struct {
ClusterID int64 `protobuf:"varint,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
BuildIDs []int64 `protobuf:"varint,2,rep,packed,name=buildIDs,proto3" json:"buildIDs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DropJobsRequest) Reset() { *m = DropJobsRequest{} }
func (m *DropJobsRequest) String() string { return proto.CompactTextString(m) }
func (*DropJobsRequest) ProtoMessage() {}
func (*DropJobsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{4}
}
func (m *DropJobsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DropJobsRequest.Unmarshal(m, b)
}
func (m *DropJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DropJobsRequest.Marshal(b, m, deterministic)
}
func (m *DropJobsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DropJobsRequest.Merge(m, src)
}
func (m *DropJobsRequest) XXX_Size() int {
return xxx_messageInfo_DropJobsRequest.Size(m)
}
func (m *DropJobsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DropJobsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DropJobsRequest proto.InternalMessageInfo
func (m *DropJobsRequest) GetClusterID() int64 {
if m != nil {
return m.ClusterID
}
return 0
}
func (m *DropJobsRequest) GetBuildIDs() []int64 {
if m != nil {
return m.BuildIDs
}
return nil
}
type JobInfo struct {
NumRows int64 `protobuf:"varint,1,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
Dim int64 `protobuf:"varint,2,opt,name=dim,proto3" json:"dim,omitempty"`
StartTime int64 `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
EndTime int64 `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
IndexParams []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
PodID int64 `protobuf:"varint,6,opt,name=podID,proto3" json:"podID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *JobInfo) Reset() { *m = JobInfo{} }
func (m *JobInfo) String() string { return proto.CompactTextString(m) }
func (*JobInfo) ProtoMessage() {}
func (*JobInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{5}
}
func (m *JobInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_JobInfo.Unmarshal(m, b)
}
func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_JobInfo.Marshal(b, m, deterministic)
}
func (m *JobInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_JobInfo.Merge(m, src)
}
func (m *JobInfo) XXX_Size() int {
return xxx_messageInfo_JobInfo.Size(m)
}
func (m *JobInfo) XXX_DiscardUnknown() {
xxx_messageInfo_JobInfo.DiscardUnknown(m)
}
var xxx_messageInfo_JobInfo proto.InternalMessageInfo
func (m *JobInfo) GetNumRows() int64 {
if m != nil {
return m.NumRows
}
return 0
}
func (m *JobInfo) GetDim() int64 {
if m != nil {
return m.Dim
}
return 0
}
func (m *JobInfo) GetStartTime() int64 {
if m != nil {
return m.StartTime
}
return 0
}
func (m *JobInfo) GetEndTime() int64 {
if m != nil {
return m.EndTime
}
return 0
}
func (m *JobInfo) GetIndexParams() []*commonpb.KeyValuePair {
if m != nil {
return m.IndexParams
}
return nil
}
func (m *JobInfo) GetPodID() int64 {
if m != nil {
return m.PodID
}
return 0
}
type GetJobStatsRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetJobStatsRequest) Reset() { *m = GetJobStatsRequest{} }
func (m *GetJobStatsRequest) String() string { return proto.CompactTextString(m) }
func (*GetJobStatsRequest) ProtoMessage() {}
func (*GetJobStatsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{6}
}
func (m *GetJobStatsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetJobStatsRequest.Unmarshal(m, b)
}
func (m *GetJobStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetJobStatsRequest.Marshal(b, m, deterministic)
}
func (m *GetJobStatsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetJobStatsRequest.Merge(m, src)
}
func (m *GetJobStatsRequest) XXX_Size() int {
return xxx_messageInfo_GetJobStatsRequest.Size(m)
}
func (m *GetJobStatsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetJobStatsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetJobStatsRequest proto.InternalMessageInfo
type GetJobStatsRespond struct {
Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
PendingJobs int64 `protobuf:"varint,2,opt,name=pendingJobs,proto3" json:"pendingJobs,omitempty"`
JobInfos []*JobInfo `protobuf:"bytes,3,rep,name=job_infos,json=jobInfos,proto3" json:"job_infos,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetJobStatsRespond) Reset() { *m = GetJobStatsRespond{} }
func (m *GetJobStatsRespond) String() string { return proto.CompactTextString(m) }
func (*GetJobStatsRespond) ProtoMessage() {}
func (*GetJobStatsRespond) Descriptor() ([]byte, []int) {
return fileDescriptor_7c97d3c987a256af, []int{7}
}
func (m *GetJobStatsRespond) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetJobStatsRespond.Unmarshal(m, b)
}
func (m *GetJobStatsRespond) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetJobStatsRespond.Marshal(b, m, deterministic)
}
func (m *GetJobStatsRespond) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetJobStatsRespond.Merge(m, src)
}
func (m *GetJobStatsRespond) XXX_Size() int {
return xxx_messageInfo_GetJobStatsRespond.Size(m)
}
func (m *GetJobStatsRespond) XXX_DiscardUnknown() {
xxx_messageInfo_GetJobStatsRespond.DiscardUnknown(m)
}
var xxx_messageInfo_GetJobStatsRespond proto.InternalMessageInfo
func (m *GetJobStatsRespond) GetStatus() *commonpb.Status {
if m != nil {
return m.Status
}
return nil
}
func (m *GetJobStatsRespond) GetPendingJobs() int64 {
if m != nil {
return m.PendingJobs
}
return 0
}
func (m *GetJobStatsRespond) GetJobInfos() []*JobInfo {
if m != nil {
return m.JobInfos
}
return nil
}
func init() {
proto.RegisterType((*CreateJobRequest)(nil), "milvus.proto.indexnode.CreateJobRequest")
proto.RegisterType((*QueryJobsRequest)(nil), "milvus.proto.indexnode.QueryJobsRequest")
proto.RegisterType((*IndexInfo)(nil), "milvus.proto.indexnode.IndexInfo")
proto.RegisterType((*QueryJobsRespond)(nil), "milvus.proto.indexnode.QueryJobsRespond")
proto.RegisterType((*DropJobsRequest)(nil), "milvus.proto.indexnode.DropJobsRequest")
proto.RegisterType((*JobInfo)(nil), "milvus.proto.indexnode.JobInfo")
proto.RegisterType((*GetJobStatsRequest)(nil), "milvus.proto.indexnode.GetJobStatsRequest")
proto.RegisterType((*GetJobStatsRespond)(nil), "milvus.proto.indexnode.GetJobStatsRespond")
}
func init() { proto.RegisterFile("index_node.proto", fileDescriptor_7c97d3c987a256af) }
var fileDescriptor_7c97d3c987a256af = []byte{
// 719 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x54, 0xc1, 0x6e, 0xdb, 0x46,
0x10, 0xb5, 0x4c, 0xcb, 0x16, 0x87, 0x6e, 0xad, 0x2e, 0x8c, 0x82, 0x55, 0x5b, 0x58, 0x65, 0x0f,
0x15, 0x8c, 0x56, 0x02, 0x64, 0xb4, 0xe8, 0xa1, 0x97, 0xba, 0x42, 0x03, 0xc9, 0x81, 0xa1, 0xd0,
0x86, 0x0f, 0xb9, 0x10, 0x4b, 0x71, 0x24, 0xaf, 0x2d, 0x72, 0x19, 0xee, 0xd2, 0xb6, 0x0e, 0x39,
0xe4, 0x73, 0xf2, 0x2f, 0xfe, 0xa8, 0x60, 0x77, 0x29, 0xda, 0x92, 0xad, 0x44, 0x48, 0x72, 0xdb,
0x79, 0x33, 0xf3, 0x38, 0xfb, 0xde, 0x2c, 0xa1, 0xce, 0x92, 0x08, 0xef, 0x82, 0x84, 0x47, 0xd8,
0x4e, 0x33, 0x2e, 0x39, 0xf9, 0x3e, 0x66, 0xd3, 0x9b, 0x5c, 0x98, 0xa8, 0xad, 0xd3, 0x2a, 0xdb,
0xd8, 0x1d, 0xf1, 0x38, 0xe6, 0x89, 0xc1, 0xbd, 0x7b, 0x0b, 0xea, 0xff, 0x65, 0x48, 0x25, 0x0e,
0x78, 0xe8, 0xe3, 0x9b, 0x1c, 0x85, 0x24, 0x3f, 0x81, 0x3d, 0x9a, 0xe6, 0x42, 0x62, 0xd6, 0xef,
0xb9, 0x95, 0x66, 0xa5, 0x65, 0xf9, 0x0f, 0x00, 0x39, 0x84, 0xef, 0xcc, 0xc7, 0xc6, 0x6c, 0x8a,
0x41, 0x9a, 0xe1, 0x98, 0xdd, 0xb9, 0x9b, 0xcd, 0x4a, 0xcb, 0xf6, 0xf7, 0x74, 0xe2, 0x7f, 0x36,
0xc5, 0xa1, 0x86, 0x89, 0x0b, 0x3b, 0x61, 0xce, 0xa6, 0x51, 0xbf, 0xe7, 0x5a, 0x9a, 0x67, 0x1e,
0x92, 0x9f, 0x01, 0x22, 0x2a, 0x69, 0x90, 0x52, 0x79, 0x29, 0xdc, 0xad, 0xa6, 0xd5, 0xb2, 0x7d,
0x5b, 0x21, 0x43, 0x05, 0x90, 0x5f, 0xe1, 0x1b, 0xf3, 0x91, 0x1b, 0xcc, 0x04, 0xe3, 0x89, 0x5b,
0xd5, 0xed, 0xbb, 0x1a, 0xbc, 0x30, 0x98, 0x62, 0xd7, 0x71, 0xbf, 0xe7, 0x6e, 0x1b, 0xf6, 0x22,
0x54, 0xec, 0x85, 0x20, 0x34, 0x46, 0x77, 0x47, 0x0f, 0x67, 0x6b, 0xe4, 0x94, 0xc6, 0x48, 0x0e,
0xc0, 0x09, 0xf3, 0xd1, 0x35, 0x4a, 0x93, 0xaf, 0xe9, 0x3c, 0x18, 0x48, 0x17, 0xfc, 0x0e, 0x44,
0x48, 0x9e, 0xd1, 0x09, 0x06, 0x74, 0x34, 0x42, 0x21, 0x82, 0x6b, 0x9c, 0xb9, 0xb6, 0xae, 0xab,
0x17, 0x99, 0x7f, 0x75, 0xe2, 0x04, 0x67, 0xa4, 0x07, 0x66, 0xae, 0x20, 0xa5, 0x19, 0x8d, 0x85,
0x0b, 0x4d, 0xab, 0xe5, 0x74, 0x7f, 0x69, 0x2f, 0x38, 0x50, 0xc8, 0x7e, 0x82, 0xb3, 0x0b, 0x3a,
0xcd, 0x71, 0x48, 0x59, 0xe6, 0x3b, 0xba, 0x6d, 0xa8, 0xbb, 0xc8, 0x31, 0x38, 0x72, 0x96, 0xe2,
0x9c, 0xc4, 0x59, 0x97, 0x04, 0x54, 0x97, 0xe1, 0xf0, 0x5e, 0x42, 0xfd, 0x55, 0x8e, 0xd9, 0x6c,
0xc0, 0x43, 0xb1, 0x9e, 0x9b, 0x0d, 0xa8, 0x15, 0x96, 0x08, 0x77, 0xb3, 0x69, 0xb5, 0x2c, 0xbf,
0x8c, 0xbd, 0xb7, 0x60, 0xf7, 0xb5, 0xa0, 0xc9, 0x98, 0x3f, 0xb6, 0xb2, 0xb2, 0x68, 0xe5, 0x9f,
0x50, 0x15, 0x92, 0x4a, 0xd4, 0x4b, 0xf0, 0x6d, 0xf7, 0xe0, 0xd9, 0x91, 0x35, 0xd1, 0x99, 0x2a,
0xf3, 0x4d, 0xb5, 0x32, 0xe1, 0x61, 0x8f, 0x84, 0x6b, 0xe9, 0x15, 0x80, 0x72, 0x83, 0x84, 0xf7,
0xbe, 0xb2, 0x70, 0x1b, 0x91, 0xf2, 0x24, 0x22, 0x47, 0xb0, 0xad, 0xda, 0x73, 0xa1, 0xa7, 0x70,
0xba, 0x3f, 0x3e, 0xfb, 0xb5, 0x33, 0x5d, 0xe2, 0x17, 0xa5, 0x8b, 0x12, 0x6c, 0x2e, 0x4b, 0x70,
0x3c, 0x1f, 0x84, 0x25, 0x63, 0x6e, 0x06, 0x79, 0x22, 0x7c, 0xf9, 0x7e, 0xda, 0xa5, 0x22, 0xc5,
0xac, 0xea, 0x28, 0xbc, 0x13, 0xd8, 0xeb, 0x65, 0x3c, 0xfd, 0x3a, 0xba, 0xdf, 0x57, 0x60, 0x67,
0xc0, 0x43, 0x2d, 0xfb, 0x0f, 0x50, 0x4b, 0xf2, 0x38, 0xc8, 0xf8, 0xad, 0x98, 0xeb, 0x9e, 0xe4,
0xb1, 0xcf, 0x6f, 0x05, 0xa9, 0x83, 0x15, 0xb1, 0xb8, 0xb8, 0x8f, 0x3a, 0xaa, 0xb5, 0x17, 0x92,
0x66, 0x32, 0x90, 0x2c, 0xc6, 0xe2, 0xc5, 0xd9, 0x1a, 0x39, 0x67, 0x31, 0x2a, 0x2e, 0x4c, 0x22,
0x93, 0xdc, 0x32, 0x5c, 0x98, 0x44, 0x3a, 0xb5, 0xbc, 0xc2, 0xd5, 0xcf, 0x5a, 0xe1, 0x7d, 0xa8,
0xa6, 0x3c, 0x2a, 0x9f, 0xa3, 0x09, 0xbc, 0x7d, 0x20, 0x2f, 0x50, 0x0e, 0x78, 0xa8, 0x5c, 0x99,
0xcb, 0xa3, 0xdc, 0x5d, 0x84, 0xbf, 0xc0, 0xdf, 0x26, 0x38, 0x29, 0x26, 0x11, 0x4b, 0x26, 0xca,
0x80, 0x42, 0x91, 0xc7, 0x10, 0xf9, 0x07, 0xec, 0x2b, 0x1e, 0x2e, 0x38, 0x7c, 0xb0, 0xca, 0xe1,
0x42, 0x7a, 0xbf, 0x76, 0x65, 0x0e, 0xa2, 0xfb, 0xce, 0x2a, 0x5e, 0xc2, 0x29, 0x8f, 0x90, 0x9c,
0x83, 0x5d, 0xfe, 0x32, 0x49, 0x6b, 0x15, 0xcb, 0xf2, 0x5f, 0xb5, 0xf1, 0xb1, 0x9b, 0x78, 0x1b,
0x84, 0x82, 0x5d, 0x2e, 0xfb, 0x6a, 0xd6, 0xe5, 0xd7, 0xdd, 0x58, 0xa7, 0x52, 0x2b, 0xeb, 0x6d,
0x10, 0x1f, 0x6a, 0xf3, 0x25, 0x25, 0xbf, 0xad, 0xea, 0x5b, 0x5a, 0xe3, 0x4f, 0x8d, 0x3d, 0x01,
0xe7, 0x91, 0x8b, 0xe4, 0x70, 0x15, 0xed, 0xd3, 0x0d, 0x68, 0xac, 0x57, 0x5b, 0x0c, 0x7f, 0xfc,
0xf7, 0xeb, 0xbf, 0x26, 0x4c, 0x5e, 0xe6, 0xa1, 0x1a, 0xa1, 0x63, 0x3a, 0xff, 0x60, 0xbc, 0x38,
0x75, 0x58, 0x22, 0x31, 0x4b, 0xe8, 0xb4, 0xa3, 0xc9, 0x3a, 0x25, 0x59, 0x1a, 0x86, 0xdb, 0x1a,
0x3a, 0xfa, 0x10, 0x00, 0x00, 0xff, 0xff, 0x1c, 0x62, 0xeb, 0xe7, 0x24, 0x07, 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
// IndexNodeClient is the client API for IndexNode service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type IndexNodeClient interface {
CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
QueryJobs(ctx context.Context, in *QueryJobsRequest, opts ...grpc.CallOption) (*QueryJobsRespond, error)
DropJobs(ctx context.Context, in *DropJobsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
GetJobStats(ctx context.Context, in *GetJobStatsRequest, opts ...grpc.CallOption) (*GetJobStatsRespond, error)
}
type indexNodeClient struct {
cc *grpc.ClientConn
}
func NewIndexNodeClient(cc *grpc.ClientConn) IndexNodeClient {
return &indexNodeClient{cc}
}
func (c *indexNodeClient) CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
out := new(commonpb.Status)
err := c.cc.Invoke(ctx, "/milvus.proto.indexnode.IndexNode/CreateJob", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *indexNodeClient) QueryJobs(ctx context.Context, in *QueryJobsRequest, opts ...grpc.CallOption) (*QueryJobsRespond, error) {
out := new(QueryJobsRespond)
err := c.cc.Invoke(ctx, "/milvus.proto.indexnode.IndexNode/QueryJobs", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *indexNodeClient) DropJobs(ctx context.Context, in *DropJobsRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
out := new(commonpb.Status)
err := c.cc.Invoke(ctx, "/milvus.proto.indexnode.IndexNode/DropJobs", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *indexNodeClient) GetJobStats(ctx context.Context, in *GetJobStatsRequest, opts ...grpc.CallOption) (*GetJobStatsRespond, error) {
out := new(GetJobStatsRespond)
err := c.cc.Invoke(ctx, "/milvus.proto.indexnode.IndexNode/GetJobStats", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// IndexNodeServer is the server API for IndexNode service.
type IndexNodeServer interface {
CreateJob(context.Context, *CreateJobRequest) (*commonpb.Status, error)
QueryJobs(context.Context, *QueryJobsRequest) (*QueryJobsRespond, error)
DropJobs(context.Context, *DropJobsRequest) (*commonpb.Status, error)
GetJobStats(context.Context, *GetJobStatsRequest) (*GetJobStatsRespond, error)
}
// UnimplementedIndexNodeServer can be embedded to have forward compatible implementations.
type UnimplementedIndexNodeServer struct {
}
func (*UnimplementedIndexNodeServer) CreateJob(ctx context.Context, req *CreateJobRequest) (*commonpb.Status, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateJob not implemented")
}
func (*UnimplementedIndexNodeServer) QueryJobs(ctx context.Context, req *QueryJobsRequest) (*QueryJobsRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method QueryJobs not implemented")
}
func (*UnimplementedIndexNodeServer) DropJobs(ctx context.Context, req *DropJobsRequest) (*commonpb.Status, error) {
return nil, status.Errorf(codes.Unimplemented, "method DropJobs not implemented")
}
func (*UnimplementedIndexNodeServer) GetJobStats(ctx context.Context, req *GetJobStatsRequest) (*GetJobStatsRespond, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetJobStats not implemented")
}
func RegisterIndexNodeServer(s *grpc.Server, srv IndexNodeServer) {
s.RegisterService(&_IndexNode_serviceDesc, srv)
}
func _IndexNode_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateJobRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(IndexNodeServer).CreateJob(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/milvus.proto.indexnode.IndexNode/CreateJob",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(IndexNodeServer).CreateJob(ctx, req.(*CreateJobRequest))
}
return interceptor(ctx, in, info, handler)
}
func _IndexNode_QueryJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryJobsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(IndexNodeServer).QueryJobs(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/milvus.proto.indexnode.IndexNode/QueryJobs",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(IndexNodeServer).QueryJobs(ctx, req.(*QueryJobsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _IndexNode_DropJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DropJobsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(IndexNodeServer).DropJobs(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/milvus.proto.indexnode.IndexNode/DropJobs",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(IndexNodeServer).DropJobs(ctx, req.(*DropJobsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _IndexNode_GetJobStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetJobStatsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(IndexNodeServer).GetJobStats(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/milvus.proto.indexnode.IndexNode/GetJobStats",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(IndexNodeServer).GetJobStats(ctx, req.(*GetJobStatsRequest))
}
return interceptor(ctx, in, info, handler)
}
var _IndexNode_serviceDesc = grpc.ServiceDesc{
ServiceName: "milvus.proto.indexnode.IndexNode",
HandlerType: (*IndexNodeServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "CreateJob",
Handler: _IndexNode_CreateJob_Handler,
},
{
MethodName: "QueryJobs",
Handler: _IndexNode_QueryJobs_Handler,
},
{
MethodName: "DropJobs",
Handler: _IndexNode_DropJobs_Handler,
},
{
MethodName: "GetJobStats",
Handler: _IndexNode_GetJobStats_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "index_node.proto",
}
Reference in New Issue View Git Blame Copy Permalink