interconn

package
v0.0.0-...-3388463 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2024 License: Apache-2.0 Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_kuscia_proto_api_v1_interconn_common_proto protoreflect.FileDescriptor
View Source 
var File_kuscia_proto_api_v1_interconn_job_proto protoreflect.FileDescriptor
View Source 
var File_kuscia_proto_api_v1_interconn_task_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CommonResponse 

type CommonResponse struct {
	Code int32            `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string           `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Data *structpb.Struct `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

CommonResponse defines the response for request.

func (*CommonResponse) Descriptor deprecated 

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

Deprecated: Use CommonResponse.ProtoReflect.Descriptor instead.

func (*CommonResponse) GetCode 

func (x *CommonResponse) GetCode() int32

func (*CommonResponse) GetData 

func (x *CommonResponse) GetData() *structpb.Struct

func (*CommonResponse) GetMsg 

func (x *CommonResponse) GetMsg() string

func (*CommonResponse) ProtoMessage 

func (*CommonResponse) ProtoMessage()

func (*CommonResponse) ProtoReflect 

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

func (*CommonResponse) Reset 

func (x *CommonResponse) Reset()

func (*CommonResponse) String 

func (x *CommonResponse) String() string

type Component 

type Component struct {
	Code       string         `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Name       string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ModuleName string         `protobuf:"bytes,3,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	Version    string         `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Input      []*ComponentIO `protobuf:"bytes,5,rep,name=input,proto3" json:"input,omitempty"`
	Output     []*ComponentIO `protobuf:"bytes,6,rep,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

Component represents functional module units for independently computing privacy-preserving tasks.

func (*Component) Descriptor deprecated 

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

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetCode 

func (x *Component) GetCode() string

func (*Component) GetInput 

func (x *Component) GetInput() []*ComponentIO

func (*Component) GetModuleName 

func (x *Component) GetModuleName() string

func (*Component) GetName 

func (x *Component) GetName() string

func (*Component) GetOutput 

func (x *Component) GetOutput() []*ComponentIO

func (*Component) GetVersion 

func (x *Component) GetVersion() string

func (*Component) ProtoMessage 

func (*Component) ProtoMessage()

func (*Component) ProtoReflect 

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

func (*Component) Reset 

func (x *Component) Reset()

func (*Component) String 

func (x *Component) String() string

type ComponentIO 

type ComponentIO struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

ComponentIO defines input and output of component.

func (*ComponentIO) Descriptor deprecated 

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

Deprecated: Use ComponentIO.ProtoReflect.Descriptor instead.

func (*ComponentIO) GetKey 

func (x *ComponentIO) GetKey() string

func (*ComponentIO) GetType 

func (x *ComponentIO) GetType() string

func (*ComponentIO) ProtoMessage 

func (*ComponentIO) ProtoMessage()

func (*ComponentIO) ProtoReflect 

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

func (*ComponentIO) Reset 

func (x *ComponentIO) Reset()

func (*ComponentIO) String 

func (x *ComponentIO) String() string

type Config 

type Config struct {
	Role       *ConfigRole      `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	Initiator  *ConfigInitiator `protobuf:"bytes,2,opt,name=initiator,proto3" json:"initiator,omitempty"`
	JobParams  *ConfigParams    `protobuf:"bytes,3,opt,name=job_params,json=jobParams,proto3" json:"job_params,omitempty"`
	TaskParams *ConfigParams    `protobuf:"bytes,4,opt,name=task_params,json=taskParams,proto3" json:"task_params,omitempty"`
	Version    string           `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Config defines parameter configuration for each component, etc.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetInitiator 

func (x *Config) GetInitiator() *ConfigInitiator

func (*Config) GetJobParams 

func (x *Config) GetJobParams() *ConfigParams

func (*Config) GetRole 

func (x *Config) GetRole() *ConfigRole

func (*Config) GetTaskParams 

func (x *Config) GetTaskParams() *ConfigParams

func (*Config) GetVersion 

func (x *Config) GetVersion() string

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type ConfigInitiator 

type ConfigInitiator struct {
	Role   string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

ConfigInitiator defines config initiator information.

func (*ConfigInitiator) Descriptor deprecated 

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

Deprecated: Use ConfigInitiator.ProtoReflect.Descriptor instead.

func (*ConfigInitiator) GetNodeId 

func (x *ConfigInitiator) GetNodeId() string

func (*ConfigInitiator) GetRole 

func (x *ConfigInitiator) GetRole() string

func (*ConfigInitiator) ProtoMessage 

func (*ConfigInitiator) ProtoMessage()

func (*ConfigInitiator) ProtoReflect 

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

func (*ConfigInitiator) Reset 

func (x *ConfigInitiator) Reset()

func (*ConfigInitiator) String 

func (x *ConfigInitiator) String() string

type ConfigParams 

type ConfigParams struct {
	Host    *structpb.Struct `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Arbiter *structpb.Struct `protobuf:"bytes,2,opt,name=arbiter,proto3" json:"arbiter,omitempty"`
	Guest   *structpb.Struct `protobuf:"bytes,3,opt,name=guest,proto3" json:"guest,omitempty"`
	Common  *structpb.Struct `protobuf:"bytes,4,opt,name=common,proto3" json:"common,omitempty"`
	// contains filtered or unexported fields
}

