tes

package
v0.0.0-...-2e51320 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2024 License: MIT Imports: 32 Imported by: 1

Documentation

Overview

Package tes is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	Unknown       = State_UNKNOWN
	Queued        = State_QUEUED
	Running       = State_RUNNING
	Paused        = State_PAUSED
	Complete      = State_COMPLETE
	ExecutorError = State_EXECUTOR_ERROR
	SystemError   = State_SYSTEM_ERROR
	Canceled      = State_CANCELED
	Initializing  = State_INITIALIZING
)

State variables for convenience

View Source 
const (
	TaskService_ListTasks_FullMethodName      = "/tes.TaskService/ListTasks"
	TaskService_CreateTask_FullMethodName     = "/tes.TaskService/CreateTask"
	TaskService_GetTask_FullMethodName        = "/tes.TaskService/GetTask"
	TaskService_CancelTask_FullMethodName     = "/tes.TaskService/CancelTask"
	TaskService_GetServiceInfo_FullMethodName = "/tes.TaskService/GetServiceInfo"
)
View Source 
const (
	Minimal   = View_MINIMAL
	Basic     = View_BASIC
	Full      = View_FULL
	File      = FileType_FILE
	Directory = FileType_DIRECTORY
)

Shorthand for task views

Variables

View Source 
var (
	State_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "QUEUED",
		2:  "INITIALIZING",
		3:  "RUNNING",
		4:  "PAUSED",
		5:  "COMPLETE",
		6:  "EXECUTOR_ERROR",
		7:  "SYSTEM_ERROR",
		8:  "CANCELED",
		9:  "PREEMPTED",
		10: "CANCELING",
	}
	State_value = map[string]int32{
		"UNKNOWN":        0,
		"QUEUED":         1,
		"INITIALIZING":   2,
		"RUNNING":        3,
		"PAUSED":         4,
		"COMPLETE":       5,
		"EXECUTOR_ERROR": 6,
		"SYSTEM_ERROR":   7,
		"CANCELED":       8,
		"PREEMPTED":      9,
		"CANCELING":      10,
	}
)

Enum value maps for State.

View Source 
var (
	FileType_name = map[int32]string{
		0: "FILE",
		1: "DIRECTORY",
	}
	FileType_value = map[string]int32{
		"FILE":      0,
		"DIRECTORY": 1,
	}
)

Enum value maps for FileType.

View Source 
var (
	View_name = map[int32]string{
		0: "MINIMAL",
		1: "BASIC",
		2: "FULL",
	}
	View_value = map[string]int32{
		"MINIMAL": 0,
		"BASIC":   1,
		"FULL":    2,
	}
)

Enum value maps for View.

View Source 
var ErrConcurrentStateChange = errors.New("Concurrent stage change")
View Source 
var ErrNotFound = errors.New("task not found")

ErrNotFound is returned when a task is not found.

View Source 
var File_tes_proto protoreflect.FileDescriptor
View Source 
var Marshaler = protojson.MarshalOptions{
	Indent: "  ",
}

Marshaler marshals tasks to indented JSON.

View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tes.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTasks",
			Handler:    _TaskService_ListTasks_Handler,
		},
		{
			MethodName: "CreateTask",
			Handler:    _TaskService_CreateTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _TaskService_GetTask_Handler,
		},
		{
			MethodName: "CancelTask",
			Handler:    _TaskService_CancelTask_Handler,
		},
		{
			MethodName: "GetServiceInfo",
			Handler:    _TaskService_GetServiceInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tes.proto",
}

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

Functions

func Base64Encode 

func Base64Encode(t *Task) (string, error)

Base64Encode encodes a task as a base64 encoded string

func GenerateID 

func GenerateID() string

GenerateID generates a task ID string. IDs are globally unique and sortable.

func GetPageSize 

func GetPageSize(reqSize int32) int

GetPageSize takes in the page size from a request and returns a new page size taking into account the minimum, maximum and default as documented in the TES spec.

func Hash 

func Hash(task *Task) (string, error)

Hash returns a hash of the task, for caching. The hash is calculated only from fields which affect execution, so fields such as Name, Description, Tags, etc. are ignored.

func InitTask 

func InitTask(task *Task, overwrite bool) error

InitTask intializes task fields which are commonly set by CreateTask, such as Id, CreationTime, State, etc. If the task fails validation, an error is returned. See Validate(). The given task is modified.

If "overwrite" is true, the fields Id, State, and CreationTime will always be overwritten, even if already set, otherwise they will only be set if they are empty.

func MarshalToString 

func MarshalToString(t *Task) (string, error)

MarshalToString marshals a task to an indented JSON string.

func RegisterTaskServiceHandler 

func RegisterTaskServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTaskServiceHandler registers the http handlers for service TaskService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTaskServiceHandlerClient 

func RegisterTaskServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TaskServiceClient) error

