v1

package
v0.0.0-...-094827e Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2024 License: MIT Imports: 10 Imported by: 3

Documentation

Index

Constants

View Source
const (
	Executor_Introspect_FullMethodName = "/executor.knita.io.Executor/Introspect"
	Executor_Events_FullMethodName     = "/executor.knita.io.Executor/Events"
	Executor_Open_FullMethodName       = "/executor.knita.io.Executor/Open"
	Executor_Heartbeat_FullMethodName  = "/executor.knita.io.Executor/Heartbeat"
	Executor_Exec_FullMethodName       = "/executor.knita.io.Executor/Exec"
	Executor_Import_FullMethodName     = "/executor.knita.io.Executor/Import"
	Executor_Export_FullMethodName     = "/executor.knita.io.Executor/Export"
	Executor_Close_FullMethodName      = "/executor.knita.io.Executor/Close"
)

Variables

View Source
var (
	RuntimeType_name = map[int32]string{
		0: "RUNTIME_UNSPECIFIED",
		1: "RUNTIME_HOST",
		2: "RUNTIME_DOCKER",
	}
	RuntimeType_value = map[string]int32{
		"RUNTIME_UNSPECIFIED": 0,
		"RUNTIME_HOST":        1,
		"RUNTIME_DOCKER":      2,
	}
)

Enum value maps for RuntimeType.

View Source
var (
	DockerPullOpts_PullStrategy_name = map[int32]string{
		0: "PULL_STRATEGY_UNSPECIFIED",
		1: "PULL_STRATEGY_NEVER",
		2: "PULL_STRATEGY_ALWAYS",
		3: "PULL_STRATEGY_NOT_EXISTS",
	}
	DockerPullOpts_PullStrategy_value = map[string]int32{
		"PULL_STRATEGY_UNSPECIFIED": 0,
		"PULL_STRATEGY_NEVER":       1,
		"PULL_STRATEGY_ALWAYS":      2,
		"PULL_STRATEGY_NOT_EXISTS":  3,
	}
)

Enum value maps for DockerPullOpts_PullStrategy.

View Source
var Executor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "executor.knita.io.Executor",
	HandlerType: (*ExecutorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Introspect",
			Handler:    _Executor_Introspect_Handler,
		},
		{
			MethodName: "Open",
			Handler:    _Executor_Open_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Executor_Heartbeat_Handler,
		},
		{
			MethodName: "Exec",
			Handler:    _Executor_Exec_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Executor_Close_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _Executor_Events_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Import",
			Handler:       _Executor_Import_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Export",
			Handler:       _Executor_Export_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "executor/v1/executor.proto",
}

Executor_ServiceDesc is the grpc.ServiceDesc for Executor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_executor_v1_executor_proto protoreflect.FileDescriptor

Functions

func RegisterExecutorServer

func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)

Types

type AWSECRAuth

type AWSECRAuth struct {
	Region         string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	AwsAccessKeyId string `protobuf:"bytes,2,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretKey   string `protobuf:"bytes,3,opt,name=aws_secret_key,json=awsSecretKey,proto3" json:"aws_secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*AWSECRAuth) Descriptor deprecated

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

Deprecated: Use AWSECRAuth.ProtoReflect.Descriptor instead.

func (*AWSECRAuth) GetAwsAccessKeyId

func (x *AWSECRAuth) GetAwsAccessKeyId() string

func (*AWSECRAuth) GetAwsSecretKey

func (x *AWSECRAuth) GetAwsSecretKey() string

func (*AWSECRAuth) GetRegion

func (x *AWSECRAuth) GetRegion() string

func (*AWSECRAuth) ProtoMessage

func (*AWSECRAuth) ProtoMessage()

func (*AWSECRAuth) ProtoReflect

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

func (*AWSECRAuth) Reset

func (x *AWSECRAuth) Reset()

func (*AWSECRAuth) String

func (x *AWSECRAuth) String() string

type BasicAuth

type BasicAuth struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*BasicAuth) Descriptor deprecated

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

Deprecated: Use BasicAuth.ProtoReflect.Descriptor instead.

func (*BasicAuth) GetPassword

func (x *BasicAuth) GetPassword() string