ConfigInitiator defines config params information.

func (*ConfigParams) Descriptor deprecated 

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

Deprecated: Use ConfigParams.ProtoReflect.Descriptor instead.

func (*ConfigParams) GetArbiter 

func (x *ConfigParams) GetArbiter() *structpb.Struct

func (*ConfigParams) GetCommon 

func (x *ConfigParams) GetCommon() *structpb.Struct

func (*ConfigParams) GetGuest 

func (x *ConfigParams) GetGuest() *structpb.Struct

func (*ConfigParams) GetHost 

func (x *ConfigParams) GetHost() *structpb.Struct

func (*ConfigParams) ProtoMessage 

func (*ConfigParams) ProtoMessage()

func (*ConfigParams) ProtoReflect 

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

func (*ConfigParams) Reset 

func (x *ConfigParams) Reset()

func (*ConfigParams) String 

func (x *ConfigParams) String() string

type ConfigResources 

type ConfigResources struct {
	Disk   int32 `protobuf:"varint,1,opt,name=disk,proto3" json:"disk,omitempty"`
	Memory int32 `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"`
	Cpu    int32 `protobuf:"varint,3,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// contains filtered or unexported fields
}

ConfigInitiator defines config Resources information.

func (*ConfigResources) Descriptor deprecated 

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

Deprecated: Use ConfigResources.ProtoReflect.Descriptor instead.

func (*ConfigResources) GetCpu 

func (x *ConfigResources) GetCpu() int32

func (*ConfigResources) GetDisk 

func (x *ConfigResources) GetDisk() int32

func (*ConfigResources) GetMemory 

func (x *ConfigResources) GetMemory() int32

func (*ConfigResources) ProtoMessage 

func (*ConfigResources) ProtoMessage()

func (*ConfigResources) ProtoReflect 

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

func (*ConfigResources) Reset 

func (x *ConfigResources) Reset()

func (*ConfigResources) String 

func (x *ConfigResources) String() string

type ConfigRole 

type ConfigRole struct {
	Arbiter []string `protobuf:"bytes,1,rep,name=arbiter,proto3" json:"arbiter,omitempty"`
	Host    []string `protobuf:"bytes,2,rep,name=host,proto3" json:"host,omitempty"`
	Guest   []string `protobuf:"bytes,3,rep,name=guest,proto3" json:"guest,omitempty"`
	// contains filtered or unexported fields
}

ConfigInitiator defines config role information.

func (*ConfigRole) Descriptor deprecated 

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

Deprecated: Use ConfigRole.ProtoReflect.Descriptor instead.

func (*ConfigRole) GetArbiter 

func (x *ConfigRole) GetArbiter() []string

func (*ConfigRole) GetGuest 

func (x *ConfigRole) GetGuest() []string

func (*ConfigRole) GetHost 

func (x *ConfigRole) GetHost() []string

func (*ConfigRole) ProtoMessage 

func (*ConfigRole) ProtoMessage()

func (*ConfigRole) ProtoReflect 

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

func (*ConfigRole) Reset 

func (x *ConfigRole) Reset()

func (*ConfigRole) String 

func (x *ConfigRole) String() string

type CreateJobAllRequest 

type CreateJobAllRequest struct {
	JobId  string  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	FlowId string  `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Dag    *DAG    `protobuf:"bytes,3,opt,name=dag,proto3" json:"dag,omitempty"`
	Config *Config `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

CreateJobAllRequest defines the request for creating job all.

func (*CreateJobAllRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobAllRequest.ProtoReflect.Descriptor instead.

func (*CreateJobAllRequest) GetConfig 

func (x *CreateJobAllRequest) GetConfig() *Config

func (*CreateJobAllRequest) GetDag 

func (x *CreateJobAllRequest) GetDag() *DAG

func (*CreateJobAllRequest) GetFlowId 

func (x *CreateJobAllRequest) GetFlowId() string

func (*CreateJobAllRequest) GetJobId 

func (x *CreateJobAllRequest) GetJobId() string

func (*CreateJobAllRequest) ProtoMessage 

func (*CreateJobAllRequest) ProtoMessage()

func (*CreateJobAllRequest) ProtoReflect 

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

func (*CreateJobAllRequest) Reset 

func (x *CreateJobAllRequest) Reset()

func (*CreateJobAllRequest) String 

func (x *CreateJobAllRequest) String() string

type CreateJobRequest 

type CreateJobRequest struct {
	JobId  string  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	FlowId string  `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Dag    *DAG    `protobuf:"bytes,3,opt,name=dag,proto3" json:"dag,omitempty"`
	Config *Config `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

CreateJobRequest defines the request for creating job.

func (*CreateJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetConfig 

func (x *CreateJobRequest) GetConfig() *Config

func (*CreateJobRequest) GetDag 

func (x *CreateJobRequest) GetDag() *DAG

func (*CreateJobRequest) GetFlowId 

func (x *CreateJobRequest) GetFlowId() string

func (*CreateJobRequest) GetJobId 

func (x *CreateJobRequest) GetJobId() string

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect 

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

func (*CreateJobRequest) Reset 

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (x *CreateJobRequest) String() string

type DAG 

type DAG struct {
	Version    string       `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Components []*Component `protobuf:"bytes,2,rep,name=components,proto3" json:"components,omitempty"`
	// contains filtered or unexported fields
}