RegisterTaskServiceHandlerClient registers the http handlers for service TaskService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TaskServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TaskServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TaskServiceClient" to call the correct interceptors.

func RegisterTaskServiceHandlerFromEndpoint 

func RegisterTaskServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTaskServiceHandlerFromEndpoint is same as RegisterTaskServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTaskServiceHandlerServer 

func RegisterTaskServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TaskServiceServer) error

RegisterTaskServiceHandlerServer registers the http handlers for service TaskService to "mux". UnaryRPC :call TaskServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterTaskServiceHandlerFromEndpoint instead.

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

func RunnableState 

func RunnableState(s State) bool

RunnableState returns true if the state is RUNNING or INITIALIZING

func TerminalState 

func TerminalState(s State) bool

TerminalState returns true if the state is COMPLETE, ERROR, SYSTEM_ERROR, or CANCELED

func ValidateTransition 

func ValidateTransition(from, to State) error

ValidateTransition validates a task state transition. Returns a TransitionError if the transition is not valid.

Types

type CancelTaskRequest 

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

func (*CancelTaskRequest) Descriptor deprecated 

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

Deprecated: Use CancelTaskRequest.ProtoReflect.Descriptor instead.

func (*CancelTaskRequest) GetId 

func (x *CancelTaskRequest) GetId() string

func (*CancelTaskRequest) ProtoMessage 

func (*CancelTaskRequest) ProtoMessage()

func (*CancelTaskRequest) ProtoReflect 

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

func (*CancelTaskRequest) Reset 

func (x *CancelTaskRequest) Reset()

func (*CancelTaskRequest) String 

func (x *CancelTaskRequest) String() string

type CancelTaskResponse 

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

func (*CancelTaskResponse) Descriptor deprecated 

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

Deprecated: Use CancelTaskResponse.ProtoReflect.Descriptor instead.

func (*CancelTaskResponse) ProtoMessage 

func (*CancelTaskResponse) ProtoMessage()

func (*CancelTaskResponse) ProtoReflect 

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

func (*CancelTaskResponse) Reset 

func (x *CancelTaskResponse) Reset()

func (*CancelTaskResponse) String 

func (x *CancelTaskResponse) String() string

type Client 

type Client struct {
	Marshaler *protojson.MarshalOptions
	User      string
	Password  string
	// contains filtered or unexported fields
}

Client represents the HTTP Task client.

func NewClient 

func NewClient(address string) (*Client, error)

NewClient returns a new HTTP client for accessing Create/List/Get/Cancel Task endpoints. "address" is the address of the TES server.

func (*Client) CancelTask 

func (c *Client) CancelTask(ctx context.Context, req *CancelTaskRequest) (*CancelTaskResponse, error)

CancelTask POSTs to /v1/tasks/{id}:cancel

func (*Client) CreateTask 

func (c *Client) CreateTask(ctx context.Context, task *Task) (*CreateTaskResponse, error)

CreateTask POSTs a Task message to /v1/tasks

func (*Client) GetServiceInfo 

func (c *Client) GetServiceInfo(ctx context.Context, req *GetServiceInfoRequest) (*ServiceInfo, error)

GetServiceInfo returns result of GET /v1/service-info

func (*Client) GetTask 

func (c *Client) GetTask(ctx context.Context, req *GetTaskRequest) (*Task, error)

GetTask returns the raw bytes from GET /v1/tasks/{id}

func (*Client) ListTasks 

func (c *Client) ListTasks(ctx context.Context, req *ListTasksRequest) (*ListTasksResponse, error)

ListTasks returns the result of GET /v1/tasks

func (*Client) WaitForTask 

func (c *Client) WaitForTask(ctx context.Context, taskIDs ...string) error

WaitForTask polls /v1/tasks/{id} for each Id provided and returns once all tasks are in a terminal state.

type CreateTaskResponse 

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

func (*CreateTaskResponse) Descriptor deprecated 

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

Deprecated: Use CreateTaskResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskResponse) GetId 

func (x *CreateTaskResponse) GetId() string

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) ProtoReflect 

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

func (*CreateTaskResponse) Reset 

func (x *CreateTaskResponse) Reset()

func (*CreateTaskResponse) String 

func (x *CreateTaskResponse) String() string

type Executor 