func (*BasicAuth) GetUsername

func (x *BasicAuth) GetUsername() string

func (*BasicAuth) ProtoMessage

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) ProtoReflect

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

func (*BasicAuth) Reset

func (x *BasicAuth) Reset()

func (*BasicAuth) String

func (x *BasicAuth) String() string

type CloseRequest

type CloseRequest struct {
	RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	BarrierId string `protobuf:"bytes,2,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetBarrierId

func (x *CloseRequest) GetBarrierId() string

func (*CloseRequest) GetRuntimeId

func (x *CloseRequest) GetRuntimeId() string

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect

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

func (*CloseRequest) Reset

func (x *CloseRequest) Reset()

func (*CloseRequest) String

func (x *CloseRequest) String() string

type CloseResponse

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

func (*CloseResponse) Descriptor deprecated

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect

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

func (*CloseResponse) Reset

func (x *CloseResponse) Reset()

func (*CloseResponse) String

func (x *CloseResponse) String() string

type DockerOpts

type DockerOpts struct {
	Image *DockerPullOpts `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

func (*DockerOpts) Descriptor deprecated

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

Deprecated: Use DockerOpts.ProtoReflect.Descriptor instead.

func (*DockerOpts) GetImage

func (x *DockerOpts) GetImage() *DockerPullOpts

func (*DockerOpts) ProtoMessage

func (*DockerOpts) ProtoMessage()

func (*DockerOpts) ProtoReflect

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

func (*DockerOpts) Reset

func (x *DockerOpts) Reset()

func (*DockerOpts) String

func (x *DockerOpts) String() string

type DockerPullAuth

type DockerPullAuth struct {

	// Types that are assignable to Auth:
	//
	//	*DockerPullAuth_Basic
	//	*DockerPullAuth_AwsEcr
	Auth isDockerPullAuth_Auth `protobuf_oneof:"auth"`
	// contains filtered or unexported fields
}

func (*DockerPullAuth) Descriptor deprecated

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

Deprecated: Use DockerPullAuth.ProtoReflect.Descriptor instead.

func (*DockerPullAuth) GetAuth

func (m *DockerPullAuth) GetAuth() isDockerPullAuth_Auth

func (*DockerPullAuth) GetAwsEcr

func (x *DockerPullAuth) GetAwsEcr() *AWSECRAuth

func (*DockerPullAuth) GetBasic

func (x *DockerPullAuth) GetBasic() *BasicAuth

func (*DockerPullAuth) ProtoMessage

func (*DockerPullAuth) ProtoMessage()

func (*DockerPullAuth) ProtoReflect

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

func (*DockerPullAuth) Reset

func (x *DockerPullAuth) Reset()

func (*DockerPullAuth) String

func (x *DockerPullAuth) String() string

type DockerPullAuth_AwsEcr

type DockerPullAuth_AwsEcr struct {
	AwsEcr *AWSECRAuth `protobuf:"bytes,2,opt,name=aws_ecr,json=awsEcr,proto3,oneof"`
}

type DockerPullAuth_Basic

type DockerPullAuth_Basic struct {
	Basic *BasicAuth `protobuf:"bytes,1,opt,name=basic,proto3,oneof"`
}

type DockerPullOpts

type DockerPullOpts struct {
	ImageUri     string                      `protobuf:"bytes,1,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"`
	PullStrategy DockerPullOpts_PullStrategy `` /* 149-byte string literal not displayed */
	Auth         *DockerPullAuth             `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*DockerPullOpts) Descriptor deprecated

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

Deprecated: Use DockerPullOpts.ProtoReflect.Descriptor instead.

func (*DockerPullOpts) GetAuth

func (x *DockerPullOpts) GetAuth() *DockerPullAuth

func (*DockerPullOpts) GetImageUri

func (x *DockerPullOpts) GetImageUri() string

func (*DockerPullOpts) GetPullStrategy

func (x *DockerPullOpts) GetPullStrategy() DockerPullOpts_PullStrategy

func (*DockerPullOpts) ProtoMessage

func (*DockerPullOpts) ProtoMessage()

func (*DockerPullOpts) ProtoReflect

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

func (*DockerPullOpts) Reset

func (x *DockerPullOpts) Reset()

func (*DockerPullOpts) String

func (x *DockerPullOpts) String() string

type DockerPullOpts_PullStrategy

type DockerPullOpts_PullStrategy int32
const (
	DockerPullOpts_PULL_STRATEGY_UNSPECIFIED DockerPullOpts_PullStrategy = 0
	DockerPullOpts_PULL_STRATEGY_NEVER       DockerPullOpts_PullStrategy = 1
	DockerPullOpts_PULL_STRATEGY_ALWAYS      DockerPullOpts_PullStrategy = 2
	DockerPullOpts_PULL_STRATEGY_NOT_EXISTS  DockerPullOpts_PullStrategy = 3
)

func (DockerPullOpts_PullStrategy) Descriptor

func (DockerPullOpts_PullStrategy) Enum

func (DockerPullOpts_PullStrategy) EnumDescriptor deprecated

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

Deprecated: Use DockerPullOpts_PullStrategy.Descriptor instead.

func (DockerPullOpts_PullStrategy) Number

func (DockerPullOpts_PullStrategy) String

func (DockerPullOpts_PullStrategy) Type

type EventsRequest

type EventsRequest struct {
	BuildId   string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	RuntimeId string `protobuf:"bytes,2,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	BarrierId string `protobuf:"bytes,3,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsRequest) Descriptor deprecated

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

Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.

func (*EventsRequest) GetBarrierId

func (x *EventsRequest) GetBarrierId() string

func (*EventsRequest) GetBuildId

func (x *EventsRequest) GetBuildId() string

func (*EventsRequest) GetRuntimeId

func (x *EventsRequest) GetRuntimeId() string

func (*EventsRequest) ProtoMessage

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) ProtoReflect

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