DAG represents direct Acyclic Graph which is used to describe dependencies between components.

func (*DAG) Descriptor deprecated 

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

Deprecated: Use DAG.ProtoReflect.Descriptor instead.

func (*DAG) GetComponents 

func (x *DAG) GetComponents() []*Component

func (*DAG) GetVersion 

func (x *DAG) GetVersion() string

func (*DAG) ProtoMessage 

func (*DAG) ProtoMessage()

func (*DAG) ProtoReflect 

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

func (*DAG) Reset 

func (x *DAG) Reset()

func (*DAG) String 

func (x *DAG) String() string

type PollTaskStatusRequest 

type PollTaskStatusRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Role   string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

PollTaskStatusRequest defines the request for polling task status.

func (*PollTaskStatusRequest) Descriptor deprecated 

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

Deprecated: Use PollTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*PollTaskStatusRequest) GetRole 

func (x *PollTaskStatusRequest) GetRole() string

func (*PollTaskStatusRequest) GetTaskId 

func (x *PollTaskStatusRequest) GetTaskId() string

func (*PollTaskStatusRequest) ProtoMessage 

func (*PollTaskStatusRequest) ProtoMessage()

func (*PollTaskStatusRequest) ProtoReflect 

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

func (*PollTaskStatusRequest) Reset 

