protobuf

package
v2.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	KillResult_Code_name = map[int32]string{
		0: "SUCCESS",
		1: "FAILED",
		2: "NOT_EXIST",
	}
	KillResult_Code_value = map[string]int32{
		"SUCCESS":   0,
		"FAILED":    1,
		"NOT_EXIST": 2,
	}
)

Enum value maps for KillResult_Code.

View Source 
var (
	Health_Status_name = map[int32]string{
		0: "IDLE",
		1: "BUSY",
		2: "INVALID",
	}
	Health_Status_value = map[string]int32{
		"IDLE":    0,
		"BUSY":    1,
		"INVALID": 2,
	}
)

Enum value maps for Health_Status.

View Source 
var (
	OperatorMachine_Status_name = map[int32]string{
		0: "UNKNOWN_STATUS",
		1: "IDLE",
		2: "RESERVED",
		3: "BUSY",
		4: "DEAD",
	}
	OperatorMachine_Status_value = map[string]int32{
		"UNKNOWN_STATUS": 0,
		"IDLE":           1,
		"RESERVED":       2,
		"BUSY":           3,
		"DEAD":           4,
	}
)

Enum value maps for OperatorMachine_Status.

View Source 
var (
	RevokeBlockResponse_Code_name = map[int32]string{
		0: "SUCCESS",
		1: "FAILED",
		2: "NOT_EXIST",
	}
	RevokeBlockResponse_Code_value = map[string]int32{
		"SUCCESS":   0,
		"FAILED":    1,
		"NOT_EXIST": 2,
	}
)

Enum value maps for RevokeBlockResponse_Code.

View Source 
var (
	UpdateProgressRequest_Category_name = map[int32]string{
		0: "GENERAL",
		1: "INPUT",
		2: "OUTPUT",
		3: "COMPUTATION",
		4: "ERROR",
	}
	UpdateProgressRequest_Category_value = map[string]int32{
		"GENERAL":     0,
		"INPUT":       1,
		"OUTPUT":      2,
		"COMPUTATION": 3,
		"ERROR":       4,
	}
)

Enum value maps for UpdateProgressRequest_Category.

View Source 
var (
	CompleteStageRequest_Code_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "INVALID_PARAM",
		3: "INTERNAL_ERROR",
		4: "KILLED",
	}
	CompleteStageRequest_Code_value = map[string]int32{
		"UNKNOWN":        0,
		"SUCCESS":        1,
		"INVALID_PARAM":  2,
		"INTERNAL_ERROR": 3,
		"KILLED":         4,
	}
)

Enum value maps for CompleteStageRequest_Code.

View Source 
var (
	BlockStatus_State_name = map[int32]string{
		0: "RUNNING",
		1: "SUCCEEDED",
		2: "ERROR",
		3: "CANCELED",
		4: "UNKNOWN",
		5: "INVALID_PARAM_ERROR",
	}
	BlockStatus_State_value = map[string]int32{
		"RUNNING":             0,
		"SUCCEEDED":           1,
		"ERROR":               2,
		"CANCELED":            3,
		"UNKNOWN":             4,
		"INVALID_PARAM_ERROR": 5,
	}
)

Enum value maps for BlockStatus_State.

View Source 
var (
	OnlinePredictResponseItem_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "NOT_FOUND_ANYWHERE",
		2: "PARTIAL",
	}
	OnlinePredictResponseItem_Status_value = map[string]int32{
		"SUCCESS":            0,
		"NOT_FOUND_ANYWHERE": 1,
		"PARTIAL":            2,
	}
)

Enum value maps for OnlinePredictResponseItem_Status.

View Source 
var File_sudo_protobuf_infra_adapter_infra_adapter_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Block 