type Executor struct {
	Command     []string          `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"`
	Env         map[string]string `` /* 147-byte string literal not displayed */
	IgnoreError bool              `protobuf:"varint,3,opt,name=ignore_error,json=ignoreError,proto3" json:"ignore_error,omitempty"`
	Image       string            `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	Stderr      string            `protobuf:"bytes,5,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Stdin       string            `protobuf:"bytes,6,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout      string            `protobuf:"bytes,7,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Workdir     string            `protobuf:"bytes,8,opt,name=workdir,proto3" json:"workdir,omitempty"`
	// contains filtered or unexported fields
}

func (*Executor) Descriptor deprecated 

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

Deprecated: Use Executor.ProtoReflect.Descriptor instead.

func (*Executor) GetCommand 

func (x *Executor) GetCommand() []string

func (*Executor) GetEnv 

func (x *Executor) GetEnv() map[string]string

func (*Executor) GetIgnoreError 

func (x *Executor) GetIgnoreError() bool

func (*Executor) GetImage 

func (x *Executor) GetImage() string

func (*Executor) GetStderr 

func (x *Executor) GetStderr() string

func (*Executor) GetStdin 

func (x *Executor) GetStdin() string

func (*Executor) GetStdout 

func (x *Executor) GetStdout() string

func (*Executor) GetWorkdir 

func (x *Executor) GetWorkdir() string

func (*Executor) ProtoMessage 

func (*Executor) ProtoMessage()

func (*Executor) ProtoReflect 

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

func (*Executor) Reset 

func (x *Executor) Reset()

func (*Executor) String 

func (x *Executor) String() string

type ExecutorBasic 

type ExecutorBasic struct {
	Command     []string          `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"`
	Env         map[string]string `` /* 147-byte string literal not displayed */
	IgnoreError bool              `protobuf:"varint,3,opt,name=ignore_error,json=ignoreError,proto3" json:"ignore_error,omitempty"`
	Image       string            `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	Stdin       string            `protobuf:"bytes,5,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Workdir     string            `protobuf:"bytes,6,opt,name=workdir,proto3" json:"workdir,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutorBasic) Descriptor deprecated 

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

Deprecated: Use ExecutorBasic.ProtoReflect.Descriptor instead.

func (*ExecutorBasic) GetCommand 

func (x *ExecutorBasic) GetCommand() []string

func (*ExecutorBasic) GetEnv 

func (x *ExecutorBasic) GetEnv() map[string]string

func (*ExecutorBasic) GetIgnoreError 

func (x *ExecutorBasic) GetIgnoreError() bool

func (*ExecutorBasic) GetImage 

func (x *ExecutorBasic) GetImage() string

func (*ExecutorBasic) GetStdin 

func (x *ExecutorBasic) GetStdin() string

func (*ExecutorBasic) GetWorkdir 

func (x *ExecutorBasic) GetWorkdir() string

func (*ExecutorBasic) ProtoMessage 

func (*ExecutorBasic) ProtoMessage()

func (*ExecutorBasic) ProtoReflect 

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

func (*ExecutorBasic) Reset 

func (x *ExecutorBasic) Reset()

func (*ExecutorBasic) String 

func (x *ExecutorBasic) String() string

type ExecutorLog 

type ExecutorLog struct {
	EndTime   string `protobuf:"bytes,1,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	ExitCode  int32  `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	StartTime string `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	Stderr    string `protobuf:"bytes,4,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Stdout    string `protobuf:"bytes,5,opt,name=stdout,proto3" json:"stdout,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutorLog) Descriptor deprecated 

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

Deprecated: Use ExecutorLog.ProtoReflect.Descriptor instead.

func (*ExecutorLog) GetEndTime 

func (x *ExecutorLog) GetEndTime() string

func (*ExecutorLog) GetExitCode 

func (x *ExecutorLog) GetExitCode() int32

func (*ExecutorLog) GetStartTime 

func (x *ExecutorLog) GetStartTime() string

func (*ExecutorLog) GetStderr 

func (x *ExecutorLog) GetStderr() string

func (*ExecutorLog) GetStdout 

func (x *ExecutorLog) GetStdout() string

func (*ExecutorLog) ProtoMessage 

func (*ExecutorLog) ProtoMessage()

func (*ExecutorLog) ProtoReflect 

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

func (*ExecutorLog) Reset 

func (x *ExecutorLog) Reset()

func (*ExecutorLog) String 

func (x *ExecutorLog) String() string

type FileType 

type FileType int32
const (
	FileType_FILE      FileType = 0
	FileType_DIRECTORY FileType = 1
)

func (FileType) Descriptor 

func (FileType) Descriptor() protoreflect.EnumDescriptor

func (FileType) Enum 

func (x FileType) Enum() *FileType

func (FileType) EnumDescriptor deprecated 

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

Deprecated: Use FileType.Descriptor instead.

func (FileType) Number 

func (x FileType) Number() protoreflect.EnumNumber

func (FileType) String 

func (x FileType) String() string

func (FileType) Type 

func (FileType) Type() protoreflect.EnumType

type GetServiceInfoRequest 

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