func (*EventsRequest) Reset

func (x *EventsRequest) Reset()

func (*EventsRequest) String

func (x *EventsRequest) String() string

type ExecOpts

type ExecOpts struct {
	Name string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args []string          `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Env  []string          `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"`
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecOpts) Descriptor deprecated

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

Deprecated: Use ExecOpts.ProtoReflect.Descriptor instead.

func (*ExecOpts) GetArgs

func (x *ExecOpts) GetArgs() []string

func (*ExecOpts) GetEnv

func (x *ExecOpts) GetEnv() []string

func (*ExecOpts) GetName

func (x *ExecOpts) GetName() string

func (*ExecOpts) GetTags

func (x *ExecOpts) GetTags() map[string]string

func (*ExecOpts) ProtoMessage

func (*ExecOpts) ProtoMessage()

func (*ExecOpts) ProtoReflect

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

func (*ExecOpts) Reset

func (x *ExecOpts) Reset()

func (*ExecOpts) String

func (x *ExecOpts) String() string

type ExecRequest

type ExecRequest struct {
	RuntimeId string    `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	ExecId    string    `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	BarrierId string    `protobuf:"bytes,3,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	Opts      *ExecOpts `protobuf:"bytes,4,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecRequest) Descriptor deprecated

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetBarrierId

func (x *ExecRequest) GetBarrierId() string

func (*ExecRequest) GetExecId

func (x *ExecRequest) GetExecId() string

func (*ExecRequest) GetOpts

func (x *ExecRequest) GetOpts() *ExecOpts

func (*ExecRequest) GetRuntimeId

func (x *ExecRequest) GetRuntimeId() string

func (*ExecRequest) ProtoMessage

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect

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

func (*ExecRequest) Reset

func (x *ExecRequest) Reset()

func (*ExecRequest) String

func (x *ExecRequest) String() string

type ExecResponse

type ExecResponse struct {
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetExitCode

func (x *ExecResponse) GetExitCode() int32

func (*ExecResponse) ProtoMessage

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) ProtoReflect

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

func (*ExecResponse) Reset

func (x *ExecResponse) Reset()

func (*ExecResponse) String

func (x *ExecResponse) String() string

type ExecutorClient

ExecutorClient is the client API for Executor service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutorClient

func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient

type ExecutorInfo

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

func (*ExecutorInfo) Descriptor deprecated

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

Deprecated: Use ExecutorInfo.ProtoReflect.Descriptor instead.

func (*ExecutorInfo) GetName

func (x *ExecutorInfo) GetName() string

func (*ExecutorInfo) ProtoMessage

func (*ExecutorInfo) ProtoMessage()

func (*ExecutorInfo) ProtoReflect

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

func (*ExecutorInfo) Reset

func (x *ExecutorInfo) Reset()

func (*ExecutorInfo) String

func (x *ExecutorInfo) String() string

type ExecutorServer

ExecutorServer is the server API for Executor service. All implementations must embed UnimplementedExecutorServer for forward compatibility

type Executor_EventsClient

type Executor_EventsClient interface {
	Recv() (*v1.Event, error)
	grpc.ClientStream
}

type Executor_EventsServer

type Executor_EventsServer interface {
	Send(*v1.Event) error
	grpc.ServerStream
}

type Executor_ExportClient

type Executor_ExportClient interface {
	Recv() (*FileTransfer, error)
	grpc.ClientStream
}

type Executor_ExportServer

type Executor_ExportServer interface {
	Send(*FileTransfer) error
	grpc.ServerStream
}

type Executor_ImportClient

type Executor_ImportClient interface {
	Send(*FileTransfer) error
	CloseAndRecv() (*ImportResponse, error)
	grpc.ClientStream
}

type Executor_ImportServer

type Executor_ImportServer interface {
	SendAndClose(*ImportResponse) error
	Recv() (*FileTransfer, error)
	grpc.ServerStream
}

type ExportOpts

type ExportOpts struct {
	DestPath string   `protobuf:"bytes,1,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"`
	Excludes []string `protobuf:"bytes,2,rep,name=excludes,proto3" json:"excludes,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportOpts) Descriptor deprecated

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

Deprecated: Use ExportOpts.ProtoReflect.Descriptor instead.

func (*ExportOpts) GetDestPath

func (x *ExportOpts) GetDestPath() string

func (*ExportOpts) GetExcludes

func (x *ExportOpts) GetExcludes() []string

func (*ExportOpts) ProtoMessage

func (*ExportOpts) ProtoMessage()

func (*ExportOpts) ProtoReflect

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

func (*ExportOpts) Reset

func (x *ExportOpts) Reset()

func (*ExportOpts) String

func (x *ExportOpts) String() string

type ExportRequest

type ExportRequest struct {
	RuntimeId string      `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	ExportId  string      `protobuf:"bytes,2,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	SrcPath   string      `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	Opts      *ExportOpts `protobuf:"bytes,4,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportRequest) Descriptor deprecated

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

Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.

func (*ExportRequest) GetExportId

func (x *ExportRequest) GetExportId() string

func (*ExportRequest) GetOpts

func (x *ExportRequest) GetOpts() *ExportOpts

func (*ExportRequest) GetRuntimeId

func (x *ExportRequest) GetRuntimeId() string

func (*ExportRequest) GetSrcPath

func (x *ExportRequest) GetSrcPath() string

func (*ExportRequest) ProtoMessage

func (*ExportRequest) ProtoMessage()

func (*ExportRequest) ProtoReflect

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

func (*ExportRequest) Reset

func (x *ExportRequest) Reset()

func (*ExportRequest) String

func (x *ExportRequest) String() string

type FileTransfer

type FileTransfer struct {
	RuntimeId  string               `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	TransferId string               `protobuf:"bytes,2,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	FileId     string               `protobuf:"bytes,3,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	Header     *FileTransferHeader  `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"`
	Body       *FileTransferBody    `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	Trailer    *FileTransferTrailer `protobuf:"bytes,6,opt,name=trailer,proto3" json:"trailer,omitempty"`
	// contains filtered or unexported fields
}

func (*FileTransfer) Descriptor deprecated

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

Deprecated: Use FileTransfer.ProtoReflect.Descriptor instead.

func (*FileTransfer) GetBody

func (x *FileTransfer) GetBody() *FileTransferBody

func (*FileTransfer) GetFileId

func (x *FileTransfer) GetFileId() string

func (*FileTransfer) GetHeader

func (x *FileTransfer) GetHeader() *FileTransferHeader

func (*FileTransfer) GetRuntimeId

func (x *FileTransfer) GetRuntimeId() string

func (*FileTransfer) GetTrailer

func (x *FileTransfer) GetTrailer() *FileTransferTrailer

func (*FileTransfer) GetTransferId

func (x *FileTransfer) GetTransferId() string

func (*FileTransfer) ProtoMessage

func (*FileTransfer) ProtoMessage()

func (*FileTransfer) ProtoReflect

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

func (*FileTransfer) Reset

func (x *FileTransfer) Reset()

func (*FileTransfer) String

func (x *FileTransfer) String() string

type FileTransferBody

type FileTransferBody struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*FileTransferBody) Descriptor deprecated

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