func (x *PollTaskStatusRequest) Reset()

func (*PollTaskStatusRequest) String 

func (x *PollTaskStatusRequest) String() string

type PushTaskStatusRequest 

type PushTaskStatusRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Role   string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// Possible values include Pending,RUNNING,SUCCESS,FAILED
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*PushTaskStatusRequest) Descriptor deprecated 

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

Deprecated: Use PushTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*PushTaskStatusRequest) GetRole 

func (x *PushTaskStatusRequest) GetRole() string

func (*PushTaskStatusRequest) GetStatus 

func (x *PushTaskStatusRequest) GetStatus() string

func (*PushTaskStatusRequest) GetTaskId 

func (x *PushTaskStatusRequest) GetTaskId() string

func (*PushTaskStatusRequest) ProtoMessage 

func (*PushTaskStatusRequest) ProtoMessage()

func (*PushTaskStatusRequest) ProtoReflect 

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

func (*PushTaskStatusRequest) Reset 

func (x *PushTaskStatusRequest) Reset()

func (*PushTaskStatusRequest) String 

func (x *PushTaskStatusRequest) String() string

type QueryJobStatusAllRequest 

type QueryJobStatusAllRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

QueryJobStatusAllRequest defines the request for querying job all status.

func (*QueryJobStatusAllRequest) Descriptor deprecated 

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

Deprecated: Use QueryJobStatusAllRequest.ProtoReflect.Descriptor instead.

func (*QueryJobStatusAllRequest) GetJobId 

func (x *QueryJobStatusAllRequest) GetJobId() string

func (*QueryJobStatusAllRequest) ProtoMessage 

func (*QueryJobStatusAllRequest) ProtoMessage()

func (*QueryJobStatusAllRequest) ProtoReflect 

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

func (*QueryJobStatusAllRequest) Reset 

func (x *QueryJobStatusAllRequest) Reset()

func (*QueryJobStatusAllRequest) String 

func (x *QueryJobStatusAllRequest) String() string

type StartJobRequest 

type StartJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

StartJobRequest defines the request for starting job.

func (*StartJobRequest) Descriptor deprecated 

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

Deprecated: Use StartJobRequest.ProtoReflect.Descriptor instead.

func (*StartJobRequest) GetJobId 

func (x *StartJobRequest) GetJobId() string

func (*StartJobRequest) ProtoMessage 

func (*StartJobRequest) ProtoMessage()

func (*StartJobRequest) ProtoReflect 

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

func (*StartJobRequest) Reset 

func (x *StartJobRequest) Reset()

func (*StartJobRequest) String 

func (x *StartJobRequest) String() string

type StartTaskRequest 