type Block struct {
	TaskId    uint64            `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // task may contain many stage
	Id        *BlockID          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Operators []*OperatorConfig `protobuf:"bytes,3,rep,name=operators,proto3" json:"operators,omitempty"`
	Priority  uint32            `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"` // Operators ignore this
	// deprecated.
	XDeprecatedPartyUriMap map[string]string `` /* 218-byte string literal not displayed */
	// include resource cfg,visiable to server furnace
	PartyInfos []*PartyInfo `protobuf:"bytes,6,rep,name=party_infos,json=partyInfos,proto3" json:"party_infos,omitempty"`
	TaskName   string       `protobuf:"bytes,13,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"` // task name, used for front end display
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated 

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetId 

func (x *Block) GetId() *BlockID

func (*Block) GetOperators 

func (x *Block) GetOperators() []*OperatorConfig

func (*Block) GetPartyInfos 

func (x *Block) GetPartyInfos() []*PartyInfo

func (*Block) GetPriority 

func (x *Block) GetPriority() uint32

func (*Block) GetTaskId 

func (x *Block) GetTaskId() uint64

func (*Block) GetTaskName 

func (x *Block) GetTaskName() string

func (*Block) GetXDeprecatedPartyUriMap 

func (x *Block) GetXDeprecatedPartyUriMap() map[string]string

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

func (x *Block) ProtoReflect() protoreflect.Message

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

type BlockID 

type BlockID struct {
	StageId       uint64 `protobuf:"varint,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	InnerId       uint64 `protobuf:"varint,2,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"`
	CoordinatorId string `protobuf:"bytes,3,opt,name=coordinator_id,json=coordinatorId,proto3" json:"coordinator_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockID) Descriptor deprecated 

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

Deprecated: Use BlockID.ProtoReflect.Descriptor instead.

func (*BlockID) GetCoordinatorId 

func (x *BlockID) GetCoordinatorId() string

func (*BlockID) GetInnerId 

func (x *BlockID) GetInnerId() uint64

func (*BlockID) GetStageId 

func (x *BlockID) GetStageId() uint64

func (*BlockID) ProtoMessage 

func (*BlockID) ProtoMessage()

func (*BlockID) ProtoReflect 

func (x *BlockID) ProtoReflect() protoreflect.Message

func (*BlockID) Reset 

func (x *BlockID) Reset()

func (*BlockID) String 

func (x *BlockID) String() string

type BlockStatus 

type BlockStatus struct {
	State   BlockStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=sudo.protobuf.infra_adapter.BlockStatus_State" json:"state,omitempty"`
	Message string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockStatus) Descriptor deprecated 

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

Deprecated: Use BlockStatus.ProtoReflect.Descriptor instead.

func (*BlockStatus) GetMessage 

func (x *BlockStatus) GetMessage() string

func (*BlockStatus) GetState 

func (x *BlockStatus) GetState() BlockStatus_State

func (*BlockStatus) ProtoMessage 

func (*BlockStatus) ProtoMessage()

func (*BlockStatus) ProtoReflect 

func (x *BlockStatus) ProtoReflect() protoreflect.Message

func (*BlockStatus) Reset 

func (x *BlockStatus) Reset()

func (*BlockStatus) String 

func (x *BlockStatus) String() string

type BlockStatus_State 

type BlockStatus_State int32
const (
	BlockStatus_RUNNING             BlockStatus_State = 0
	BlockStatus_SUCCEEDED           BlockStatus_State = 1
	BlockStatus_ERROR               BlockStatus_State = 2
	BlockStatus_CANCELED            BlockStatus_State = 3
	BlockStatus_UNKNOWN             BlockStatus_State = 4
	BlockStatus_INVALID_PARAM_ERROR BlockStatus_State = 5
)

func (BlockStatus_State) Descriptor 

func (BlockStatus_State) Descriptor() protoreflect.EnumDescriptor

func (BlockStatus_State) Enum 

func (x BlockStatus_State) Enum() *BlockStatus_State

func (BlockStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use BlockStatus_State.Descriptor instead.

func (BlockStatus_State) Number 

func (x BlockStatus_State) Number() protoreflect.EnumNumber

func (BlockStatus_State) String 

func (x BlockStatus_State) String() string

func (BlockStatus_State) Type 

func (BlockStatus_State) Type() protoreflect.EnumType

type Chunk 

type Chunk struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk) Descriptor deprecated 

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetChunk 

func (x *Chunk) GetChunk() []byte

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

func (x *Chunk) ProtoReflect() protoreflect.Message

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type CompleteSlaveStageRequest 

type CompleteSlaveStageRequest struct {
	ChildStageId uint64 `protobuf:"varint,1,opt,name=child_stage_id,json=childStageId,proto3" json:"child_stage_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteSlaveStageRequest) Descriptor deprecated 

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

Deprecated: Use CompleteSlaveStageRequest.ProtoReflect.Descriptor instead.

func (*CompleteSlaveStageRequest) GetChildStageId 

func (x *CompleteSlaveStageRequest) GetChildStageId() uint64

func (*CompleteSlaveStageRequest) ProtoMessage 

func (*CompleteSlaveStageRequest) ProtoMessage()

func (*CompleteSlaveStageRequest) ProtoReflect 

func (x *CompleteSlaveStageRequest) ProtoReflect() protoreflect.Message

func (*CompleteSlaveStageRequest) Reset 

func (x *CompleteSlaveStageRequest) Reset()

func (*CompleteSlaveStageRequest) String 

func (x *CompleteSlaveStageRequest) String() string

type CompleteStageRequest 

type CompleteStageRequest struct {
	Id      *BlockID                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Code    CompleteStageRequest_Code `protobuf:"varint,2,opt,name=code,proto3,enum=sudo.protobuf.infra_adapter.CompleteStageRequest_Code" json:"code,omitempty"`
	Message string                    `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteStageRequest) Descriptor deprecated 

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

Deprecated: Use CompleteStageRequest.ProtoReflect.Descriptor instead.

func (*CompleteStageRequest) GetCode 

func (x *CompleteStageRequest) GetCode() CompleteStageRequest_Code

func (*CompleteStageRequest) GetId 

func (x *CompleteStageRequest) GetId() *BlockID

func (*CompleteStageRequest) GetMessage 

func (x *CompleteStageRequest) GetMessage() string

func (*CompleteStageRequest) ProtoMessage 

func (*CompleteStageRequest) ProtoMessage()

func (*CompleteStageRequest) ProtoReflect 

func (x *CompleteStageRequest) ProtoReflect() protoreflect.Message

func (*CompleteStageRequest) Reset 

func (x *CompleteStageRequest) Reset()

func (*CompleteStageRequest) String 

func (x *CompleteStageRequest) String() string

type CompleteStageRequest_Code 

type CompleteStageRequest_Code int32
const (
	CompleteStageRequest_UNKNOWN        CompleteStageRequest_Code = 0
	CompleteStageRequest_SUCCESS        CompleteStageRequest_Code = 1
	CompleteStageRequest_INVALID_PARAM  CompleteStageRequest_Code = 2
	CompleteStageRequest_INTERNAL_ERROR CompleteStageRequest_Code = 3
	CompleteStageRequest_KILLED         CompleteStageRequest_Code = 4
)

func (CompleteStageRequest_Code) Descriptor 

func (CompleteStageRequest_Code) Descriptor() protoreflect.EnumDescriptor

func (CompleteStageRequest_Code) Enum 

func (x CompleteStageRequest_Code) Enum() *CompleteStageRequest_Code

func (CompleteStageRequest_Code) EnumDescriptor deprecated 

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

Deprecated: Use CompleteStageRequest_Code.Descriptor instead.

func (CompleteStageRequest_Code) Number 

func (x CompleteStageRequest_Code) Number() protoreflect.EnumNumber

func (CompleteStageRequest_Code) String 

func (x CompleteStageRequest_Code) String() string

func (CompleteStageRequest_Code) Type 

func (CompleteStageRequest_Code) Type() protoreflect.EnumType

type CreateBlockRequest 

type CreateBlockRequest struct {
	Block           *Block           `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	ProjectId       uint64           `protobuf:"varint,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`           // this block is created by which project
	OwnerPartyId    string           `protobuf:"bytes,3,opt,name=owner_party_id,json=ownerPartyId,proto3" json:"owner_party_id,omitempty"` // this block is created by which party
	OwnerUserId     uint64           `protobuf:"varint,4,opt,name=owner_user_id,json=ownerUserId,proto3" json:"owner_user_id,omitempty"`   // this block is created by which user
	OriginStageType enums.Stage_Type ``                                                                                                    // stage type before DSL
	/* 145-byte string literal not displayed */
	JobType     enums.Job_Type `protobuf:"varint,7,opt,name=job_type,json=jobType,proto3,enum=sudo.protobuf.enums.Job_Type" json:"job_type,omitempty"` // type of the job, such as model fit or predict
	ProjectName string         `protobuf:"bytes,8,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`                        // project name, used for front end display
	// contains filtered or unexported fields
}

CreateBlockRequest is a simple wrapper for block. its created when tusita calls furnace. it stores important information to furnace, but useless to operator

func (*CreateBlockRequest) Descriptor deprecated 

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

Deprecated: Use CreateBlockRequest.ProtoReflect.Descriptor instead.

func (*CreateBlockRequest) GetBlock 

func (x *CreateBlockRequest) GetBlock() *Block

func (*CreateBlockRequest) GetJobType 

func (x *CreateBlockRequest) GetJobType() enums.Job_Type

func (*CreateBlockRequest) GetOriginStageType 

func (x *CreateBlockRequest) GetOriginStageType() enums.Stage_Type

func (*CreateBlockRequest) GetOwnerPartyId 

func (x *CreateBlockRequest) GetOwnerPartyId() string

func (*CreateBlockRequest) GetOwnerUserId 

func (x *CreateBlockRequest) GetOwnerUserId() uint64

func (*CreateBlockRequest) GetProjectId 

func (x *CreateBlockRequest) GetProjectId() uint64

func (*CreateBlockRequest) GetProjectName 

func (x *CreateBlockRequest) GetProjectName() string

func (*CreateBlockRequest) ProtoMessage 

func (*CreateBlockRequest) ProtoMessage()

func (*CreateBlockRequest) ProtoReflect 

func (x *CreateBlockRequest) ProtoReflect() protoreflect.Message

func (*CreateBlockRequest) Reset 

func (x *CreateBlockRequest) Reset()

func (*CreateBlockRequest) String 

func (x *CreateBlockRequest) String() string

type DescFileNodeRequest 

type DescFileNodeRequest struct {

	// Deprecated: use file instead
	//
	// Deprecated: Do not use.
	DatasourceName string `protobuf:"bytes,1,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	// Deprecated: use file instead
	//
	// Deprecated: Do not use.
	Filepath string `protobuf:"bytes,2,opt,name=filepath,proto3" json:"filepath,omitempty"`
	// 对象文件的具体信息
	File *infra_adapter.DataLocation_File `protobuf:"bytes,4,opt,name=file,proto3" json:"file,omitempty"`
	// it could be extremely slow for large file, false by default
	NeedRowCount bool `protobuf:"varint,3,opt,name=need_row_count,json=needRowCount,proto3" json:"need_row_count,omitempty"`
	// contains filtered or unexported fields
}

func (*DescFileNodeRequest) Descriptor deprecated 

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

Deprecated: Use DescFileNodeRequest.ProtoReflect.Descriptor instead.

func (*DescFileNodeRequest) GetDatasourceName deprecated 

func (x *DescFileNodeRequest) GetDatasourceName() string

Deprecated: Do not use.

func (*DescFileNodeRequest) GetFile 

func (x *DescFileNodeRequest) GetFile() *infra_adapter.DataLocation_File

func (*DescFileNodeRequest) GetFilepath deprecated 

func (x *DescFileNodeRequest) GetFilepath() string

Deprecated: Do not use.

func (*DescFileNodeRequest) GetNeedRowCount 

func (x *DescFileNodeRequest) GetNeedRowCount() bool

func (*DescFileNodeRequest) ProtoMessage 

func (*DescFileNodeRequest) ProtoMessage()

func (*DescFileNodeRequest) ProtoReflect 

func (x *DescFileNodeRequest) ProtoReflect() protoreflect.Message

func (*DescFileNodeRequest) Reset 

func (x *DescFileNodeRequest) Reset()

func (*DescFileNodeRequest) String 

func (x *DescFileNodeRequest) String() string

type DescFileNodeResponse 

type DescFileNodeResponse struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// 文件大小，单位为字节。
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// 10位数Unix时间戳
	LastModified uint64 `protobuf:"varint,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	// 文件的第一行
	Headers []string `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	// 只有当请求中`need_row_count`为`true`时才会返回。
	RowCount uint64 `protobuf:"varint,5,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// contains filtered or unexported fields
}

func (*DescFileNodeResponse) Descriptor deprecated 

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

Deprecated: Use DescFileNodeResponse.ProtoReflect.Descriptor instead.

func (*DescFileNodeResponse) GetFilename 

func (x *DescFileNodeResponse) GetFilename() string

func (*DescFileNodeResponse) GetHeaders 

func (x *DescFileNodeResponse) GetHeaders() []string

func (*DescFileNodeResponse) GetLastModified 

func (x *DescFileNodeResponse) GetLastModified() uint64

func (*DescFileNodeResponse) GetRowCount 

func (x *DescFileNodeResponse) GetRowCount() uint64

func (*DescFileNodeResponse) GetSize 

func (x *DescFileNodeResponse) GetSize() uint64

func (*DescFileNodeResponse) ProtoMessage 

func (*DescFileNodeResponse) ProtoMessage()

func (*DescFileNodeResponse) ProtoReflect 

func (x *DescFileNodeResponse) ProtoReflect() protoreflect.Message

func (*DescFileNodeResponse) Reset 

func (x *DescFileNodeResponse) Reset()

func (*DescFileNodeResponse) String 

func (x *DescFileNodeResponse) String() string

type DescTableRequest 

type DescTableRequest struct {
	DatasourceName string                                   `protobuf:"bytes,1,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	Database       string                                   `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Table          string                                   `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	FetchRowCount  bool                                     `protobuf:"varint,4,opt,name=fetch_row_count,json=fetchRowCount,proto3" json:"fetch_row_count,omitempty"`
	Connection     *infra_adapter.DataLocation_DBConnection `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*DescTableRequest) Descriptor deprecated 

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

Deprecated: Use DescTableRequest.ProtoReflect.Descriptor instead.

func (*DescTableRequest) GetConnection 

func (x *DescTableRequest) GetConnection() *infra_adapter.DataLocation_DBConnection

func (*DescTableRequest) GetDatabase 

func (x *DescTableRequest) GetDatabase() string

func (*DescTableRequest) GetDatasourceName 

func (x *DescTableRequest) GetDatasourceName() string

func (*DescTableRequest) GetFetchRowCount 

func (x *DescTableRequest) GetFetchRowCount() bool

func (*DescTableRequest) GetTable 

func (x *DescTableRequest) GetTable() string

func (*DescTableRequest) ProtoMessage 

func (*DescTableRequest) ProtoMessage()

func (*DescTableRequest) ProtoReflect 

func (x *DescTableRequest) ProtoReflect() protoreflect.Message

func (*DescTableRequest) Reset 

func (x *DescTableRequest) Reset()

func (*DescTableRequest) String 

func (x *DescTableRequest) String() string

type DescTableResponse 

type DescTableResponse struct {
	Fields []*DescTableResponse_TableFieldMetaInfo `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// row sample
	Samples  []string `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	RowCount uint64   `protobuf:"varint,3,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// contains filtered or unexported fields
}

func (*DescTableResponse) Descriptor deprecated 

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

Deprecated: Use DescTableResponse.ProtoReflect.Descriptor instead.

func (*DescTableResponse) GetFields 

func (x *DescTableResponse) GetFields() []*DescTableResponse_TableFieldMetaInfo

func (*DescTableResponse) GetRowCount 

func (x *DescTableResponse) GetRowCount() uint64

func (*DescTableResponse) GetSamples 

func (x *DescTableResponse) GetSamples() []string

func (*DescTableResponse) ProtoMessage 

func (*DescTableResponse) ProtoMessage()

func (*DescTableResponse) ProtoReflect 

func (x *DescTableResponse) ProtoReflect() protoreflect.Message

func (*DescTableResponse) Reset 

func (x *DescTableResponse) Reset()

func (*DescTableResponse) String 

func (x *DescTableResponse) String() string

type DescTableResponse_TableFieldMetaInfo 

type DescTableResponse_TableFieldMetaInfo struct {
	Field    string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Type     string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Nullable bool   `protobuf:"varint,3,opt,name=nullable,proto3" json:"nullable,omitempty"`
	IsKey    bool   `protobuf:"varint,4,opt,name=is_key,json=isKey,proto3" json:"is_key,omitempty"`
	IsIndex  bool   `protobuf:"varint,5,opt,name=is_index,json=isIndex,proto3" json:"is_index,omitempty"`
	// contains filtered or unexported fields
}

func (*DescTableResponse_TableFieldMetaInfo) Descriptor deprecated 

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

Deprecated: Use DescTableResponse_TableFieldMetaInfo.ProtoReflect.Descriptor instead.

func (*DescTableResponse_TableFieldMetaInfo) GetField 

func (x *DescTableResponse_TableFieldMetaInfo) GetField() string

func (*DescTableResponse_TableFieldMetaInfo) GetIsIndex 

func (x *DescTableResponse_TableFieldMetaInfo) GetIsIndex() bool

func (*DescTableResponse_TableFieldMetaInfo) GetIsKey 

func (x *DescTableResponse_TableFieldMetaInfo) GetIsKey() bool

func (*DescTableResponse_TableFieldMetaInfo) GetNullable 

func (x *DescTableResponse_TableFieldMetaInfo) GetNullable() bool

func (*DescTableResponse_TableFieldMetaInfo) GetType 

func (x *DescTableResponse_TableFieldMetaInfo) GetType() string

func (*DescTableResponse_TableFieldMetaInfo) ProtoMessage 

func (*DescTableResponse_TableFieldMetaInfo) ProtoMessage()

func (*DescTableResponse_TableFieldMetaInfo) ProtoReflect 

func (x *DescTableResponse_TableFieldMetaInfo) ProtoReflect() protoreflect.Message

func (*DescTableResponse_TableFieldMetaInfo) Reset 

func (x *DescTableResponse_TableFieldMetaInfo) Reset()

func (*DescTableResponse_TableFieldMetaInfo) String 

func (x *DescTableResponse_TableFieldMetaInfo) String() string

type GetBlockStatusRequest 

type GetBlockStatusRequest struct {
	Id *BlockID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetBlockStatusRequest.ProtoReflect.Descriptor instead.

func (*GetBlockStatusRequest) GetId 

func (x *GetBlockStatusRequest) GetId() *BlockID

func (*GetBlockStatusRequest) ProtoMessage 

func (*GetBlockStatusRequest) ProtoMessage()

func (*GetBlockStatusRequest) ProtoReflect 

func (x *GetBlockStatusRequest) ProtoReflect() protoreflect.Message

func (*GetBlockStatusRequest) Reset 

func (x *GetBlockStatusRequest) Reset()

func (*GetBlockStatusRequest) String 

func (x *GetBlockStatusRequest) String() string

type GetBlockStatusResponse 

type GetBlockStatusResponse struct {
	Status *BlockStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetBlockStatusResponse.ProtoReflect.Descriptor instead.

func (*GetBlockStatusResponse) GetStatus 

func (x *GetBlockStatusResponse) GetStatus() *BlockStatus

func (*GetBlockStatusResponse) ProtoMessage 

func (*GetBlockStatusResponse) ProtoMessage()

func (*GetBlockStatusResponse) ProtoReflect 

func (x *GetBlockStatusResponse) ProtoReflect() protoreflect.Message

func (*GetBlockStatusResponse) Reset 

func (x *GetBlockStatusResponse) Reset()

func (*GetBlockStatusResponse) String 

func (x *GetBlockStatusResponse) String() string

type GetCodeVersionRequest 

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

func (*GetCodeVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetCodeVersionRequest.ProtoReflect.Descriptor instead.

func (*GetCodeVersionRequest) ProtoMessage 

func (*GetCodeVersionRequest) ProtoMessage()

func (*GetCodeVersionRequest) ProtoReflect 

func (x *GetCodeVersionRequest) ProtoReflect() protoreflect.Message

func (*GetCodeVersionRequest) Reset 

func (x *GetCodeVersionRequest) Reset()

func (*GetCodeVersionRequest) String 

func (x *GetCodeVersionRequest) String() string

type GetCodeVersionResponse 

type GetCodeVersionResponse struct {
	VersionDesc string `protobuf:"bytes,1,opt,name=version_desc,json=versionDesc,proto3" json:"version_desc,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCodeVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetCodeVersionResponse.ProtoReflect.Descriptor instead.

func (*GetCodeVersionResponse) GetVersionDesc 

func (x *GetCodeVersionResponse) GetVersionDesc() string

func (*GetCodeVersionResponse) ProtoMessage 

func (*GetCodeVersionResponse) ProtoMessage()

func (*GetCodeVersionResponse) ProtoReflect 

func (x *GetCodeVersionResponse) ProtoReflect() protoreflect.Message

func (*GetCodeVersionResponse) Reset 

func (x *GetCodeVersionResponse) Reset()

func (*GetCodeVersionResponse) String 

func (x *GetCodeVersionResponse) String() string

type GetFurnaceConfigRequest 

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

func (*GetFurnaceConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetFurnaceConfigRequest.ProtoReflect.Descriptor instead.

func (*GetFurnaceConfigRequest) ProtoMessage 

func (*GetFurnaceConfigRequest) ProtoMessage()

func (*GetFurnaceConfigRequest) ProtoReflect 

func (x *GetFurnaceConfigRequest) ProtoReflect() protoreflect.Message

func (*GetFurnaceConfigRequest) Reset 

func (x *GetFurnaceConfigRequest) Reset()

func (*GetFurnaceConfigRequest) String 

func (x *GetFurnaceConfigRequest) String() string

type GetFurnaceConfigResponse 

type GetFurnaceConfigResponse struct {
	Resource *GetFurnaceConfigResponse_Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFurnaceConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetFurnaceConfigResponse.ProtoReflect.Descriptor instead.

func (*GetFurnaceConfigResponse) GetResource 

func (x *GetFurnaceConfigResponse) GetResource() *GetFurnaceConfigResponse_Resource

func (*GetFurnaceConfigResponse) ProtoMessage 

func (*GetFurnaceConfigResponse) ProtoMessage()

func (*GetFurnaceConfigResponse) ProtoReflect 

func (x *GetFurnaceConfigResponse) ProtoReflect() protoreflect.Message

func (*GetFurnaceConfigResponse) Reset 

func (x *GetFurnaceConfigResponse) Reset()

func (*GetFurnaceConfigResponse) String 

func (x *GetFurnaceConfigResponse) String() string

type GetFurnaceConfigResponse_Resource 

type GetFurnaceConfigResponse_Resource struct {
	Mode enums.Resource_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=sudo.protobuf.enums.Resource_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFurnaceConfigResponse_Resource) Descriptor deprecated 

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

Deprecated: Use GetFurnaceConfigResponse_Resource.ProtoReflect.Descriptor instead.

func (*GetFurnaceConfigResponse_Resource) GetMode 

func (x *GetFurnaceConfigResponse_Resource) GetMode() enums.Resource_Mode

func (*GetFurnaceConfigResponse_Resource) ProtoMessage 

func (*GetFurnaceConfigResponse_Resource) ProtoMessage()

func (*GetFurnaceConfigResponse_Resource) ProtoReflect 

func (x *GetFurnaceConfigResponse_Resource) ProtoReflect() protoreflect.Message

func (*GetFurnaceConfigResponse_Resource) Reset 

func (x *GetFurnaceConfigResponse_Resource) Reset()

func (*GetFurnaceConfigResponse_Resource) String 

func (x *GetFurnaceConfigResponse_Resource) String() string

type GetRunningsRequest 

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

func (*GetRunningsRequest) Descriptor deprecated 

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

Deprecated: Use GetRunningsRequest.ProtoReflect.Descriptor instead.

func (*GetRunningsRequest) ProtoMessage 

func (*GetRunningsRequest) ProtoMessage()

func (*GetRunningsRequest) ProtoReflect 

func (x *GetRunningsRequest) ProtoReflect() protoreflect.Message

func (*GetRunningsRequest) Reset 

func (x *GetRunningsRequest) Reset()

func (*GetRunningsRequest) String 

func (x *GetRunningsRequest) String() string

type GetRunningsResponse 

type GetRunningsResponse struct {
	Ids []*BlockID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRunningsResponse) Descriptor deprecated 

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

Deprecated: Use GetRunningsResponse.ProtoReflect.Descriptor instead.

func (*GetRunningsResponse) GetIds 

func (x *GetRunningsResponse) GetIds() []*BlockID

func (*GetRunningsResponse) ProtoMessage 

func (*GetRunningsResponse) ProtoMessage()

func (*GetRunningsResponse) ProtoReflect 

func (x *GetRunningsResponse) ProtoReflect() protoreflect.Message

func (*GetRunningsResponse) Reset 

func (x *GetRunningsResponse) Reset()

func (*GetRunningsResponse) String 

func (x *GetRunningsResponse) String() string

type GetStageConfigRequest 

type GetStageConfigRequest struct {
	Id *BlockID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Furnace service requests & responses

func (*GetStageConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetStageConfigRequest.ProtoReflect.Descriptor instead.

func (*GetStageConfigRequest) GetId 

func (x *GetStageConfigRequest) GetId() *BlockID

func (*GetStageConfigRequest) ProtoMessage 

func (*GetStageConfigRequest) ProtoMessage()

func (*GetStageConfigRequest) ProtoReflect 

func (x *GetStageConfigRequest) ProtoReflect() protoreflect.Message

func (*GetStageConfigRequest) Reset 

func (x *GetStageConfigRequest) Reset()

func (*GetStageConfigRequest) String 

func (x *GetStageConfigRequest) String() string

type GetStageConfigResponse 

type GetStageConfigResponse struct {
	Config *Block `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStageConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetStageConfigResponse.ProtoReflect.Descriptor instead.

func (*GetStageConfigResponse) GetConfig 

func (x *GetStageConfigResponse) GetConfig() *Block

func (*GetStageConfigResponse) ProtoMessage 

func (*GetStageConfigResponse) ProtoMessage()

func (*GetStageConfigResponse) ProtoReflect 

func (x *GetStageConfigResponse) ProtoReflect() protoreflect.Message

func (*GetStageConfigResponse) Reset 

func (x *GetStageConfigResponse) Reset()

func (*GetStageConfigResponse) String 

func (x *GetStageConfigResponse) String() string

type GrpcProxyToPartyRequest 

type GrpcProxyToPartyRequest struct {
	PartyId       string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	CoordinatorId string `protobuf:"bytes,2,opt,name=coordinator_id,json=coordinatorId,proto3" json:"coordinator_id,omitempty"`
	Uri           string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	Method        string `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Payload       []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcProxyToPartyRequest) Descriptor deprecated 

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

Deprecated: Use GrpcProxyToPartyRequest.ProtoReflect.Descriptor instead.

func (*GrpcProxyToPartyRequest) GetCoordinatorId 

func (x *GrpcProxyToPartyRequest) GetCoordinatorId() string

func (*GrpcProxyToPartyRequest) GetMethod 

func (x *GrpcProxyToPartyRequest) GetMethod() string

func (*GrpcProxyToPartyRequest) GetPartyId 

func (x *GrpcProxyToPartyRequest) GetPartyId() string

func (*GrpcProxyToPartyRequest) GetPayload 

func (x *GrpcProxyToPartyRequest) GetPayload() []byte

func (*GrpcProxyToPartyRequest) GetUri 

func (x *GrpcProxyToPartyRequest) GetUri() string

func (*GrpcProxyToPartyRequest) ProtoMessage 

func (*GrpcProxyToPartyRequest) ProtoMessage()

func (*GrpcProxyToPartyRequest) ProtoReflect 

func (x *GrpcProxyToPartyRequest) ProtoReflect() protoreflect.Message

func (*GrpcProxyToPartyRequest) Reset 

func (x *GrpcProxyToPartyRequest) Reset()

func (*GrpcProxyToPartyRequest) String 

func (x *GrpcProxyToPartyRequest) String() string

type GrpcProxyToPartyResponse 

type GrpcProxyToPartyResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcProxyToPartyResponse) Descriptor deprecated 

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

Deprecated: Use GrpcProxyToPartyResponse.ProtoReflect.Descriptor instead.

func (*GrpcProxyToPartyResponse) GetPayload 

func (x *GrpcProxyToPartyResponse) GetPayload() []byte

func (*GrpcProxyToPartyResponse) ProtoMessage 

func (*GrpcProxyToPartyResponse) ProtoMessage()

func (*GrpcProxyToPartyResponse) ProtoReflect 

func (x *GrpcProxyToPartyResponse) ProtoReflect() protoreflect.Message

func (*GrpcProxyToPartyResponse) Reset 

func (x *GrpcProxyToPartyResponse) Reset()

func (*GrpcProxyToPartyResponse) String 

func (x *GrpcProxyToPartyResponse) String() string

type Health 

type Health struct {
	Status Health_Status `protobuf:"varint,1,opt,name=status,proto3,enum=sudo.protobuf.infra_adapter.Health_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Health) Descriptor deprecated 

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

Deprecated: Use Health.ProtoReflect.Descriptor instead.

func (*Health) GetStatus 

func (x *Health) GetStatus() Health_Status

func (*Health) ProtoMessage 

func (*Health) ProtoMessage()

func (*Health) ProtoReflect 

func (x *Health) ProtoReflect() protoreflect.Message

func (*Health) Reset 

func (x *Health) Reset()

func (*Health) String 

func (x *Health) String() string

type Health_Status 

type Health_Status int32
const (
	Health_IDLE    Health_Status = 0
	Health_BUSY    Health_Status = 1
	Health_INVALID Health_Status = 2
)

func (Health_Status) Descriptor 

func (Health_Status) Descriptor() protoreflect.EnumDescriptor

func (Health_Status) Enum 

func (x Health_Status) Enum() *Health_Status

func (Health_Status) EnumDescriptor deprecated 

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

Deprecated: Use Health_Status.Descriptor instead.

func (Health_Status) Number 

func (x Health_Status) Number() protoreflect.EnumNumber

func (Health_Status) String 

func (x Health_Status) String() string

func (Health_Status) Type 

func (Health_Status) Type() protoreflect.EnumType

type KillResult 

type KillResult struct {
	Code KillResult_Code `protobuf:"varint,1,opt,name=code,proto3,enum=sudo.protobuf.infra_adapter.KillResult_Code" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*KillResult) Descriptor deprecated 

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

Deprecated: Use KillResult.ProtoReflect.Descriptor instead.

func (*KillResult) GetCode 

func (x *KillResult) GetCode() KillResult_Code

func (*KillResult) ProtoMessage 

func (*KillResult) ProtoMessage()

func (*KillResult) ProtoReflect 

func (x *KillResult) ProtoReflect() protoreflect.Message

func (*KillResult) Reset 

func (x *KillResult) Reset()

func (*KillResult) String 

func (x *KillResult) String() string

type KillResult_Code 

type KillResult_Code int32
const (
	KillResult_SUCCESS   KillResult_Code = 0
	KillResult_FAILED    KillResult_Code = 1
	KillResult_NOT_EXIST KillResult_Code = 2
)

func (KillResult_Code) Descriptor 

func (KillResult_Code) Descriptor() protoreflect.EnumDescriptor

func (KillResult_Code) Enum 

func (x KillResult_Code) Enum() *KillResult_Code

func (KillResult_Code) EnumDescriptor deprecated 

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

Deprecated: Use KillResult_Code.Descriptor instead.

func (KillResult_Code) Number 

func (x KillResult_Code) Number() protoreflect.EnumNumber

func (KillResult_Code) String 

func (x KillResult_Code) String() string

func (KillResult_Code) Type 

func (KillResult_Code) Type() protoreflect.EnumType

type LaunchBlockRequest 

type LaunchBlockRequest struct {
	Block *Block `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

func (*LaunchBlockRequest) Descriptor deprecated 

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

Deprecated: Use LaunchBlockRequest.ProtoReflect.Descriptor instead.

func (*LaunchBlockRequest) GetBlock 

func (x *LaunchBlockRequest) GetBlock() *Block

func (*LaunchBlockRequest) ProtoMessage 

func (*LaunchBlockRequest) ProtoMessage()

func (*LaunchBlockRequest) ProtoReflect 

func (x *LaunchBlockRequest) ProtoReflect() protoreflect.Message

func (*LaunchBlockRequest) Reset 

func (x *LaunchBlockRequest) Reset()

func (*LaunchBlockRequest) String 

func (x *LaunchBlockRequest) String() string

type LaunchBlockResponse 

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

func (*LaunchBlockResponse) Descriptor deprecated 

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

Deprecated: Use LaunchBlockResponse.ProtoReflect.Descriptor instead.

func (*LaunchBlockResponse) ProtoMessage 

func (*LaunchBlockResponse) ProtoMessage()

func (*LaunchBlockResponse) ProtoReflect 

func (x *LaunchBlockResponse) ProtoReflect() protoreflect.Message

func (*LaunchBlockResponse) Reset 

func (x *LaunchBlockResponse) Reset()

func (*LaunchBlockResponse) String 

func (x *LaunchBlockResponse) String() string

type OnlineBlock 

type OnlineBlock struct {
	ServiceId       uint64                     `protobuf:"varint,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	PartyId         string                     `protobuf:"bytes,2,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"` // 自己这一方的名字
	Operators       []*OnlineOperatorConfig    `protobuf:"bytes,3,rep,name=operators,proto3" json:"operators,omitempty"`
	PartyInfos      []*PartyInfo               `protobuf:"bytes,4,rep,name=party_infos,json=partyInfos,proto3" json:"party_infos,omitempty"` // 所有参与方信息, 第0个是client
	ResultMemoryKey map[string]*OnlineParamKey ``                                                                                            /* 196-byte string literal not displayed */
	EnableProtectId bool                       `protobuf:"varint,6,opt,name=enable_protect_id,json=enableProtectId,proto3" json:"enable_protect_id,omitempty"`
	TripletsBitInfo enums.TripletsBitInfo_Type `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OnlineBlock) Descriptor deprecated 

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

Deprecated: Use OnlineBlock.ProtoReflect.Descriptor instead.

func (*OnlineBlock) GetEnableProtectId 

func (x *OnlineBlock) GetEnableProtectId() bool

func (*OnlineBlock) GetOperators 

func (x *OnlineBlock) GetOperators() []*OnlineOperatorConfig

func (*OnlineBlock) GetPartyId 

func (x *OnlineBlock) GetPartyId() string

func (*OnlineBlock) GetPartyInfos 

func (x *OnlineBlock) GetPartyInfos() []*PartyInfo

func (*OnlineBlock) GetResultMemoryKey 

func (x *OnlineBlock) GetResultMemoryKey() map[string]*OnlineParamKey

func (*OnlineBlock) GetServiceId 

func (x *OnlineBlock) GetServiceId() uint64

func (*OnlineBlock) GetTripletsBitInfo 

func (x *OnlineBlock) GetTripletsBitInfo() enums.TripletsBitInfo_Type

func (*OnlineBlock) ProtoMessage 

func (*OnlineBlock) ProtoMessage()

func (*OnlineBlock) ProtoReflect 

func (x *OnlineBlock) ProtoReflect() protoreflect.Message

func (*OnlineBlock) Reset 

func (x *OnlineBlock) Reset()

func (*OnlineBlock) String 

func (x *OnlineBlock) String() string

type OnlineBlockId 

type OnlineBlockId struct {
	ServiceId uint64 `protobuf:"varint,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineBlockId) Descriptor deprecated 

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

Deprecated: Use OnlineBlockId.ProtoReflect.Descriptor instead.

func (*OnlineBlockId) GetServiceId 

func (x *OnlineBlockId) GetServiceId() uint64

func (*OnlineBlockId) ProtoMessage 

func (*OnlineBlockId) ProtoMessage()

func (*OnlineBlockId) ProtoReflect 

func (x *OnlineBlockId) ProtoReflect() protoreflect.Message

func (*OnlineBlockId) Reset 

func (x *OnlineBlockId) Reset()

func (*OnlineBlockId) String 

func (x *OnlineBlockId) String() string

type OnlineInput 

type OnlineInput struct {

	// Types that are assignable to Location:
	//	*OnlineInput_Table
	//	*OnlineInput_Constants_
	Location isOnlineInput_Location `protobuf_oneof:"location"`
	// contains filtered or unexported fields
}

func (*OnlineInput) Descriptor deprecated 

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

Deprecated: Use OnlineInput.ProtoReflect.Descriptor instead.

func (*OnlineInput) GetConstants 

func (x *OnlineInput) GetConstants() *OnlineInput_Constants

func (*OnlineInput) GetLocation 

func (m *OnlineInput) GetLocation() isOnlineInput_Location

func (*OnlineInput) GetTable 

func (x *OnlineInput) GetTable() *OnlineInput_TableRow

func (*OnlineInput) ProtoMessage 

func (*OnlineInput) ProtoMessage()

func (*OnlineInput) ProtoReflect 

func (x *OnlineInput) ProtoReflect() protoreflect.Message

func (*OnlineInput) Reset 

func (x *OnlineInput) Reset()

func (*OnlineInput) String 

func (x *OnlineInput) String() string

type OnlineInput_Constants 

type OnlineInput_Constants struct {
	Header []string `protobuf:"bytes,1,rep,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

For quick debugging

func (*OnlineInput_Constants) Descriptor deprecated 

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

Deprecated: Use OnlineInput_Constants.ProtoReflect.Descriptor instead.

func (*OnlineInput_Constants) GetHeader 

func (x *OnlineInput_Constants) GetHeader() []string

func (*OnlineInput_Constants) ProtoMessage 

func (*OnlineInput_Constants) ProtoMessage()

func (*OnlineInput_Constants) ProtoReflect 

func (x *OnlineInput_Constants) ProtoReflect() protoreflect.Message

func (*OnlineInput_Constants) Reset 

func (x *OnlineInput_Constants) Reset()

func (*OnlineInput_Constants) String 

func (x *OnlineInput_Constants) String() string

type OnlineInput_Constants_ 

type OnlineInput_Constants_ struct {
	Constants *OnlineInput_Constants `protobuf:"bytes,2,opt,name=constants,proto3,oneof"`
}

type OnlineInput_Table 

type OnlineInput_Table struct {
	Table *OnlineInput_TableRow `protobuf:"bytes,1,opt,name=table,proto3,oneof"`
}

type OnlineInput_TableRow 

type OnlineInput_TableRow struct {
	DatasourceName string                            `protobuf:"bytes,1,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	Table          *infra_adapter.DataLocation_Table `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	KeyColumn      string                            `protobuf:"bytes,3,opt,name=key_column,json=keyColumn,proto3" json:"key_column,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineInput_TableRow) Descriptor deprecated 

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

Deprecated: Use OnlineInput_TableRow.ProtoReflect.Descriptor instead.

func (*OnlineInput_TableRow) GetDatasourceName 

func (x *OnlineInput_TableRow) GetDatasourceName() string

func (*OnlineInput_TableRow) GetKeyColumn 

func (x *OnlineInput_TableRow) GetKeyColumn() string

func (*OnlineInput_TableRow) GetTable 

func (x *OnlineInput_TableRow) GetTable() *infra_adapter.DataLocation_Table

func (*OnlineInput_TableRow) ProtoMessage 

func (*OnlineInput_TableRow) ProtoMessage()

func (*OnlineInput_TableRow) ProtoReflect 

func (x *OnlineInput_TableRow) ProtoReflect() protoreflect.Message

func (*OnlineInput_TableRow) Reset 

func (x *OnlineInput_TableRow) Reset()

func (*OnlineInput_TableRow) String 

func (x *OnlineInput_TableRow) String() string

type OnlineOperatorConfig 

type OnlineOperatorConfig struct {
	StageName string `protobuf:"bytes,1,opt,name=stage_name,json=stageName,proto3" json:"stage_name,omitempty"`
	StageType string `protobuf:"bytes,2,opt,name=stage_type,json=stageType,proto3" json:"stage_type,omitempty"`
	// 比较tricky的是这个数组不光代表了这些party参与，这个数组的顺序还分别表示 [client, server1, server2 ..]
	Parties      []*OnlineParticipant `protobuf:"bytes,3,rep,name=parties,proto3" json:"parties,omitempty"`
	GlobalConfig string               `protobuf:"bytes,4,opt,name=global_config,json=globalConfig,proto3" json:"global_config,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineOperatorConfig) Descriptor deprecated 

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

Deprecated: Use OnlineOperatorConfig.ProtoReflect.Descriptor instead.

func (*OnlineOperatorConfig) GetGlobalConfig 

func (x *OnlineOperatorConfig) GetGlobalConfig() string

func (*OnlineOperatorConfig) GetParties 

func (x *OnlineOperatorConfig) GetParties() []*OnlineParticipant

func (*OnlineOperatorConfig) GetStageName 

func (x *OnlineOperatorConfig) GetStageName() string

func (*OnlineOperatorConfig) GetStageType 

func (x *OnlineOperatorConfig) GetStageType() string

func (*OnlineOperatorConfig) ProtoMessage 

func (*OnlineOperatorConfig) ProtoMessage()

func (*OnlineOperatorConfig) ProtoReflect 

func (x *OnlineOperatorConfig) ProtoReflect() protoreflect.Message

func (*OnlineOperatorConfig) Reset 

func (x *OnlineOperatorConfig) Reset()

func (*OnlineOperatorConfig) String 

func (x *OnlineOperatorConfig) String() string

type OnlineParamKey 

type OnlineParamKey struct {
	StageName        string `protobuf:"bytes,1,opt,name=stage_name,json=stageName,proto3" json:"stage_name,omitempty"`                       // 要引用哪个stage，name是唯一的
	ParticipantIndex uint64 `protobuf:"varint,2,opt,name=participant_index,json=participantIndex,proto3" json:"participant_index,omitempty"` // 对应 OnlineOperatorConfig 里第几个 party, 在operator和stage一一对应的时候等价于inner_id
	ParamKey         string `protobuf:"bytes,3,opt,name=param_key,json=paramKey,proto3" json:"param_key,omitempty"`                          // 对应 OnlineOperatorConfig 的input里的key
	// contains filtered or unexported fields
}

func (*OnlineParamKey) Descriptor deprecated 

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

Deprecated: Use OnlineParamKey.ProtoReflect.Descriptor instead.

func (*OnlineParamKey) GetParamKey 

func (x *OnlineParamKey) GetParamKey() string

func (*OnlineParamKey) GetParticipantIndex 

func (x *OnlineParamKey) GetParticipantIndex() uint64

func (*OnlineParamKey) GetStageName 

func (x *OnlineParamKey) GetStageName() string

func (*OnlineParamKey) ProtoMessage 

func (*OnlineParamKey) ProtoMessage()

func (*OnlineParamKey) ProtoReflect 

func (x *OnlineParamKey) ProtoReflect() protoreflect.Message

func (*OnlineParamKey) Reset 

func (x *OnlineParamKey) Reset()

func (*OnlineParamKey) String 

func (x *OnlineParamKey) String() string

type OnlineParticipant 

type OnlineParticipant struct {
	PartyId string                                       `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	Inputs  map[string]*OnlineParticipant_OnlineLocation `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OnlineParticipant) Descriptor deprecated 

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

Deprecated: Use OnlineParticipant.ProtoReflect.Descriptor instead.

func (*OnlineParticipant) GetInputs 

func (x *OnlineParticipant) GetInputs() map[string]*OnlineParticipant_OnlineLocation

func (*OnlineParticipant) GetPartyId 

func (x *OnlineParticipant) GetPartyId() string

func (*OnlineParticipant) ProtoMessage 

func (*OnlineParticipant) ProtoMessage()

func (*OnlineParticipant) ProtoReflect 

func (x *OnlineParticipant) ProtoReflect() protoreflect.Message

func (*OnlineParticipant) Reset 

func (x *OnlineParticipant) Reset()

func (*OnlineParticipant) String 

func (x *OnlineParticipant) String() string

type OnlineParticipant_OnlineLocation 

type OnlineParticipant_OnlineLocation struct {

	// Types that are assignable to Location:
	//	*OnlineParticipant_OnlineLocation_Preload
	//	*OnlineParticipant_OnlineLocation_Upstream
	//	*OnlineParticipant_OnlineLocation_Online
	//	*OnlineParticipant_OnlineLocation_FromApi
	Location isOnlineParticipant_OnlineLocation_Location `protobuf_oneof:"location"`
	// contains filtered or unexported fields
}

func (*OnlineParticipant_OnlineLocation) Descriptor deprecated 

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

Deprecated: Use OnlineParticipant_OnlineLocation.ProtoReflect.Descriptor instead.

func (*OnlineParticipant_OnlineLocation) GetFromApi 

func (x *OnlineParticipant_OnlineLocation) GetFromApi() *emptypb.Empty

func (*OnlineParticipant_OnlineLocation) GetLocation 

func (m *OnlineParticipant_OnlineLocation) GetLocation() isOnlineParticipant_OnlineLocation_Location

func (*OnlineParticipant_OnlineLocation) GetOnline 

func (x *OnlineParticipant_OnlineLocation) GetOnline() *OnlineInput

func (*OnlineParticipant_OnlineLocation) GetPreload 

func (x *OnlineParticipant_OnlineLocation) GetPreload() *infra_adapter.DataLocation

func (*OnlineParticipant_OnlineLocation) GetUpstream 

func (x *OnlineParticipant_OnlineLocation) GetUpstream() *OnlineParamKey

func (*OnlineParticipant_OnlineLocation) ProtoMessage 

func (*OnlineParticipant_OnlineLocation) ProtoMessage()

func (*OnlineParticipant_OnlineLocation) ProtoReflect 

func (x *OnlineParticipant_OnlineLocation) ProtoReflect() protoreflect.Message

func (*OnlineParticipant_OnlineLocation) Reset 

func (x *OnlineParticipant_OnlineLocation) Reset()

func (*OnlineParticipant_OnlineLocation) String 

func (x *OnlineParticipant_OnlineLocation) String() string

type OnlineParticipant_OnlineLocation_FromApi 

type OnlineParticipant_OnlineLocation_FromApi struct {
	FromApi *emptypb.Empty `protobuf:"bytes,4,opt,name=from_api,json=fromApi,proto3,oneof"` // 由用户在预测时通过API输入
}

type OnlineParticipant_OnlineLocation_Online 

type OnlineParticipant_OnlineLocation_Online struct {
	Online *OnlineInput `protobuf:"bytes,3,opt,name=online,proto3,oneof"` // 由用户填充, 实际的输入的"来源", 并不是输入本身
}

type OnlineParticipant_OnlineLocation_Preload 

type OnlineParticipant_OnlineLocation_Preload struct {
	Preload *infra_adapter.DataLocation `protobuf:"bytes,1,opt,name=preload,proto3,oneof"` // 由paas填充, 预先载入的模型的地址
}

type OnlineParticipant_OnlineLocation_Upstream 

type OnlineParticipant_OnlineLocation_Upstream struct {
	Upstream *OnlineParamKey `protobuf:"bytes,2,opt,name=upstream,proto3,oneof"` // 由paas填充, 上游输入
}

type OnlinePirReponse 

type OnlinePirReponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlinePirReponse) Descriptor deprecated 

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

Deprecated: Use OnlinePirReponse.ProtoReflect.Descriptor instead.

func (*OnlinePirReponse) GetValue 

func (x *OnlinePirReponse) GetValue() string

func (*OnlinePirReponse) ProtoMessage 

func (*OnlinePirReponse) ProtoMessage()

func (*OnlinePirReponse) ProtoReflect 

func (x *OnlinePirReponse) ProtoReflect() protoreflect.Message

func (*OnlinePirReponse) Reset 

func (x *OnlinePirReponse) Reset()

func (*OnlinePirReponse) String 

func (x *OnlinePirReponse) String() string

type OnlinePirRequest 

type OnlinePirRequest struct {
	ServerUri        string `protobuf:"bytes,1,opt,name=server_uri,json=serverUri,proto3" json:"server_uri,omitempty"`
	ClientStorageKey string `protobuf:"bytes,2,opt,name=client_storage_key,json=clientStorageKey,proto3" json:"client_storage_key,omitempty"`
	ServerStorageKey string `protobuf:"bytes,3,opt,name=server_storage_key,json=serverStorageKey,proto3" json:"server_storage_key,omitempty"`
	QueryKey         string `protobuf:"bytes,4,opt,name=query_key,json=queryKey,proto3" json:"query_key,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlinePirRequest) Descriptor deprecated 

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

Deprecated: Use OnlinePirRequest.ProtoReflect.Descriptor instead.

func (*OnlinePirRequest) GetClientStorageKey 

func (x *OnlinePirRequest) GetClientStorageKey() string

func (*OnlinePirRequest) GetQueryKey 

func (x *OnlinePirRequest) GetQueryKey() string

func (*OnlinePirRequest) GetServerStorageKey 

func (x *OnlinePirRequest) GetServerStorageKey() string

func (*OnlinePirRequest) GetServerUri 

func (x *OnlinePirRequest) GetServerUri() string

func (*OnlinePirRequest) ProtoMessage 

func (*OnlinePirRequest) ProtoMessage()

func (*OnlinePirRequest) ProtoReflect 

func (x *OnlinePirRequest) ProtoReflect() protoreflect.Message

func (*OnlinePirRequest) Reset 

func (x *OnlinePirRequest) Reset()

func (*OnlinePirRequest) String 

func (x *OnlinePirRequest) String() string

type OnlinePredictRequest 

type OnlinePredictRequest struct {
	ServiceId uint64 `protobuf:"varint,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// 对于不同stage输入给一个不同的查询ID
	//
	// Deprecated: Do not use.
	Inputs      []*RowKeys `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	BucketCount uint64     `protobuf:"varint,3,opt,name=bucket_count,json=bucketCount,proto3" json:"bucket_count,omitempty"`
	// 用户实时查询的ID
	Ids []string `protobuf:"bytes,4,rep,name=ids,proto3" json:"ids,omitempty"`
	// 支持API输入特征的查询
	Params []*PredictParam `protobuf:"bytes,5,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlinePredictRequest) Descriptor deprecated 

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

Deprecated: Use OnlinePredictRequest.ProtoReflect.Descriptor instead.

func (*OnlinePredictRequest) GetBucketCount 

func (x *OnlinePredictRequest) GetBucketCount() uint64

func (*OnlinePredictRequest) GetIds 

func (x *OnlinePredictRequest) GetIds() []string

func (*OnlinePredictRequest) GetInputs deprecated 

func (x *OnlinePredictRequest) GetInputs() []*RowKeys

Deprecated: Do not use.

func (*OnlinePredictRequest) GetParams 

func (x *OnlinePredictRequest) GetParams() []*PredictParam

func (*OnlinePredictRequest) GetServiceId 

func (x *OnlinePredictRequest) GetServiceId() uint64

func (*OnlinePredictRequest) ProtoMessage 

func (*OnlinePredictRequest) ProtoMessage()

func (*OnlinePredictRequest) ProtoReflect 

func (x *OnlinePredictRequest) ProtoReflect() protoreflect.Message

func (*OnlinePredictRequest) Reset 

func (x *OnlinePredictRequest) Reset()

func (*OnlinePredictRequest) String 

func (x *OnlinePredictRequest) String() string

type OnlinePredictResponse 

type OnlinePredictResponse struct {

	// Deprecated: Do not use.
	Result map[string]string `` /* 153-byte string literal not displayed */
	// 预测返回值, 与 `OnlinePredictRequest.ids` 一一对应
	Items []*OnlinePredictResponseItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlinePredictResponse) Descriptor deprecated 

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

Deprecated: Use OnlinePredictResponse.ProtoReflect.Descriptor instead.

func (*OnlinePredictResponse) GetItems 

func (x *OnlinePredictResponse) GetItems() []*OnlinePredictResponseItem

func (*OnlinePredictResponse) GetResult deprecated 

func (x *OnlinePredictResponse) GetResult() map[string]string

Deprecated: Do not use.

func (*OnlinePredictResponse) ProtoMessage 

func (*OnlinePredictResponse) ProtoMessage()

func (*OnlinePredictResponse) ProtoReflect 

func (x *OnlinePredictResponse) ProtoReflect() protoreflect.Message

func (*OnlinePredictResponse) Reset 

func (x *OnlinePredictResponse) Reset()

func (*OnlinePredictResponse) String 

func (x *OnlinePredictResponse) String() string

type OnlinePredictResponseItem 

type OnlinePredictResponseItem struct {
	Status OnlinePredictResponseItem_Status `` /* 132-byte string literal not displayed */
	// Key与`OnlineBlock.result_memory_key`一一对应
	Result map[string]string `` /* 153-byte string literal not displayed */
	// 对PARTIAL状态的补充说明，表示缺失一方的id集合
	MissingParties []string `protobuf:"bytes,3,rep,name=missing_parties,json=missingParties,proto3" json:"missing_parties,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlinePredictResponseItem) Descriptor deprecated 

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

Deprecated: Use OnlinePredictResponseItem.ProtoReflect.Descriptor instead.

func (*OnlinePredictResponseItem) GetMissingParties 

func (x *OnlinePredictResponseItem) GetMissingParties() []string

func (*OnlinePredictResponseItem) GetResult 

func (x *OnlinePredictResponseItem) GetResult() map[string]string

func (*OnlinePredictResponseItem) GetStatus 

func (x *OnlinePredictResponseItem) GetStatus() OnlinePredictResponseItem_Status

func (*OnlinePredictResponseItem) ProtoMessage 

func (*OnlinePredictResponseItem) ProtoMessage()

func (*OnlinePredictResponseItem) ProtoReflect 

func (x *OnlinePredictResponseItem) ProtoReflect() protoreflect.Message

func (*OnlinePredictResponseItem) Reset 

func (x *OnlinePredictResponseItem) Reset()

func (*OnlinePredictResponseItem) String 

func (x *OnlinePredictResponseItem) String() string

type OnlinePredictResponseItem_Status 

type OnlinePredictResponseItem_Status int32
const (
	OnlinePredictResponseItem_SUCCESS OnlinePredictResponseItem_Status = 0
	// 所有party都没有数据, 无法进行任何有意义的预测
	// 此时result是空的
	OnlinePredictResponseItem_NOT_FOUND_ANYWHERE OnlinePredictResponseItem_Status = 1
	OnlinePredictResponseItem_PARTIAL            OnlinePredictResponseItem_Status = 2
)

func (OnlinePredictResponseItem_Status) Descriptor 

func (OnlinePredictResponseItem_Status) Descriptor() protoreflect.EnumDescriptor

func (OnlinePredictResponseItem_Status) Enum 

func (x OnlinePredictResponseItem_Status) Enum() *OnlinePredictResponseItem_Status

func (OnlinePredictResponseItem_Status) EnumDescriptor deprecated 

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

Deprecated: Use OnlinePredictResponseItem_Status.Descriptor instead.

func (OnlinePredictResponseItem_Status) Number 

func (x OnlinePredictResponseItem_Status) Number() protoreflect.EnumNumber

func (OnlinePredictResponseItem_Status) String 

func (x OnlinePredictResponseItem_Status) String() string

func (OnlinePredictResponseItem_Status) Type 

func (OnlinePredictResponseItem_Status) Type() protoreflect.EnumType

type OperatorConfig 

type OperatorConfig struct {
	OperatorType string                                 `protobuf:"bytes,1,opt,name=operator_type,json=operatorType,proto3" json:"operator_type,omitempty"`
	GlobalConfig string                                 `protobuf:"bytes,2,opt,name=global_config,json=globalConfig,proto3" json:"global_config,omitempty"` // json
	PartyConfig  string                                 `protobuf:"bytes,3,opt,name=party_config,json=partyConfig,proto3" json:"party_config,omitempty"`    // json
	Inputs       map[string]*infra_adapter.DataLocation ``                                                                                                  /* 153-byte string literal not displayed */
	Outputs      map[string]*infra_adapter.DataLocation ``                                                                                                  /* 155-byte string literal not displayed */
	// deprecated
	Parties []string `protobuf:"bytes,6,rep,name=parties,proto3" json:"parties,omitempty"`
	// only visiable to client, indicates which servers to connect
	// client will find destination url through party_infos,
	// the client (inner_id=0) is always included, [0, a, b, c ...]
	PartyInnerIds []uint64 `protobuf:"varint,7,rep,packed,name=party_inner_ids,json=partyInnerIds,proto3" json:"party_inner_ids,omitempty"`
	// used in PaaS, since operator_type_str in operator is different with it in PaaS
	OpTypeEnum enums.Stage_Type `` /* 130-byte string literal not displayed */
	Version    *Version         `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorConfig) Descriptor deprecated 

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

Deprecated: Use OperatorConfig.ProtoReflect.Descriptor instead.

func (*OperatorConfig) GetGlobalConfig 

func (x *OperatorConfig) GetGlobalConfig() string

func (*OperatorConfig) GetInputs 

func (x *OperatorConfig) GetInputs() map[string]*infra_adapter.DataLocation

func (*OperatorConfig) GetOpTypeEnum 

func (x *OperatorConfig) GetOpTypeEnum() enums.Stage_Type

func (*OperatorConfig) GetOperatorType 

func (x *OperatorConfig) GetOperatorType() string

func (*OperatorConfig) GetOutputs 

func (x *OperatorConfig) GetOutputs() map[string]*infra_adapter.DataLocation

func (*OperatorConfig) GetParties 

func (x *OperatorConfig) GetParties() []string

func (*OperatorConfig) GetPartyConfig 

func (x *OperatorConfig) GetPartyConfig() string

func (*OperatorConfig) GetPartyInnerIds 

func (x *OperatorConfig) GetPartyInnerIds() []uint64

func (*OperatorConfig) GetVersion 

func (x *OperatorConfig) GetVersion() *Version

func (*OperatorConfig) ProtoMessage 

func (*OperatorConfig) ProtoMessage()

func (*OperatorConfig) ProtoReflect 

func (x *OperatorConfig) ProtoReflect() protoreflect.Message

func (*OperatorConfig) Reset 

func (x *OperatorConfig) Reset()

func (*OperatorConfig) String 

func (x *OperatorConfig) String() string

type OperatorMachine 

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

func (*OperatorMachine) Descriptor deprecated 

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

Deprecated: Use OperatorMachine.ProtoReflect.Descriptor instead.

func (*OperatorMachine) ProtoMessage 

func (*OperatorMachine) ProtoMessage()

func (*OperatorMachine) ProtoReflect 

func (x *OperatorMachine) ProtoReflect() protoreflect.Message

func (*OperatorMachine) Reset 

func (x *OperatorMachine) Reset()

func (*OperatorMachine) String 

func (x *OperatorMachine) String() string

type OperatorMachine_Status 

type OperatorMachine_Status int32
const (
	OperatorMachine_UNKNOWN_STATUS OperatorMachine_Status = 0
	OperatorMachine_IDLE           OperatorMachine_Status = 1
	OperatorMachine_RESERVED       OperatorMachine_Status = 2
	OperatorMachine_BUSY           OperatorMachine_Status = 3
	OperatorMachine_DEAD           OperatorMachine_Status = 4
)

func (OperatorMachine_Status) Descriptor 

func (OperatorMachine_Status) Descriptor() protoreflect.EnumDescriptor

func (OperatorMachine_Status) Enum 

func (x OperatorMachine_Status) Enum() *OperatorMachine_Status

func (OperatorMachine_Status) EnumDescriptor deprecated 

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

Deprecated: Use OperatorMachine_Status.Descriptor instead.

func (OperatorMachine_Status) Number 

func (x OperatorMachine_Status) Number() protoreflect.EnumNumber

func (OperatorMachine_Status) String 

func (x OperatorMachine_Status) String() string

func (OperatorMachine_Status) Type 

func (OperatorMachine_Status) Type() protoreflect.EnumType

type OperatorSchema 

type OperatorSchema struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// string author = 2;
	Version *Version `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Schema  string   `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"` // contains tags/task_type/config_schema/display_name etc.
	// unique id of operator
	// when defining operator, if it's legacy operator (in enum), it can be 0, furnace can find corresponding id
	// by stage type in enum; if it's newly added operator, we need to ensure it's unique.
	Id uint32 `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorSchema) Descriptor deprecated 

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

Deprecated: Use OperatorSchema.ProtoReflect.Descriptor instead.

func (*OperatorSchema) GetId 

func (x *OperatorSchema) GetId() uint32

func (*OperatorSchema) GetName 

func (x *OperatorSchema) GetName() string

func (*OperatorSchema) GetSchema 

func (x *OperatorSchema) GetSchema() string

func (*OperatorSchema) GetVersion 

func (x *OperatorSchema) GetVersion() *Version

func (*OperatorSchema) ProtoMessage 

func (*OperatorSchema) ProtoMessage()

func (*OperatorSchema) ProtoReflect 

func (x *OperatorSchema) ProtoReflect() protoreflect.Message

func (*OperatorSchema) Reset 

func (x *OperatorSchema) Reset()

func (*OperatorSchema) String 

func (x *OperatorSchema) String() string

type PartyInfo 

type PartyInfo struct {
	InnerId uint64 `protobuf:"varint,1,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"`
	PartyId string `protobuf:"bytes,2,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	// string deprecated_uri = 3;  // deprecated: use "op_service" instead
	OpService           string                      `protobuf:"bytes,4,opt,name=op_service,json=opService,proto3" json:"op_service,omitempty"` // entry point (nginx) to connect to operators via WebSocket
	OpHost              string                      `protobuf:"bytes,5,opt,name=op_host,json=opHost,proto3" json:"op_host,omitempty"`          // host of the actual (reserved) operator master to process the stage
	OpPort              uint32                      `protobuf:"varint,6,opt,name=op_port,json=opPort,proto3" json:"op_port,omitempty"`         // port of the actual (reserved) operator master to process the stage
	ResourceType        enums.Resource_Type         ``                                                                                         /* 137-byte string literal not displayed */
	ResourceRequirement *common.ResourceRequirement `protobuf:"bytes,8,opt,name=resource_requirement,json=resourceRequirement,proto3" json:"resource_requirement,omitempty"`
	// contains filtered or unexported fields
}

func (*PartyInfo) Descriptor deprecated 

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

Deprecated: Use PartyInfo.ProtoReflect.Descriptor instead.

func (*PartyInfo) GetInnerId 

func (x *PartyInfo) GetInnerId() uint64

func (*PartyInfo) GetOpHost 

func (x *PartyInfo) GetOpHost() string

func (*PartyInfo) GetOpPort 

func (x *PartyInfo) GetOpPort() uint32

func (*PartyInfo) GetOpService 

func (x *PartyInfo) GetOpService() string

func (*PartyInfo) GetPartyId 

func (x *PartyInfo) GetPartyId() string

func (*PartyInfo) GetResourceRequirement 

func (x *PartyInfo) GetResourceRequirement() *common.ResourceRequirement

func (*PartyInfo) GetResourceType 

func (x *PartyInfo) GetResourceType() enums.Resource_Type

func (*PartyInfo) ProtoMessage 

func (*PartyInfo) ProtoMessage()

func (*PartyInfo) ProtoReflect 

func (x *PartyInfo) ProtoReflect() protoreflect.Message

func (*PartyInfo) Reset 

func (x *PartyInfo) Reset()

func (*PartyInfo) String 

func (x *PartyInfo) String() string

type PredictInput 

type PredictInput struct {

	// 特征列名称
	FeatureColumns []string    `protobuf:"bytes,1,rep,name=feature_columns,json=featureColumns,proto3" json:"feature_columns,omitempty"`
	RowValues      []*RowValue `protobuf:"bytes,2,rep,name=row_values,json=rowValues,proto3" json:"row_values,omitempty"`
	// contains filtered or unexported fields
}

func (*PredictInput) Descriptor deprecated 

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

Deprecated: Use PredictInput.ProtoReflect.Descriptor instead.

func (*PredictInput) GetFeatureColumns 

func (x *PredictInput) GetFeatureColumns() []string

func (*PredictInput) GetRowValues 

func (x *PredictInput) GetRowValues() []*RowValue

func (*PredictInput) ProtoMessage 

func (*PredictInput) ProtoMessage()

func (*PredictInput) ProtoReflect 

func (x *PredictInput) ProtoReflect() protoreflect.Message

func (*PredictInput) Reset 

func (x *PredictInput) Reset()

func (*PredictInput) String 

func (x *PredictInput) String() string

type PredictParam 

type PredictParam struct {
	OnlineParamKeys *OnlineParamKey `protobuf:"bytes,1,opt,name=online_param_keys,json=onlineParamKeys,proto3" json:"online_param_keys,omitempty"`
	PredictInputs   *PredictInput   `protobuf:"bytes,2,opt,name=predict_inputs,json=predictInputs,proto3" json:"predict_inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*PredictParam) Descriptor deprecated 

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

Deprecated: Use PredictParam.ProtoReflect.Descriptor instead.

func (*PredictParam) GetOnlineParamKeys 

func (x *PredictParam) GetOnlineParamKeys() *OnlineParamKey

func (*PredictParam) GetPredictInputs 

func (x *PredictParam) GetPredictInputs() *PredictInput

func (*PredictParam) ProtoMessage 

func (*PredictParam) ProtoMessage()

func (*PredictParam) ProtoReflect 

func (x *PredictParam) ProtoReflect() protoreflect.Message

func (*PredictParam) Reset 

func (x *PredictParam) Reset()

func (*PredictParam) String 

func (x *PredictParam) String() string

type ReadFileRequest 

type ReadFileRequest struct {

	// Deprecated: use file instead
	//
	// Deprecated: Do not use.
	FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	// Deprecated: Do not use.
	DatasourceName string                           `protobuf:"bytes,2,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	File           *infra_adapter.DataLocation_File `protobuf:"bytes,5,opt,name=file,proto3" json:"file,omitempty"`
	PageSize       uint32                           `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageNum        uint64                           `protobuf:"varint,4,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFileRequest) Descriptor deprecated 

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

Deprecated: Use ReadFileRequest.ProtoReflect.Descriptor instead.

func (*ReadFileRequest) GetDatasourceName deprecated 

func (x *ReadFileRequest) GetDatasourceName() string

Deprecated: Do not use.

func (*ReadFileRequest) GetFile 

func (x *ReadFileRequest) GetFile() *infra_adapter.DataLocation_File

func (*ReadFileRequest) GetFilePath deprecated 

func (x *ReadFileRequest) GetFilePath() string

Deprecated: Do not use.

func (*ReadFileRequest) GetPageNum 

func (x *ReadFileRequest) GetPageNum() uint64

func (*ReadFileRequest) GetPageSize 

func (x *ReadFileRequest) GetPageSize() uint32

func (*ReadFileRequest) ProtoMessage 

func (*ReadFileRequest) ProtoMessage()

func (*ReadFileRequest) ProtoReflect 

func (x *ReadFileRequest) ProtoReflect() protoreflect.Message

func (*ReadFileRequest) Reset 

func (x *ReadFileRequest) Reset()

func (*ReadFileRequest) String 

func (x *ReadFileRequest) String() string

type ReadFileResponse 

type ReadFileResponse struct {
	Columns []*SqlColumn `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFileResponse) Descriptor deprecated 

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

Deprecated: Use ReadFileResponse.ProtoReflect.Descriptor instead.

func (*ReadFileResponse) GetColumns 

func (x *ReadFileResponse) GetColumns() []*SqlColumn

func (*ReadFileResponse) ProtoMessage 

func (*ReadFileResponse) ProtoMessage()

func (*ReadFileResponse) ProtoReflect 

func (x *ReadFileResponse) ProtoReflect() protoreflect.Message

func (*ReadFileResponse) Reset 

func (x *ReadFileResponse) Reset()

func (*ReadFileResponse) String 

func (x *ReadFileResponse) String() string

type RegisterMachineRequest 

type RegisterMachineRequest struct {
	Host      string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	GrpcPort  uint32            `protobuf:"varint,2,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	WsPort    uint32            `protobuf:"varint,3,opt,name=ws_port,json=wsPort,proto3" json:"ws_port,omitempty"`
	Operators []*OperatorSchema `protobuf:"bytes,4,rep,name=operators,proto3" json:"operators,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMachineRequest) Descriptor deprecated 

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

Deprecated: Use RegisterMachineRequest.ProtoReflect.Descriptor instead.

func (*RegisterMachineRequest) GetGrpcPort 

func (x *RegisterMachineRequest) GetGrpcPort() uint32

func (*RegisterMachineRequest) GetHost 

func (x *RegisterMachineRequest) GetHost() string

func (*RegisterMachineRequest) GetOperators 

func (x *RegisterMachineRequest) GetOperators() []*OperatorSchema

func (*RegisterMachineRequest) GetWsPort 

func (x *RegisterMachineRequest) GetWsPort() uint32

func (*RegisterMachineRequest) ProtoMessage 

func (*RegisterMachineRequest) ProtoMessage()

func (*RegisterMachineRequest) ProtoReflect 

func (x *RegisterMachineRequest) ProtoReflect() protoreflect.Message

func (*RegisterMachineRequest) Reset 

func (x *RegisterMachineRequest) Reset()

func (*RegisterMachineRequest) String 

func (x *RegisterMachineRequest) String() string

type RegisterMachineResponse 

type RegisterMachineResponse struct {
	OperatorId uint64 `protobuf:"varint,1,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMachineResponse) Descriptor deprecated 

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

Deprecated: Use RegisterMachineResponse.ProtoReflect.Descriptor instead.

func (*RegisterMachineResponse) GetOperatorId 

func (x *RegisterMachineResponse) GetOperatorId() uint64

func (*RegisterMachineResponse) ProtoMessage 

func (*RegisterMachineResponse) ProtoMessage()

func (*RegisterMachineResponse) ProtoReflect 

func (x *RegisterMachineResponse) ProtoReflect() protoreflect.Message

func (*RegisterMachineResponse) Reset 

func (x *RegisterMachineResponse) Reset()

func (*RegisterMachineResponse) String 

func (x *RegisterMachineResponse) String() string

type RemoveResourcesRequest 

type RemoveResourcesRequest struct {
	Locations []*infra_adapter.DataLocation `protobuf:"bytes,1,rep,name=locations,proto3" json:"locations,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveResourcesRequest) Descriptor deprecated 

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

Deprecated: Use RemoveResourcesRequest.ProtoReflect.Descriptor instead.

func (*RemoveResourcesRequest) GetLocations 

func (x *RemoveResourcesRequest) GetLocations() []*infra_adapter.DataLocation

func (*RemoveResourcesRequest) ProtoMessage 

func (*RemoveResourcesRequest) ProtoMessage()

func (*RemoveResourcesRequest) ProtoReflect 

func (x *RemoveResourcesRequest) ProtoReflect() protoreflect.Message

func (*RemoveResourcesRequest) Reset 

func (x *RemoveResourcesRequest) Reset()

func (*RemoveResourcesRequest) String 

func (x *RemoveResourcesRequest) String() string

type RemoveResourcesResponse 

type RemoveResourcesResponse struct {
	Response []*SingleRemoveResourceResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveResourcesResponse) Descriptor deprecated 

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

Deprecated: Use RemoveResourcesResponse.ProtoReflect.Descriptor instead.

func (*RemoveResourcesResponse) GetResponse 

func (x *RemoveResourcesResponse) GetResponse() []*SingleRemoveResourceResponse

func (*RemoveResourcesResponse) ProtoMessage 

func (*RemoveResourcesResponse) ProtoMessage()

func (*RemoveResourcesResponse) ProtoReflect 

func (x *RemoveResourcesResponse) ProtoReflect() protoreflect.Message

func (*RemoveResourcesResponse) Reset 

func (x *RemoveResourcesResponse) Reset()

func (*RemoveResourcesResponse) String 

func (x *RemoveResourcesResponse) String() string

type ReportStageUsageRequest 

type ReportStageUsageRequest struct {
	Id    *BlockID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Usage uint64   `protobuf:"varint,2,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportStageUsageRequest) Descriptor deprecated 

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

Deprecated: Use ReportStageUsageRequest.ProtoReflect.Descriptor instead.

func (*ReportStageUsageRequest) GetId 

func (x *ReportStageUsageRequest) GetId() *BlockID

func (*ReportStageUsageRequest) GetUsage 

func (x *ReportStageUsageRequest) GetUsage() uint64

func (*ReportStageUsageRequest) ProtoMessage 

func (*ReportStageUsageRequest) ProtoMessage()

func (*ReportStageUsageRequest) ProtoReflect 

func (x *ReportStageUsageRequest) ProtoReflect() protoreflect.Message

func (*ReportStageUsageRequest) Reset 

func (x *ReportStageUsageRequest) Reset()

func (*ReportStageUsageRequest) String 

func (x *ReportStageUsageRequest) String() string

type RevokeBlockRequest 

type RevokeBlockRequest struct {
	BlockId *BlockID `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeBlockRequest) Descriptor deprecated 

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

Deprecated: Use RevokeBlockRequest.ProtoReflect.Descriptor instead.

func (*RevokeBlockRequest) GetBlockId 

func (x *RevokeBlockRequest) GetBlockId() *BlockID

func (*RevokeBlockRequest) ProtoMessage 

func (*RevokeBlockRequest) ProtoMessage()

func (*RevokeBlockRequest) ProtoReflect 

func (x *RevokeBlockRequest) ProtoReflect() protoreflect.Message

func (*RevokeBlockRequest) Reset 

func (x *RevokeBlockRequest) Reset()

func (*RevokeBlockRequest) String 

func (x *RevokeBlockRequest) String() string

type RevokeBlockResponse 

type RevokeBlockResponse struct {
	Code RevokeBlockResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=sudo.protobuf.infra_adapter.RevokeBlockResponse_Code" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeBlockResponse) Descriptor deprecated 

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

Deprecated: Use RevokeBlockResponse.ProtoReflect.Descriptor instead.

func (*RevokeBlockResponse) GetCode 

func (x *RevokeBlockResponse) GetCode() RevokeBlockResponse_Code

func (*RevokeBlockResponse) ProtoMessage 

func (*RevokeBlockResponse) ProtoMessage()

func (*RevokeBlockResponse) ProtoReflect 

func (x *RevokeBlockResponse) ProtoReflect() protoreflect.Message

func (*RevokeBlockResponse) Reset 

func (x *RevokeBlockResponse) Reset()

func (*RevokeBlockResponse) String 

func (x *RevokeBlockResponse) String() string

type RevokeBlockResponse_Code 

type RevokeBlockResponse_Code int32
const (
	RevokeBlockResponse_SUCCESS   RevokeBlockResponse_Code = 0
	RevokeBlockResponse_FAILED    RevokeBlockResponse_Code = 1
	RevokeBlockResponse_NOT_EXIST RevokeBlockResponse_Code = 2
)

func (RevokeBlockResponse_Code) Descriptor 

func (RevokeBlockResponse_Code) Descriptor() protoreflect.EnumDescriptor

func (RevokeBlockResponse_Code) Enum 

func (x RevokeBlockResponse_Code) Enum() *RevokeBlockResponse_Code

func (RevokeBlockResponse_Code) EnumDescriptor deprecated 

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

Deprecated: Use RevokeBlockResponse_Code.Descriptor instead.

func (RevokeBlockResponse_Code) Number 

func (x RevokeBlockResponse_Code) Number() protoreflect.EnumNumber

func (RevokeBlockResponse_Code) String 

func (x RevokeBlockResponse_Code) String() string

func (RevokeBlockResponse_Code) Type 

func (RevokeBlockResponse_Code) Type() protoreflect.EnumType

type RowKeys 

type RowKeys struct {
	Key  *OnlineParamKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Row  string          `protobuf:"bytes,2,opt,name=row,proto3" json:"row,omitempty"`
	Rows []string        `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*RowKeys) Descriptor deprecated 

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

Deprecated: Use RowKeys.ProtoReflect.Descriptor instead.

func (*RowKeys) GetKey 

func (x *RowKeys) GetKey() *OnlineParamKey

func (*RowKeys) GetRow 

func (x *RowKeys) GetRow() string

func (*RowKeys) GetRows 

func (x *RowKeys) GetRows() []string

func (*RowKeys) ProtoMessage 

func (*RowKeys) ProtoMessage()

func (*RowKeys) ProtoReflect 

func (x *RowKeys) ProtoReflect() protoreflect.Message

func (*RowKeys) Reset 

func (x *RowKeys) Reset()

func (*RowKeys) String 

func (x *RowKeys) String() string

type RowValue 

type RowValue struct {

	// 特征值
	Features []string `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*RowValue) Descriptor deprecated 

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

Deprecated: Use RowValue.ProtoReflect.Descriptor instead.

func (*RowValue) GetFeatures 

func (x *RowValue) GetFeatures() []string

func (*RowValue) ProtoMessage 

func (*RowValue) ProtoMessage()

func (*RowValue) ProtoReflect 

func (x *RowValue) ProtoReflect() protoreflect.Message

func (*RowValue) Reset 

func (x *RowValue) Reset()

func (*RowValue) String 

func (x *RowValue) String() string

type RunSqlRequest 

type RunSqlRequest struct {
	Query          string                                   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DatasourceName string                                   `protobuf:"bytes,2,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	Connection     *infra_adapter.DataLocation_DBConnection `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSqlRequest) Descriptor deprecated 

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

Deprecated: Use RunSqlRequest.ProtoReflect.Descriptor instead.

func (*RunSqlRequest) GetConnection 

func (x *RunSqlRequest) GetConnection() *infra_adapter.DataLocation_DBConnection

func (*RunSqlRequest) GetDatasourceName 

func (x *RunSqlRequest) GetDatasourceName() string

func (*RunSqlRequest) GetQuery 

func (x *RunSqlRequest) GetQuery() string

func (*RunSqlRequest) ProtoMessage 

func (*RunSqlRequest) ProtoMessage()

func (*RunSqlRequest) ProtoReflect 

func (x *RunSqlRequest) ProtoReflect() protoreflect.Message

func (*RunSqlRequest) Reset 

func (x *RunSqlRequest) Reset()

func (*RunSqlRequest) String 

func (x *RunSqlRequest) String() string

type RunSqlResponse 

type RunSqlResponse struct {
	Columns []*SqlColumn `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSqlResponse) Descriptor deprecated 

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

Deprecated: Use RunSqlResponse.ProtoReflect.Descriptor instead.

func (*RunSqlResponse) GetColumns 

func (x *RunSqlResponse) GetColumns() []*SqlColumn

func (*RunSqlResponse) ProtoMessage 

func (*RunSqlResponse) ProtoMessage()

func (*RunSqlResponse) ProtoReflect 

func (x *RunSqlResponse) ProtoReflect() protoreflect.Message

func (*RunSqlResponse) Reset 

func (x *RunSqlResponse) Reset()

func (*RunSqlResponse) String 

func (x *RunSqlResponse) String() string

type ShowDatabasesRequest 

type ShowDatabasesRequest struct {
	DatasourceName string                                   `protobuf:"bytes,1,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	Connection     *infra_adapter.DataLocation_DBConnection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDatabasesRequest) Descriptor deprecated 

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

Deprecated: Use ShowDatabasesRequest.ProtoReflect.Descriptor instead.

func (*ShowDatabasesRequest) GetConnection 

func (x *ShowDatabasesRequest) GetConnection() *infra_adapter.DataLocation_DBConnection

func (*ShowDatabasesRequest) GetDatasourceName 

func (x *ShowDatabasesRequest) GetDatasourceName() string

func (*ShowDatabasesRequest) ProtoMessage 

func (*ShowDatabasesRequest) ProtoMessage()

func (*ShowDatabasesRequest) ProtoReflect 

func (x *ShowDatabasesRequest) ProtoReflect() protoreflect.Message

func (*ShowDatabasesRequest) Reset 

func (x *ShowDatabasesRequest) Reset()

func (*ShowDatabasesRequest) String 

func (x *ShowDatabasesRequest) String() string

type ShowDatabasesResponse 

type ShowDatabasesResponse struct {
	Databases []string `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDatabasesResponse) Descriptor deprecated 

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

Deprecated: Use ShowDatabasesResponse.ProtoReflect.Descriptor instead.

func (*ShowDatabasesResponse) GetDatabases 

func (x *ShowDatabasesResponse) GetDatabases() []string

func (*ShowDatabasesResponse) ProtoMessage 

func (*ShowDatabasesResponse) ProtoMessage()

func (*ShowDatabasesResponse) ProtoReflect 

func (x *ShowDatabasesResponse) ProtoReflect() protoreflect.Message

func (*ShowDatabasesResponse) Reset 

func (x *ShowDatabasesResponse) Reset()

func (*ShowDatabasesResponse) String 

func (x *ShowDatabasesResponse) String() string

type ShowTablesRequest 

type ShowTablesRequest struct {
	DatasourceName string                                   `protobuf:"bytes,1,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	Database       string                                   `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Connection     *infra_adapter.DataLocation_DBConnection `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowTablesRequest) Descriptor deprecated 

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

Deprecated: Use ShowTablesRequest.ProtoReflect.Descriptor instead.

func (*ShowTablesRequest) GetConnection 

func (x *ShowTablesRequest) GetConnection() *infra_adapter.DataLocation_DBConnection

func (*ShowTablesRequest) GetDatabase 

func (x *ShowTablesRequest) GetDatabase() string

func (*ShowTablesRequest) GetDatasourceName 

func (x *ShowTablesRequest) GetDatasourceName() string

func (*ShowTablesRequest) ProtoMessage 

func (*ShowTablesRequest) ProtoMessage()

func (*ShowTablesRequest) ProtoReflect 

func (x *ShowTablesRequest) ProtoReflect() protoreflect.Message

func (*ShowTablesRequest) Reset 

func (x *ShowTablesRequest) Reset()

func (*ShowTablesRequest) String 

func (x *ShowTablesRequest) String() string

type ShowTablesResponse 

type ShowTablesResponse struct {
	Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowTablesResponse) Descriptor deprecated 

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

Deprecated: Use ShowTablesResponse.ProtoReflect.Descriptor instead.

func (*ShowTablesResponse) GetTables 

func (x *ShowTablesResponse) GetTables() []string

func (*ShowTablesResponse) ProtoMessage 

func (*ShowTablesResponse) ProtoMessage()

func (*ShowTablesResponse) ProtoReflect 

func (x *ShowTablesResponse) ProtoReflect() protoreflect.Message

func (*ShowTablesResponse) Reset 

func (x *ShowTablesResponse) Reset()

func (*ShowTablesResponse) String 

func (x *ShowTablesResponse) String() string

type SingleRemoveResourceResponse 

type SingleRemoveResourceResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*SingleRemoveResourceResponse) Descriptor deprecated 

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

Deprecated: Use SingleRemoveResourceResponse.ProtoReflect.Descriptor instead.

func (*SingleRemoveResourceResponse) GetMessage 

func (x *SingleRemoveResourceResponse) GetMessage() string

func (*SingleRemoveResourceResponse) GetSuccess 

func (x *SingleRemoveResourceResponse) GetSuccess() bool

func (*SingleRemoveResourceResponse) ProtoMessage 

func (*SingleRemoveResourceResponse) ProtoMessage()

func (*SingleRemoveResourceResponse) ProtoReflect 

func (x *SingleRemoveResourceResponse) ProtoReflect() protoreflect.Message

func (*SingleRemoveResourceResponse) Reset 

func (x *SingleRemoveResourceResponse) Reset()

func (*SingleRemoveResourceResponse) String 

func (x *SingleRemoveResourceResponse) String() string

type SqlColumn 

type SqlColumn struct {
	ColumnNames string   `protobuf:"bytes,1,opt,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	Data        []string `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SqlColumn) Descriptor deprecated 

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

Deprecated: Use SqlColumn.ProtoReflect.Descriptor instead.

func (*SqlColumn) GetColumnNames 

func (x *SqlColumn) GetColumnNames() string

func (*SqlColumn) GetData 

func (x *SqlColumn) GetData() []string

func (*SqlColumn) ProtoMessage 

func (*SqlColumn) ProtoMessage()

func (*SqlColumn) ProtoReflect 

func (x *SqlColumn) ProtoReflect() protoreflect.Message

func (*SqlColumn) Reset 

func (x *SqlColumn) Reset()

func (*SqlColumn) String 

func (x *SqlColumn) String() string

type StageList 

type StageList struct {
	Ids []*BlockID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StageList) Descriptor deprecated 

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

Deprecated: Use StageList.ProtoReflect.Descriptor instead.

func (*StageList) GetIds 

func (x *StageList) GetIds() []*BlockID

func (*StageList) ProtoMessage 

func (*StageList) ProtoMessage()

func (*StageList) ProtoReflect 

func (x *StageList) ProtoReflect() protoreflect.Message

func (*StageList) Reset 

func (x *StageList) Reset()

func (*StageList) String 

func (x *StageList) String() string

type UpdateBlockInfoRequest 

type UpdateBlockInfoRequest struct {
	Id             *BlockID                               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OperatorStatus *UpdateBlockInfoRequest_OperatorStatus `protobuf:"bytes,2,opt,name=operator_status,json=operatorStatus,proto3" json:"operator_status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBlockInfoRequest) Descriptor deprecated 

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

Deprecated: Use UpdateBlockInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateBlockInfoRequest) GetId 

func (x *UpdateBlockInfoRequest) GetId() *BlockID

func (*UpdateBlockInfoRequest) GetOperatorStatus 

func (x *UpdateBlockInfoRequest) GetOperatorStatus() *UpdateBlockInfoRequest_OperatorStatus

func (*UpdateBlockInfoRequest) ProtoMessage 

func (*UpdateBlockInfoRequest) ProtoMessage()

func (*UpdateBlockInfoRequest) ProtoReflect 

func (x *UpdateBlockInfoRequest) ProtoReflect() protoreflect.Message

func (*UpdateBlockInfoRequest) Reset 

func (x *UpdateBlockInfoRequest) Reset()

func (*UpdateBlockInfoRequest) String 

func (x *UpdateBlockInfoRequest) String() string

type UpdateBlockInfoRequest_OperatorStatus 

type UpdateBlockInfoRequest_OperatorStatus struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBlockInfoRequest_OperatorStatus) Descriptor deprecated 

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

Deprecated: Use UpdateBlockInfoRequest_OperatorStatus.ProtoReflect.Descriptor instead.

func (*UpdateBlockInfoRequest_OperatorStatus) GetReady 

func (x *UpdateBlockInfoRequest_OperatorStatus) GetReady() bool

func (*UpdateBlockInfoRequest_OperatorStatus) ProtoMessage 

func (*UpdateBlockInfoRequest_OperatorStatus) ProtoMessage()

func (*UpdateBlockInfoRequest_OperatorStatus) ProtoReflect 

func (x *UpdateBlockInfoRequest_OperatorStatus) ProtoReflect() protoreflect.Message

func (*UpdateBlockInfoRequest_OperatorStatus) Reset 

func (x *UpdateBlockInfoRequest_OperatorStatus) Reset()

func (*UpdateBlockInfoRequest_OperatorStatus) String 

func (x *UpdateBlockInfoRequest_OperatorStatus) String() string

type UpdateDataSourceRequest 

type UpdateDataSourceRequest struct {
	DataSources []*UpdateDataSourceRequest_DataSource `protobuf:"bytes,1,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDataSourceRequest) Descriptor deprecated 

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

Deprecated: Use UpdateDataSourceRequest.ProtoReflect.Descriptor instead.

func (*UpdateDataSourceRequest) GetDataSources 

func (x *UpdateDataSourceRequest) GetDataSources() []*UpdateDataSourceRequest_DataSource

func (*UpdateDataSourceRequest) ProtoMessage 

func (*UpdateDataSourceRequest) ProtoMessage()

func (*UpdateDataSourceRequest) ProtoReflect 

func (x *UpdateDataSourceRequest) ProtoReflect() protoreflect.Message

func (*UpdateDataSourceRequest) Reset 

func (x *UpdateDataSourceRequest) Reset()

func (*UpdateDataSourceRequest) String 

func (x *UpdateDataSourceRequest) String() string

type UpdateDataSourceRequest_DataSource 

type UpdateDataSourceRequest_DataSource struct {

	// DataSource name, unique identifier, cannot be duplicated
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// DataSouce address，for example mysql://user:pwd@127.0.0.1:3306/reqHistory
	Identifier string `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// Datasource type，such as definition in enums.proto
	Type enums.Datasource_Type `protobuf:"varint,3,opt,name=type,proto3,enum=sudo.protobuf.enums.Datasource_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDataSourceRequest_DataSource) Descriptor deprecated 

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

Deprecated: Use UpdateDataSourceRequest_DataSource.ProtoReflect.Descriptor instead.

func (*UpdateDataSourceRequest_DataSource) GetIdentifier 

func (x *UpdateDataSourceRequest_DataSource) GetIdentifier() string

func (*UpdateDataSourceRequest_DataSource) GetName 

func (x *UpdateDataSourceRequest_DataSource) GetName() string

func (*UpdateDataSourceRequest_DataSource) GetType 

func (x *UpdateDataSourceRequest_DataSource) GetType() enums.Datasource_Type

func (*UpdateDataSourceRequest_DataSource) ProtoMessage 

func (*UpdateDataSourceRequest_DataSource) ProtoMessage()

func (*UpdateDataSourceRequest_DataSource) ProtoReflect 

func (x *UpdateDataSourceRequest_DataSource) ProtoReflect() protoreflect.Message

func (*UpdateDataSourceRequest_DataSource) Reset 

func (x *UpdateDataSourceRequest_DataSource) Reset()

func (*UpdateDataSourceRequest_DataSource) String 

func (x *UpdateDataSourceRequest_DataSource) String() string

type UpdateDataSourceResponse 

type UpdateDataSourceResponse struct {
	Response []*UpdateDataSourceResponse_DatasourceRes `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDataSourceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateDataSourceResponse.ProtoReflect.Descriptor instead.

func (*UpdateDataSourceResponse) GetResponse 

func (x *UpdateDataSourceResponse) GetResponse() []*UpdateDataSourceResponse_DatasourceRes

func (*UpdateDataSourceResponse) ProtoMessage 

func (*UpdateDataSourceResponse) ProtoMessage()

func (*UpdateDataSourceResponse) ProtoReflect 

func (x *UpdateDataSourceResponse) ProtoReflect() protoreflect.Message

func (*UpdateDataSourceResponse) Reset 

func (x *UpdateDataSourceResponse) Reset()

func (*UpdateDataSourceResponse) String 

func (x *UpdateDataSourceResponse) String() string

type UpdateDataSourceResponse_DatasourceRes 

type UpdateDataSourceResponse_DatasourceRes struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

return successfully updated/created DataSource ID/Name List

func (*UpdateDataSourceResponse_DatasourceRes) Descriptor deprecated 

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

Deprecated: Use UpdateDataSourceResponse_DatasourceRes.ProtoReflect.Descriptor instead.

func (*UpdateDataSourceResponse_DatasourceRes) GetId 

func (x *UpdateDataSourceResponse_DatasourceRes) GetId() uint64

func (*UpdateDataSourceResponse_DatasourceRes) GetName 

func (x *UpdateDataSourceResponse_DatasourceRes) GetName() string

func (*UpdateDataSourceResponse_DatasourceRes) ProtoMessage 

func (*UpdateDataSourceResponse_DatasourceRes) ProtoMessage()

func (*UpdateDataSourceResponse_DatasourceRes) ProtoReflect 

func (x *UpdateDataSourceResponse_DatasourceRes) ProtoReflect() protoreflect.Message

func (*UpdateDataSourceResponse_DatasourceRes) Reset 

func (x *UpdateDataSourceResponse_DatasourceRes) Reset()

func (*UpdateDataSourceResponse_DatasourceRes) String 

func (x *UpdateDataSourceResponse_DatasourceRes) String() string

type UpdateMachineStatusRequest 

type UpdateMachineStatusRequest struct {
	OperatorId uint64                 `protobuf:"varint,1,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	Status     OperatorMachine_Status `protobuf:"varint,2,opt,name=status,proto3,enum=sudo.protobuf.infra_adapter.OperatorMachine_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMachineStatusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateMachineStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateMachineStatusRequest) GetOperatorId 

func (x *UpdateMachineStatusRequest) GetOperatorId() uint64

func (*UpdateMachineStatusRequest) GetStatus 

func (x *UpdateMachineStatusRequest) GetStatus() OperatorMachine_Status

func (*UpdateMachineStatusRequest) ProtoMessage 

func (*UpdateMachineStatusRequest) ProtoMessage()

func (*UpdateMachineStatusRequest) ProtoReflect 

func (x *UpdateMachineStatusRequest) ProtoReflect() protoreflect.Message

func (*UpdateMachineStatusRequest) Reset 

func (x *UpdateMachineStatusRequest) Reset()

func (*UpdateMachineStatusRequest) String 

func (x *UpdateMachineStatusRequest) String() string

type UpdateOperatorSchemasRequest 

type UpdateOperatorSchemasRequest struct {
	Operators []*OperatorSchema `protobuf:"bytes,1,rep,name=operators,proto3" json:"operators,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateOperatorSchemasRequest) Descriptor deprecated 

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

Deprecated: Use UpdateOperatorSchemasRequest.ProtoReflect.Descriptor instead.

func (*UpdateOperatorSchemasRequest) GetOperators 

func (x *UpdateOperatorSchemasRequest) GetOperators() []*OperatorSchema

func (*UpdateOperatorSchemasRequest) ProtoMessage 

func (*UpdateOperatorSchemasRequest) ProtoMessage()

func (*UpdateOperatorSchemasRequest) ProtoReflect 

func (x *UpdateOperatorSchemasRequest) ProtoReflect() protoreflect.Message

func (*UpdateOperatorSchemasRequest) Reset 

func (x *UpdateOperatorSchemasRequest) Reset()

func (*UpdateOperatorSchemasRequest) String 

func (x *UpdateOperatorSchemasRequest) String() string

type UpdateProgressRequest 

type UpdateProgressRequest struct {
	Id       *BlockID                       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Progress string                         `protobuf:"bytes,2,opt,name=progress,proto3" json:"progress,omitempty"`
	UsedTime uint64                         `protobuf:"varint,3,opt,name=used_time,json=usedTime,proto3" json:"used_time,omitempty"` // Deprecated
	Category UpdateProgressRequest_Category ``                                                                                       /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateProgressRequest) Descriptor deprecated 

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

Deprecated: Use UpdateProgressRequest.ProtoReflect.Descriptor instead.

func (*UpdateProgressRequest) GetCategory 

func (x *UpdateProgressRequest) GetCategory() UpdateProgressRequest_Category

func (*UpdateProgressRequest) GetId 

func (x *UpdateProgressRequest) GetId() *BlockID

func (*UpdateProgressRequest) GetProgress 

func (x *UpdateProgressRequest) GetProgress() string

func (*UpdateProgressRequest) GetUsedTime 

func (x *UpdateProgressRequest) GetUsedTime() uint64

func (*UpdateProgressRequest) ProtoMessage 

func (*UpdateProgressRequest) ProtoMessage()

func (*UpdateProgressRequest) ProtoReflect 

func (x *UpdateProgressRequest) ProtoReflect() protoreflect.Message

func (*UpdateProgressRequest) Reset 

func (x *UpdateProgressRequest) Reset()

func (*UpdateProgressRequest) String 

func (x *UpdateProgressRequest) String() string

type UpdateProgressRequest_Category 

type UpdateProgressRequest_Category int32
const (
	UpdateProgressRequest_GENERAL     UpdateProgressRequest_Category = 0
	UpdateProgressRequest_INPUT       UpdateProgressRequest_Category = 1
	UpdateProgressRequest_OUTPUT      UpdateProgressRequest_Category = 2
	UpdateProgressRequest_COMPUTATION UpdateProgressRequest_Category = 3
	UpdateProgressRequest_ERROR       UpdateProgressRequest_Category = 4
)

func (UpdateProgressRequest_Category) Descriptor 

func (UpdateProgressRequest_Category) Descriptor() protoreflect.EnumDescriptor

func (UpdateProgressRequest_Category) Enum 

func (x UpdateProgressRequest_Category) Enum() *UpdateProgressRequest_Category

func (UpdateProgressRequest_Category) EnumDescriptor deprecated 

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

Deprecated: Use UpdateProgressRequest_Category.Descriptor instead.

func (UpdateProgressRequest_Category) Number 

func (x UpdateProgressRequest_Category) Number() protoreflect.EnumNumber

func (UpdateProgressRequest_Category) String 

func (x UpdateProgressRequest_Category) String() string

func (UpdateProgressRequest_Category) Type 

func (UpdateProgressRequest_Category) Type() protoreflect.EnumType

type Version 

type Version struct {
	Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	Patch uint32 `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"`
	// contains filtered or unexported fields
}

func (*Version) Descriptor deprecated 

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetMajor 

func (x *Version) GetMajor() uint32

func (*Version) GetMinor 

func (x *Version) GetMinor() uint32

func (*Version) GetPatch 

func (x *Version) GetPatch() uint32

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

type WalkDirRequest 

type WalkDirRequest struct {
	DatasourceName string `protobuf:"bytes,1,opt,name=datasource_name,json=datasourceName,proto3" json:"datasource_name,omitempty"`
	// 文件路径
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*WalkDirRequest) Descriptor deprecated 

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

Deprecated: Use WalkDirRequest.ProtoReflect.Descriptor instead.

func (*WalkDirRequest) GetDatasourceName 

func (x *WalkDirRequest) GetDatasourceName() string

func (*WalkDirRequest) GetPath 

func (x *WalkDirRequest) GetPath() string

func (*WalkDirRequest) ProtoMessage 

func (*WalkDirRequest) ProtoMessage()

func (*WalkDirRequest) ProtoReflect 

func (x *WalkDirRequest) ProtoReflect() protoreflect.Message

func (*WalkDirRequest) Reset 

func (x *WalkDirRequest) Reset()

func (*WalkDirRequest) String 

func (x *WalkDirRequest) String() string

type WalkDirResponse 

type WalkDirResponse struct {

	// 元数据信息
	Nodes []*WalkDirResponse_NodeMetaInfo `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*WalkDirResponse) Descriptor deprecated 

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

Deprecated: Use WalkDirResponse.ProtoReflect.Descriptor instead.

func (*WalkDirResponse) GetNodes 

func (x *WalkDirResponse) GetNodes() []*WalkDirResponse_NodeMetaInfo

func (*WalkDirResponse) ProtoMessage 

func (*WalkDirResponse) ProtoMessage()

func (*WalkDirResponse) ProtoReflect 

func (x *WalkDirResponse) ProtoReflect() protoreflect.Message

func (*WalkDirResponse) Reset 

func (x *WalkDirResponse) Reset()

func (*WalkDirResponse) String 

func (x *WalkDirResponse) String() string

type WalkDirResponse_NodeMetaInfo 

type WalkDirResponse_NodeMetaInfo struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IsDir bool   `protobuf:"varint,2,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// 文件大小，单位为字节。
	Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// 10位数Unix时间戳
	LastModified uint64 `protobuf:"varint,4,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	// contains filtered or unexported fields
}

func (*WalkDirResponse_NodeMetaInfo) Descriptor deprecated 

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

Deprecated: Use WalkDirResponse_NodeMetaInfo.ProtoReflect.Descriptor instead.

func (*WalkDirResponse_NodeMetaInfo) GetIsDir 

func (x *WalkDirResponse_NodeMetaInfo) GetIsDir() bool

func (*WalkDirResponse_NodeMetaInfo) GetLastModified 

func (x *WalkDirResponse_NodeMetaInfo) GetLastModified() uint64

func (*WalkDirResponse_NodeMetaInfo) GetName 

func (x *WalkDirResponse_NodeMetaInfo) GetName() string

func (*WalkDirResponse_NodeMetaInfo) GetSize 

func (x *WalkDirResponse_NodeMetaInfo) GetSize() uint64

func (*WalkDirResponse_NodeMetaInfo) ProtoMessage 

func (*WalkDirResponse_NodeMetaInfo) ProtoMessage()

func (*WalkDirResponse_NodeMetaInfo) ProtoReflect 

func (x *WalkDirResponse_NodeMetaInfo) ProtoReflect() protoreflect.Message

func (*WalkDirResponse_NodeMetaInfo) Reset 

func (x *WalkDirResponse_NodeMetaInfo) Reset()

func (*WalkDirResponse_NodeMetaInfo) String 

func (x *WalkDirResponse_NodeMetaInfo) String() string

Source Files

View all Source files

Directories

Path Synopsis
enums
virtualservice
platformpb/apl
platformpb/datasource
platformpb/jwt
platformpb/misc
platformpb/online_service
platformpb/options
platformpb/paginator
platformpb/party
platformpb/pir
platformpb/resource
platformpb/service/common
platformpb/service/coordinator
platformpb/service/furnace
platformpb/task
platformpb/token
platformpb/user
platformpb/vtable

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.