Deprecated: Use FileTransferBody.ProtoReflect.Descriptor instead.

func (*FileTransferBody) GetData

func (x *FileTransferBody) GetData() []byte

func (*FileTransferBody) GetOffset

func (x *FileTransferBody) GetOffset() uint64

func (*FileTransferBody) ProtoMessage

func (*FileTransferBody) ProtoMessage()

func (*FileTransferBody) ProtoReflect

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

func (*FileTransferBody) Reset

func (x *FileTransferBody) Reset()

func (*FileTransferBody) String

func (x *FileTransferBody) String() string

type FileTransferHeader

type FileTransferHeader struct {
	IsDir    bool   `protobuf:"varint,1,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	SrcPath  string `protobuf:"bytes,2,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DestPath string `protobuf:"bytes,3,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"`
	Mode     uint32 `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	Size     uint64 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*FileTransferHeader) Descriptor deprecated

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

Deprecated: Use FileTransferHeader.ProtoReflect.Descriptor instead.

func (*FileTransferHeader) GetDestPath

func (x *FileTransferHeader) GetDestPath() string

func (*FileTransferHeader) GetIsDir

func (x *FileTransferHeader) GetIsDir() bool

func (*FileTransferHeader) GetMode

func (x *FileTransferHeader) GetMode() uint32

func (*FileTransferHeader) GetSize

func (x *FileTransferHeader) GetSize() uint64

func (*FileTransferHeader) GetSrcPath

func (x *FileTransferHeader) GetSrcPath() string

func (*FileTransferHeader) ProtoMessage

func (*FileTransferHeader) ProtoMessage()

func (*FileTransferHeader) ProtoReflect

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

func (*FileTransferHeader) Reset

func (x *FileTransferHeader) Reset()

func (*FileTransferHeader) String

func (x *FileTransferHeader) String() string

type FileTransferTrailer

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

func (*FileTransferTrailer) Descriptor deprecated

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

Deprecated: Use FileTransferTrailer.ProtoReflect.Descriptor instead.

func (*FileTransferTrailer) GetMd5

func (x *FileTransferTrailer) GetMd5() []byte

func (*FileTransferTrailer) ProtoMessage

func (*FileTransferTrailer) ProtoMessage()

func (*FileTransferTrailer) ProtoReflect

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

func (*FileTransferTrailer) Reset

func (x *FileTransferTrailer) Reset()

func (*FileTransferTrailer) String

func (x *FileTransferTrailer) String() string

type HeartbeatRequest

type HeartbeatRequest struct {
	RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetRuntimeId

func (x *HeartbeatRequest) GetRuntimeId() string

func (*HeartbeatRequest) ProtoMessage

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect

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

func (*HeartbeatRequest) Reset

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String

func (x *HeartbeatRequest) String() string

type HeartbeatResponse

type HeartbeatResponse struct {
	ExtendedBy *durationpb.Duration `protobuf:"bytes,1,opt,name=extended_by,json=extendedBy,proto3" json:"extended_by,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetExtendedBy

func (x *HeartbeatResponse) GetExtendedBy() *durationpb.Duration

func (*HeartbeatResponse) ProtoMessage

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect

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

func (*HeartbeatResponse) Reset

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String

func (x *HeartbeatResponse) String() string

type HostOpts

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

func (*HostOpts) Descriptor deprecated

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

Deprecated: Use HostOpts.ProtoReflect.Descriptor instead.

func (*HostOpts) ProtoMessage

func (*HostOpts) ProtoMessage()

func (*HostOpts) ProtoReflect

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

func (*HostOpts) Reset

func (x *HostOpts) Reset()

func (*HostOpts) String

func (x *HostOpts) String() string

type ImportResponse

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

func (*ImportResponse) Descriptor deprecated

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

Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.

func (*ImportResponse) ProtoMessage

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) ProtoReflect

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