func (*GetServiceInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetServiceInfoRequest.ProtoReflect.Descriptor instead.

func (*GetServiceInfoRequest) ProtoMessage 

func (*GetServiceInfoRequest) ProtoMessage()

func (*GetServiceInfoRequest) ProtoReflect 

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

func (*GetServiceInfoRequest) Reset 

func (x *GetServiceInfoRequest) Reset()

func (*GetServiceInfoRequest) String 

func (x *GetServiceInfoRequest) String() string

type GetTaskRequest 

type GetTaskRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	View string `protobuf:"bytes,2,opt,name=view,proto3" json:"view,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetId 

func (x *GetTaskRequest) GetId() string

func (*GetTaskRequest) GetView 

func (x *GetTaskRequest) GetView() string

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect 

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

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type Input 

type Input struct {
	Content     string   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Description string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Name        string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Path        string   `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	Streamable  bool     `protobuf:"varint,5,opt,name=streamable,proto3" json:"streamable,omitempty"`
	Type        FileType `protobuf:"varint,6,opt,name=type,proto3,enum=tes.FileType" json:"type,omitempty"`
	Url         string   `protobuf:"bytes,7,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Input) Descriptor deprecated 

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

Deprecated: Use Input.ProtoReflect.Descriptor instead.

func (*Input) GetContent 

func (x *Input) GetContent() string

func (*Input) GetDescription 

func (x *Input) GetDescription() string

func (*Input) GetName 

func (x *Input) GetName() string

func (*Input) GetPath 

func (x *Input) GetPath() string

func (*Input) GetStreamable 

func (x *Input) GetStreamable() bool

func (*Input) GetType 

func (x *Input) GetType() FileType

func (*Input) GetUrl 

func (x *Input) GetUrl() string

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) ProtoReflect 

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

func (*Input) Reset 

func (x *Input) Reset()

func (*Input) String 

func (x *Input) String() string

type InputBasic 

type InputBasic struct {
	Description string   `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Name        string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Path        string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Streamable  bool     `protobuf:"varint,4,opt,name=streamable,proto3" json:"streamable,omitempty"`
	Type        FileType `protobuf:"varint,5,opt,name=type,proto3,enum=tes.FileType" json:"type,omitempty"`
	Url         string   `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*InputBasic) Descriptor deprecated 

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

Deprecated: Use InputBasic.ProtoReflect.Descriptor instead.

func (*InputBasic) GetDescription 

func (x *InputBasic) GetDescription() string

func (*InputBasic) GetName 

func (x *InputBasic) GetName() string

func (*InputBasic) GetPath 

func (x *InputBasic) GetPath() string

func (*InputBasic) GetStreamable 

func (x *InputBasic) GetStreamable() bool

func (*InputBasic) GetType 

func (x *InputBasic) GetType() FileType

func (*InputBasic) GetUrl 

func (x *InputBasic) GetUrl() string

func (*InputBasic) ProtoMessage 

func (*InputBasic) ProtoMessage()

func (*InputBasic) ProtoReflect 

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

func (*InputBasic) Reset 

func (x *InputBasic) Reset()

func (*InputBasic) String 

func (x *InputBasic) String() string

type ListTasksRequest 

type ListTasksRequest struct {
	NamePrefix string   `protobuf:"bytes,1,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	State      State    `protobuf:"varint,2,opt,name=state,proto3,enum=tes.State" json:"state,omitempty"`
	TagKey     []string `protobuf:"bytes,3,rep,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	TagValue   []string `protobuf:"bytes,4,rep,name=tag_value,json=tagValue,proto3" json:"tag_value,omitempty"`
	PageSize   int32    `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken  string   `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	View       string   `protobuf:"bytes,7,opt,name=view,proto3" json:"view,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetNamePrefix 

func (x *ListTasksRequest) GetNamePrefix() string

func (*ListTasksRequest) GetPageSize 

func (x *ListTasksRequest) GetPageSize() int32

func (*ListTasksRequest) GetPageToken 

func (x *ListTasksRequest) GetPageToken() string

func (*ListTasksRequest) GetState 

func (x *ListTasksRequest) GetState() State

func (*ListTasksRequest) GetTagKey 

func (x *ListTasksRequest) GetTagKey() []string

func (*ListTasksRequest) GetTagValue 

func (x *ListTasksRequest) GetTagValue() []string

func (*ListTasksRequest) GetTags 

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

func (*ListTasksRequest) GetView 

func (x *ListTasksRequest) GetView() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {
	NextPageToken string  `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Tasks         []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetNextPageToken 

func (x *ListTasksResponse) GetNextPageToken() string

func (*ListTasksResponse) GetTasks 

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type ListTasksResponseBasic 

type ListTasksResponseBasic struct {
	NextPageToken string       `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Tasks         []*TaskBasic `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponseBasic) Descriptor deprecated 

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

Deprecated: Use ListTasksResponseBasic.ProtoReflect.Descriptor instead.

func (*ListTasksResponseBasic) GetNextPageToken 

func (x *ListTasksResponseBasic) GetNextPageToken() string

func (*ListTasksResponseBasic) GetTasks 

func (x *ListTasksResponseBasic) GetTasks() []*TaskBasic

func (*ListTasksResponseBasic) ProtoMessage 

func (*ListTasksResponseBasic) ProtoMessage()

func (*ListTasksResponseBasic) ProtoReflect 

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

func (*ListTasksResponseBasic) Reset 

func (x *ListTasksResponseBasic) Reset()

func (*ListTasksResponseBasic) String 

func (x *ListTasksResponseBasic) String() string

type ListTasksResponseMin 

type ListTasksResponseMin struct {
	NextPageToken string     `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Tasks         []*TaskMin `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponseMin) Descriptor deprecated 

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

Deprecated: Use ListTasksResponseMin.ProtoReflect.Descriptor instead.

func (*ListTasksResponseMin) GetNextPageToken 

func (x *ListTasksResponseMin) GetNextPageToken() string

func (*ListTasksResponseMin) GetTasks 

func (x *ListTasksResponseMin) GetTasks() []*TaskMin

func (*ListTasksResponseMin) ProtoMessage 

func (*ListTasksResponseMin) ProtoMessage()

func (*ListTasksResponseMin) ProtoReflect 

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

func (*ListTasksResponseMin) Reset 

func (x *ListTasksResponseMin) Reset()

func (*ListTasksResponseMin) String 

func (x *ListTasksResponseMin) String() string

type Output 

type Output struct {
	Description string   `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Name        string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Path        string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	PathPrefix  string   `protobuf:"bytes,4,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	Type        FileType `protobuf:"varint,5,opt,name=type,proto3,enum=tes.FileType" json:"type,omitempty"`
	Url         string   `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetDescription 

func (x *Output) GetDescription() string

func (*Output) GetName 

func (x *Output) GetName() string

func (*Output) GetPath 

func (x *Output) GetPath() string

func (*Output) GetPathPrefix 

func (x *Output) GetPathPrefix() string

func (*Output) GetType 

func (x *Output) GetType() FileType

func (*Output) GetUrl 

func (x *Output) GetUrl() string

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect 

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

func (*Output) Reset 

func (x *Output) Reset()

func (*Output) String 

func (x *Output) String() string

type OutputFileLog 

type OutputFileLog struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	SizeBytes string `protobuf:"bytes,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Url       string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputFileLog) Descriptor deprecated 

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

Deprecated: Use OutputFileLog.ProtoReflect.Descriptor instead.

func (*OutputFileLog) GetPath 

func (x *OutputFileLog) GetPath() string

func (*OutputFileLog) GetSizeBytes 

func (x *OutputFileLog) GetSizeBytes() string

func (*OutputFileLog) GetUrl 

func (x *OutputFileLog) GetUrl() string

func (*OutputFileLog) ProtoMessage 

func (*OutputFileLog) ProtoMessage()

func (*OutputFileLog) ProtoReflect 

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

func (*OutputFileLog) Reset 

func (x *OutputFileLog) Reset()

func (*OutputFileLog) String 

func (x *OutputFileLog) String() string

type ReadOnlyClient 

type ReadOnlyClient interface {
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
}

ReadOnlyClient describes the TES interface with only the Get/List tasks methods

type ReadOnlyServer 

type ReadOnlyServer interface {
	ListTasks(ctx context.Context, in *ListTasksRequest) (*ListTasksResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest) (*Task, error)
	Close()
}

ReadOnlyServer describes the TES interface with only the Get/List tasks methods

type Resources 

type Resources struct {
	BackendParameters       map[string]string `` /* 200-byte string literal not displayed */
	BackendParametersStrict bool              `` /* 133-byte string literal not displayed */
	CpuCores                int32             `protobuf:"varint,3,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`
	DiskGb                  float64           `protobuf:"fixed64,4,opt,name=disk_gb,json=diskGb,proto3" json:"disk_gb,omitempty"`
	Preemptible             bool              `protobuf:"varint,5,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
	RamGb                   float64           `protobuf:"fixed64,6,opt,name=ram_gb,json=ramGb,proto3" json:"ram_gb,omitempty"`
	Zones                   []string          `protobuf:"bytes,7,rep,name=zones,proto3" json:"zones,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources) Descriptor deprecated 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetBackendParameters 

func (x *Resources) GetBackendParameters() map[string]string

func (*Resources) GetBackendParametersStrict 

func (x *Resources) GetBackendParametersStrict() bool

func (*Resources) GetCpuCores 

func (x *Resources) GetCpuCores() int32

func (*Resources) GetDiskGb 

func (x *Resources) GetDiskGb() float64

func (*Resources) GetPreemptible 

func (x *Resources) GetPreemptible() bool

func (*Resources) GetRamGb 

func (x *Resources) GetRamGb() float64

func (*Resources) GetZones 

func (x *Resources) GetZones() []string

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

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

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) String 

func (x *Resources) String() string

type ServiceInfo 

type ServiceInfo struct {
	ContactUrl                    string            `protobuf:"bytes,1,opt,name=contactUrl,proto3" json:"contactUrl,omitempty"`
	CreatedAt                     string            `protobuf:"bytes,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	Description                   string            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	DocumentationUrl              string            `protobuf:"bytes,4,opt,name=documentationUrl,proto3" json:"documentationUrl,omitempty"`
	Environment                   string            `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"`
	Id                            string            `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	Name                          string            `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Organization                  map[string]string `` /* 165-byte string literal not displayed */
	Storage                       []string          `protobuf:"bytes,9,rep,name=storage,proto3" json:"storage,omitempty"`
	TesResourcesBackendParameters []string          `` /* 151-byte string literal not displayed */
	Type                          *ServiceType      `protobuf:"bytes,11,opt,name=type,proto3" json:"type,omitempty"`
	UpdatedAt                     string            `protobuf:"bytes,12,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Version                       string            `protobuf:"bytes,13,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInfo) Descriptor deprecated 

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

Deprecated: Use ServiceInfo.ProtoReflect.Descriptor instead.

func (*ServiceInfo) GetContactUrl 

func (x *ServiceInfo) GetContactUrl() string

func (*ServiceInfo) GetCreatedAt 

func (x *ServiceInfo) GetCreatedAt() string

func (*ServiceInfo) GetDescription 

func (x *ServiceInfo) GetDescription() string

func (*ServiceInfo) GetDocumentationUrl 

func (x *ServiceInfo) GetDocumentationUrl() string

func (*ServiceInfo) GetEnvironment 

func (x *ServiceInfo) GetEnvironment() string

func (*ServiceInfo) GetId 

func (x *ServiceInfo) GetId() string

func (*ServiceInfo) GetName 

func (x *ServiceInfo) GetName() string

func (*ServiceInfo) GetOrganization 

func (x *ServiceInfo) GetOrganization() map[string]string

func (*ServiceInfo) GetStorage 

func (x *ServiceInfo) GetStorage() []string

func (*ServiceInfo) GetTesResourcesBackendParameters 

func (x *ServiceInfo) GetTesResourcesBackendParameters() []string

func (*ServiceInfo) GetType 

func (x *ServiceInfo) GetType() *ServiceType

func (*ServiceInfo) GetUpdatedAt 

func (x *ServiceInfo) GetUpdatedAt() string

func (*ServiceInfo) GetVersion 

func (x *ServiceInfo) GetVersion() string

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) ProtoReflect 

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

func (*ServiceInfo) Reset 

func (x *ServiceInfo) Reset()

func (*ServiceInfo) String 

func (x *ServiceInfo) String() string

type ServiceType 

type ServiceType struct {
	Artifact string `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	Group    string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Version  string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceType) Descriptor deprecated 

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

Deprecated: Use ServiceType.ProtoReflect.Descriptor instead.

func (*ServiceType) GetArtifact 

func (x *ServiceType) GetArtifact() string

func (*ServiceType) GetGroup 

func (x *ServiceType) GetGroup() string

func (*ServiceType) GetVersion 

func (x *ServiceType) GetVersion() string

func (*ServiceType) ProtoMessage 

func (*ServiceType) ProtoMessage()

func (*ServiceType) ProtoReflect 

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

func (*ServiceType) Reset 

func (x *ServiceType) Reset()

func (*ServiceType) String 

func (x *ServiceType) String() string

type State 

type State int32
const (
	State_UNKNOWN        State = 0
	State_QUEUED         State = 1
	State_INITIALIZING   State = 2
	State_RUNNING        State = 3
	State_PAUSED         State = 4
	State_COMPLETE       State = 5
	State_EXECUTOR_ERROR State = 6
	State_SYSTEM_ERROR   State = 7
	State_CANCELED       State = 8
	State_PREEMPTED      State = 9
	State_CANCELING      State = 10
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type Task 

type Task struct {
	CreationTime string            `protobuf:"bytes,1,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	Description  string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Executors    []*Executor       `protobuf:"bytes,3,rep,name=executors,proto3" json:"executors,omitempty"`
	Id           string            `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Inputs       []*Input          `protobuf:"bytes,5,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Logs         []*TaskLog        `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	Name         string            `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Outputs      []*Output         `protobuf:"bytes,8,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Resources    *Resources        `protobuf:"bytes,9,opt,name=resources,proto3" json:"resources,omitempty"`
	State        State             `protobuf:"varint,10,opt,name=state,proto3,enum=tes.State" json:"state,omitempty"`
	Tags         map[string]string `` /* 150-byte string literal not displayed */
	Volumes      []string          `protobuf:"bytes,12,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func Base64Decode 

func Base64Decode(raw string) (*Task, error)

Base64Decode decodes a base64 encoded string into a task

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetBasicView 

func (task *Task) GetBasicView() *Task

GetBasicView returns the basic view of a task.

func (*Task) GetCreationTime 

func (x *Task) GetCreationTime() string

func (*Task) GetDescription 

func (x *Task) GetDescription() string

func (*Task) GetExecLog 

func (task *Task) GetExecLog(attempt int, i int) *ExecutorLog

GetExecLog gets the executor log entry at the given index "i". If the entry doesn't exist, empty logs will be appended up to "i".

func (*Task) GetExecutors 

func (x *Task) GetExecutors() []*Executor

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetInputs 

func (x *Task) GetInputs() []*Input

func (*Task) GetLogs 

func (x *Task) GetLogs() []*TaskLog

func (*Task) GetMinimalView 

func (task *Task) GetMinimalView() *Task

GetMinimalView returns the minimal view of a task.

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetOutputs 

func (x *Task) GetOutputs() []*Output

func (*Task) GetResources 

func (x *Task) GetResources() *Resources

func (*Task) GetState 

func (x *Task) GetState() State

func (*Task) GetTags 

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

func (*Task) GetTaskLog 

func (task *Task) GetTaskLog(i int) *TaskLog

GetTaskLog gets the task log entry at the given index "i". If the entry doesn't exist, empty logs will be appended up to "i".

func (*Task) GetVolumes 

func (x *Task) GetVolumes() []string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskBasic 

type TaskBasic struct {
	CreationTime string            `protobuf:"bytes,1,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	Description  string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Executors    []*ExecutorBasic  `protobuf:"bytes,3,rep,name=executors,proto3" json:"executors,omitempty"`
	Id           string            `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Inputs       []*InputBasic     `protobuf:"bytes,5,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Logs         []*TaskLogBasic   `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	Name         string            `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Outputs      []*Output         `protobuf:"bytes,8,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Resources    *Resources        `protobuf:"bytes,9,opt,name=resources,proto3" json:"resources,omitempty"`
	State        State             `protobuf:"varint,10,opt,name=state,proto3,enum=tes.State" json:"state,omitempty"`
	Tags         map[string]string `` /* 150-byte string literal not displayed */
	Volumes      []string          `protobuf:"bytes,12,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskBasic) Descriptor deprecated 

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

Deprecated: Use TaskBasic.ProtoReflect.Descriptor instead.

func (*TaskBasic) GetCreationTime 

func (x *TaskBasic) GetCreationTime() string

func (*TaskBasic) GetDescription 

func (x *TaskBasic) GetDescription() string

func (*TaskBasic) GetExecutors 

func (x *TaskBasic) GetExecutors() []*ExecutorBasic

func (*TaskBasic) GetId 

func (x *TaskBasic) GetId() string

func (*TaskBasic) GetInputs 

func (x *TaskBasic) GetInputs() []*InputBasic

func (*TaskBasic) GetLogs 

func (x *TaskBasic) GetLogs() []*TaskLogBasic

func (*TaskBasic) GetName 

func (x *TaskBasic) GetName() string

func (*TaskBasic) GetOutputs 

func (x *TaskBasic) GetOutputs() []*Output

func (*TaskBasic) GetResources 

func (x *TaskBasic) GetResources() *Resources

func (*TaskBasic) GetState 

func (x *TaskBasic) GetState() State

func (*TaskBasic) GetTags 

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

func (*TaskBasic) GetVolumes 

func (x *TaskBasic) GetVolumes() []string

func (*TaskBasic) ProtoMessage 

func (*TaskBasic) ProtoMessage()

func (*TaskBasic) ProtoReflect 

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

func (*TaskBasic) Reset 

func (x *TaskBasic) Reset()

func (*TaskBasic) String 

func (x *TaskBasic) String() string

type TaskLog 

type TaskLog struct {
	EndTime    string            `protobuf:"bytes,1,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Logs       []*ExecutorLog    `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	Metadata   map[string]string `` /* 157-byte string literal not displayed */
	Outputs    []*OutputFileLog  `protobuf:"bytes,4,rep,name=outputs,proto3" json:"outputs,omitempty"`
	StartTime  string            `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	SystemLogs []string          `protobuf:"bytes,6,rep,name=system_logs,json=systemLogs,proto3" json:"system_logs,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskLog) Descriptor deprecated 

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

Deprecated: Use TaskLog.ProtoReflect.Descriptor instead.

func (*TaskLog) GetEndTime 

func (x *TaskLog) GetEndTime() string

func (*TaskLog) GetLogs 

func (x *TaskLog) GetLogs() []*ExecutorLog

func (*TaskLog) GetMetadata 

func (x *TaskLog) GetMetadata() map[string]string

func (*TaskLog) GetOutputs 

func (x *TaskLog) GetOutputs() []*OutputFileLog

func (*TaskLog) GetStartTime 

func (x *TaskLog) GetStartTime() string

func (*TaskLog) GetSystemLogs 

func (x *TaskLog) GetSystemLogs() []string

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) ProtoReflect 

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

func (*TaskLog) Reset 

func (x *TaskLog) Reset()

func (*TaskLog) String 

func (x *TaskLog) String() string

type TaskLogBasic 

type TaskLogBasic struct {
	EndTime   string            `protobuf:"bytes,1,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Logs      []*ExecutorLog    `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	Metadata  map[string]string `` /* 157-byte string literal not displayed */
	Outputs   []*OutputFileLog  `protobuf:"bytes,4,rep,name=outputs,proto3" json:"outputs,omitempty"`
	StartTime string            `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskLogBasic) Descriptor deprecated 

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

Deprecated: Use TaskLogBasic.ProtoReflect.Descriptor instead.

func (*TaskLogBasic) GetEndTime 

func (x *TaskLogBasic) GetEndTime() string

func (*TaskLogBasic) GetLogs 

func (x *TaskLogBasic) GetLogs() []*ExecutorLog

func (*TaskLogBasic) GetMetadata 

func (x *TaskLogBasic) GetMetadata() map[string]string

func (*TaskLogBasic) GetOutputs 

func (x *TaskLogBasic) GetOutputs() []*OutputFileLog

func (*TaskLogBasic) GetStartTime 

func (x *TaskLogBasic) GetStartTime() string

func (*TaskLogBasic) ProtoMessage 

func (*TaskLogBasic) ProtoMessage()

func (*TaskLogBasic) ProtoReflect 

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

func (*TaskLogBasic) Reset 

func (x *TaskLogBasic) Reset()

func (*TaskLogBasic) String 

func (x *TaskLogBasic) String() string

type TaskMin 

type TaskMin struct {
	Id    string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	State State  `protobuf:"varint,10,opt,name=state,proto3,enum=tes.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskMin) Descriptor deprecated 

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

Deprecated: Use TaskMin.ProtoReflect.Descriptor instead.

func (*TaskMin) GetId 

func (x *TaskMin) GetId() string

func (*TaskMin) GetState 

func (x *TaskMin) GetState() State

func (*TaskMin) ProtoMessage 

func (*TaskMin) ProtoMessage()

func (*TaskMin) ProtoReflect 

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

func (*TaskMin) Reset 

func (x *TaskMin) Reset()

func (*TaskMin) String 

func (x *TaskMin) String() string

type TaskServiceClient 

type TaskServiceClient interface {
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	CreateTask(ctx context.Context, in *Task, opts ...grpc.CallOption) (*CreateTaskResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
	CancelTask(ctx context.Context, in *CancelTaskRequest, opts ...grpc.CallOption) (*CancelTaskResponse, error)
	GetServiceInfo(ctx context.Context, in *GetServiceInfoRequest, opts ...grpc.CallOption) (*ServiceInfo, error)
}

TaskServiceClient is the client API for TaskService service.

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

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	CreateTask(context.Context, *Task) (*CreateTaskResponse, error)
	GetTask(context.Context, *GetTaskRequest) (*Task, error)
	CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)
	GetServiceInfo(context.Context, *GetServiceInfoRequest) (*ServiceInfo, error)
	// contains filtered or unexported methods
}

TaskServiceServer is the server API for TaskService service. All implementations must embed UnimplementedTaskServiceServer for forward compatibility

type TransitionError 

type TransitionError struct {
	From, To State
}

TransitionError describes an invalid state transition.

func (*TransitionError) Error 

func (te *TransitionError) Error() string

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) CancelTask 