type StartTaskRequest struct {
	TaskId   string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	JobId    string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	TaskName string `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// contains filtered or unexported fields
}

StartTaskRequest defines the request for starting task.

func (*StartTaskRequest) Descriptor deprecated 

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

Deprecated: Use StartTaskRequest.ProtoReflect.Descriptor instead.

func (*StartTaskRequest) GetJobId 

func (x *StartTaskRequest) GetJobId() string

func (*StartTaskRequest) GetTaskId 

func (x *StartTaskRequest) GetTaskId() string

func (*StartTaskRequest) GetTaskName 

func (x *StartTaskRequest) GetTaskName() string

func (*StartTaskRequest) ProtoMessage 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) ProtoReflect 

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

func (*StartTaskRequest) Reset 

func (x *StartTaskRequest) Reset()

func (*StartTaskRequest) String 

func (x *StartTaskRequest) String() string

type StopJobAllRequest 

type StopJobAllRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

StopJobAllRequest defines the request for stopping job all.

func (*StopJobAllRequest) Descriptor deprecated 

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

Deprecated: Use StopJobAllRequest.ProtoReflect.Descriptor instead.

func (*StopJobAllRequest) GetJobId 

func (x *StopJobAllRequest) GetJobId() string

func (*StopJobAllRequest) ProtoMessage 

func (*StopJobAllRequest) ProtoMessage()

func (*StopJobAllRequest) ProtoReflect 

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

func (*StopJobAllRequest) Reset 

func (x *StopJobAllRequest) Reset()

func (*StopJobAllRequest) String 

func (x *StopJobAllRequest) String() string

type StopJobRequest 

type StopJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

StopJobRequest defines the request for stopping job.

func (*StopJobRequest) Descriptor deprecated 

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

Deprecated: Use StopJobRequest.ProtoReflect.Descriptor instead.

func (*StopJobRequest) GetJobId 

func (x *StopJobRequest) GetJobId() string

func (*StopJobRequest) ProtoMessage 

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) ProtoReflect 

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

func (*StopJobRequest) Reset 

func (x *StopJobRequest) Reset()

func (*StopJobRequest) String 

func (x *StopJobRequest) String() string

type StopTaskRequest 

type StopTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

StartTaskRequest defines the request for stopping task.

func (*StopTaskRequest) Descriptor deprecated 

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

Deprecated: Use StopTaskRequest.ProtoReflect.Descriptor instead.

func (*StopTaskRequest) GetTaskId 

func (x *StopTaskRequest) GetTaskId() string

func (*StopTaskRequest) ProtoMessage 

func (*StopTaskRequest) ProtoMessage()

func (*StopTaskRequest) ProtoReflect 

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

func (*StopTaskRequest) Reset 

func (x *StopTaskRequest) Reset()

func (*StopTaskRequest) String 

func (x *StopTaskRequest) String() string

type TaskInputConfig 

type TaskInputConfig struct {

	// Component name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Module name of component
	ModuleName string `protobuf:"bytes,2,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	// Input of component
	Input []*ComponentIO `protobuf:"bytes,3,rep,name=input,proto3" json:"input,omitempty"`
	// Output of component
	Output []*ComponentIO `protobuf:"bytes,4,rep,name=output,proto3" json:"output,omitempty"`
	// Role of task
	Role *ConfigRole `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"`
	// Initiator of task
	Initiator *ConfigInitiator `protobuf:"bytes,6,opt,name=initiator,proto3" json:"initiator,omitempty"`
	// Parameters of task
	TaskParams *ConfigParams `protobuf:"bytes,7,opt,name=task_params,json=taskParams,proto3" json:"task_params,omitempty"`
	// contains filtered or unexported fields
}

TaskInputConfig defines task input config info.

func (*TaskInputConfig) Descriptor deprecated 

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

Deprecated: Use TaskInputConfig.ProtoReflect.Descriptor instead.

func (*TaskInputConfig) GetInitiator 

func (x *TaskInputConfig) GetInitiator() *ConfigInitiator

func (*TaskInputConfig) GetInput 

func (x *TaskInputConfig) GetInput() []*ComponentIO

func (*TaskInputConfig) GetModuleName 

func (x *TaskInputConfig) GetModuleName() string

func (*TaskInputConfig) GetName 

func (x *TaskInputConfig) GetName() string

func (*TaskInputConfig) GetOutput 

func (x *TaskInputConfig) GetOutput() []*ComponentIO

func (*TaskInputConfig) GetRole 

func (x *TaskInputConfig) GetRole() *ConfigRole

func (*TaskInputConfig) GetTaskParams 

func (x *TaskInputConfig) GetTaskParams() *ConfigParams

func (*TaskInputConfig) ProtoMessage 

func (*TaskInputConfig) ProtoMessage()

func (*TaskInputConfig) ProtoReflect 

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

func (*TaskInputConfig) Reset 

func (x *TaskInputConfig) Reset()

func (*TaskInputConfig) String 

func (x *TaskInputConfig) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.