func (*ImportResponse) Reset

func (x *ImportResponse) Reset()

func (*ImportResponse) String

func (x *ImportResponse) String() string

type IntrospectRequest

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

func (*IntrospectRequest) Descriptor deprecated

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

Deprecated: Use IntrospectRequest.ProtoReflect.Descriptor instead.

func (*IntrospectRequest) ProtoMessage

func (*IntrospectRequest) ProtoMessage()

func (*IntrospectRequest) ProtoReflect

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

func (*IntrospectRequest) Reset

func (x *IntrospectRequest) Reset()

func (*IntrospectRequest) String

func (x *IntrospectRequest) String() string

type IntrospectResponse

type IntrospectResponse struct {
	SysInfo      *SystemInfo   `protobuf:"bytes,1,opt,name=sys_info,json=sysInfo,proto3" json:"sys_info,omitempty"`
	ExecutorInfo *ExecutorInfo `protobuf:"bytes,3,opt,name=executor_info,json=executorInfo,proto3" json:"executor_info,omitempty"`
	Labels       []string      `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*IntrospectResponse) Descriptor deprecated

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

Deprecated: Use IntrospectResponse.ProtoReflect.Descriptor instead.

func (*IntrospectResponse) GetExecutorInfo

func (x *IntrospectResponse) GetExecutorInfo() *ExecutorInfo

func (*IntrospectResponse) GetLabels

func (x *IntrospectResponse) GetLabels() []string

func (*IntrospectResponse) GetSysInfo

func (x *IntrospectResponse) GetSysInfo() *SystemInfo

func (*IntrospectResponse) ProtoMessage

func (*IntrospectResponse) ProtoMessage()

func (*IntrospectResponse) ProtoReflect

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

func (*IntrospectResponse) Reset

func (x *IntrospectResponse) Reset()

func (*IntrospectResponse) String

func (x *IntrospectResponse) String() string

type OpenRequest

type OpenRequest struct {
	BuildId   string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	RuntimeId string `protobuf:"bytes,2,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	Opts      *Opts  `protobuf:"bytes,3,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenRequest) Descriptor deprecated

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