func (UnimplementedTaskServiceServer) CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)

func (UnimplementedTaskServiceServer) CreateTask 

func (UnimplementedTaskServiceServer) CreateTask(context.Context, *Task) (*CreateTaskResponse, error)

func (UnimplementedTaskServiceServer) GetServiceInfo 

func (UnimplementedTaskServiceServer) GetServiceInfo(context.Context, *GetServiceInfoRequest) (*ServiceInfo, error)

func (UnimplementedTaskServiceServer) GetTask 

func (UnimplementedTaskServiceServer) GetTask(context.Context, *GetTaskRequest) (*Task, error)

func (UnimplementedTaskServiceServer) ListTasks 

func (UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

type UnsafeTaskServiceServer 

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

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

type ValidationError 

type ValidationError []error

ValidationError contains task validation errors.

func Validate 

func Validate(t *Task) ValidationError

Validate validates the given task and returns ValidationError, or nil if the task is valid.

func (ValidationError) Error 

func (v ValidationError) Error() string

type View 

type View int32
const (
	View_MINIMAL View = 0
	View_BASIC   View = 1
	View_FULL    View = 2
)

func (View) Descriptor 

func (View) Descriptor() protoreflect.EnumDescriptor

func (View) Enum 

func (x View) Enum() *View

func (View) EnumDescriptor deprecated 

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

Deprecated: Use View.Descriptor instead.

func (View) Number 

func (x View) Number() protoreflect.EnumNumber

func (View) String 

func (x View) String() string

func (View) Type 

func (View) Type() protoreflect.EnumType

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.