Deprecated: Use OpenRequest.ProtoReflect.Descriptor instead.

func (*OpenRequest) GetBuildId

func (x *OpenRequest) GetBuildId() string

func (*OpenRequest) GetOpts

func (x *OpenRequest) GetOpts() *Opts

func (*OpenRequest) GetRuntimeId

func (x *OpenRequest) GetRuntimeId() string

func (*OpenRequest) ProtoMessage

func (*OpenRequest) ProtoMessage()

func (*OpenRequest) ProtoReflect

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

func (*OpenRequest) Reset

func (x *OpenRequest) Reset()

func (*OpenRequest) String

func (x *OpenRequest) String() string

type OpenResponse

type OpenResponse struct {
	WorkDirectory string      `protobuf:"bytes,1,opt,name=work_directory,json=workDirectory,proto3" json:"work_directory,omitempty"`
	SysInfo       *SystemInfo `protobuf:"bytes,2,opt,name=sys_info,json=sysInfo,proto3" json:"sys_info,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenResponse) Descriptor deprecated

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

Deprecated: Use OpenResponse.ProtoReflect.Descriptor instead.

func (*OpenResponse) GetSysInfo

func (x *OpenResponse) GetSysInfo() *SystemInfo

func (*OpenResponse) GetWorkDirectory

func (x *OpenResponse) GetWorkDirectory() string

func (*OpenResponse) ProtoMessage

func (*OpenResponse) ProtoMessage()

func (*OpenResponse) ProtoReflect

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

func (*OpenResponse) Reset

func (x *OpenResponse) Reset()

func (*OpenResponse) String

func (x *OpenResponse) String() string

type Opts

type Opts struct {
	Type   RuntimeType       `protobuf:"varint,1,opt,name=type,proto3,enum=executor.knita.io.RuntimeType" json:"type,omitempty"`
	Labels []string          `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"` // TODO becomes "label selector". Runner labels become k/v pairs, with the same semantics as event labels.
	Tags   map[string]string ``                                                                  // TODO moves up to Event
	/* 149-byte string literal not displayed */
	// Types that are assignable to Opts:
	//
	//	*Opts_Host
	//	*Opts_Docker
	Opts isOpts_Opts `protobuf_oneof:"opts"`
	// contains filtered or unexported fields
}

func (*Opts) Descriptor deprecated

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

Deprecated: Use Opts.ProtoReflect.Descriptor instead.

func (*Opts) GetDocker

func (x *Opts) GetDocker() *DockerOpts

func (*Opts) GetHost

func (x *Opts) GetHost() *HostOpts

func (*Opts) GetLabels

func (x *Opts) GetLabels() []string

func (*Opts) GetOpts

func (m *Opts) GetOpts() isOpts_Opts

func (*Opts) GetTags

func (x *Opts) GetTags() map[string]string

func (*Opts) GetType

func (x *Opts) GetType() RuntimeType

func (*Opts) ProtoMessage

func (*Opts) ProtoMessage()

func (*Opts) ProtoReflect

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

func (*Opts) Reset

func (x *Opts) Reset()

func (*Opts) String

func (x *Opts) String() string

type Opts_Docker

type Opts_Docker struct {
	Docker *DockerOpts `protobuf:"bytes,3,opt,name=docker,proto3,oneof"`
}

type Opts_Host

type Opts_Host struct {
	Host *HostOpts `protobuf:"bytes,2,opt,name=host,proto3,oneof"`
}

type RuntimeType

type RuntimeType int32
const (
	RuntimeType_RUNTIME_UNSPECIFIED RuntimeType = 0
	RuntimeType_RUNTIME_HOST        RuntimeType = 1
	RuntimeType_RUNTIME_DOCKER      RuntimeType = 2
)

func (RuntimeType) Descriptor

func (RuntimeType) Enum

func (x RuntimeType) Enum() *RuntimeType

func (RuntimeType) EnumDescriptor deprecated

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

Deprecated: Use RuntimeType.Descriptor instead.

func (RuntimeType) Number

func (x RuntimeType) Number() protoreflect.EnumNumber

func (RuntimeType) String

func (x RuntimeType) String() string

func (RuntimeType) Type

type SystemInfo

type SystemInfo struct {
	Os            string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Arch          string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
	TotalCpuCores uint32 `protobuf:"varint,4,opt,name=total_cpu_cores,json=totalCpuCores,proto3" json:"total_cpu_cores,omitempty"`
	TotalMemory   uint64 `protobuf:"varint,5,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemInfo) Descriptor deprecated

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

Deprecated: Use SystemInfo.ProtoReflect.Descriptor instead.

func (*SystemInfo) GetArch

func (x *SystemInfo) GetArch() string

func (*SystemInfo) GetOs

func (x *SystemInfo) GetOs() string

func (*SystemInfo) GetTotalCpuCores

func (x *SystemInfo) GetTotalCpuCores() uint32

func (*SystemInfo) GetTotalMemory

func (x *SystemInfo) GetTotalMemory() uint64

func (*SystemInfo) ProtoMessage

func (*SystemInfo) ProtoMessage()

func (*SystemInfo) ProtoReflect

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

func (*SystemInfo) Reset

func (x *SystemInfo) Reset()

func (*SystemInfo) String

func (x *SystemInfo) String() string

type UnimplementedExecutorServer

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutorServer) Close

func (UnimplementedExecutorServer) Events

func (UnimplementedExecutorServer) Exec

func (UnimplementedExecutorServer) Export

func (UnimplementedExecutorServer) Heartbeat

func (UnimplementedExecutorServer) Import

func (UnimplementedExecutorServer) Introspect

func (UnimplementedExecutorServer) Open

type UnsafeExecutorServer

type UnsafeExecutorServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