worker

package
v0.0.1-alpha Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var RunCommand_BazelRequest_DEFAULT *bazel.ExecuteRequest
View Source 
var RunCommand_Env_DEFAULT map[string]string
View Source 
var RunCommand_JobId_DEFAULT string
View Source 
var RunCommand_SnapshotId_DEFAULT string
View Source 
var RunCommand_Tag_DEFAULT string
View Source 
var RunCommand_TaskId_DEFAULT string
View Source 
var RunCommand_TimeoutMs_DEFAULT int32
View Source 
var RunStatus_BazelResult__DEFAULT *bazel.ActionResult_
View Source 
var RunStatus_ErrUri_DEFAULT string
View Source 
var RunStatus_Error_DEFAULT string
View Source 
var RunStatus_ExitCode_DEFAULT int32
View Source 
var RunStatus_JobId_DEFAULT string
View Source 
var RunStatus_OutUri_DEFAULT string
View Source 
var RunStatus_SnapshotId_DEFAULT string
View Source 
var RunStatus_Tag_DEFAULT string
View Source 
var RunStatus_TaskId_DEFAULT string

Functions

This section is empty.

Types

type RunCommand 

type RunCommand struct {
	Argv         []string              `thrift:"argv,1,required" json:"argv"`
	Env          map[string]string     `thrift:"env,2" json:"env,omitempty"`
	SnapshotId   *string               `thrift:"snapshotId,3" json:"snapshotId,omitempty"`
	TimeoutMs    *int32                `thrift:"timeoutMs,4" json:"timeoutMs,omitempty"`
	JobId        *string               `thrift:"jobId,5" json:"jobId,omitempty"`
	TaskId       *string               `thrift:"taskId,6" json:"taskId,omitempty"`
	Tag          *string               `thrift:"tag,7" json:"tag,omitempty"`
	BazelRequest *bazel.ExecuteRequest `thrift:"bazelRequest,8" json:"bazelRequest,omitempty"`
}

Attributes:

  • Argv
  • Env
  • SnapshotId
  • TimeoutMs
  • JobId
  • TaskId
  • Tag
  • BazelRequest
var WorkerRunArgs_Cmd_DEFAULT *RunCommand

func NewRunCommand 

func NewRunCommand() *RunCommand

func (*RunCommand) GetArgv 

func (p *RunCommand) GetArgv() []string

func (*RunCommand) GetBazelRequest 

func (p *RunCommand) GetBazelRequest() *bazel.ExecuteRequest

func (*RunCommand) GetEnv 

func (p *RunCommand) GetEnv() map[string]string

func (*RunCommand) GetJobId 

func (p *RunCommand) GetJobId() string

func (*RunCommand) GetSnapshotId 

func (p *RunCommand) GetSnapshotId() string

func (*RunCommand) GetTag 

func (p *RunCommand) GetTag() string

func (*RunCommand) GetTaskId 

func (p *RunCommand) GetTaskId() string

func (*RunCommand) GetTimeoutMs 

func (p *RunCommand) GetTimeoutMs() int32

func (*RunCommand) IsSetBazelRequest 

func (p *RunCommand) IsSetBazelRequest() bool

func (*RunCommand) IsSetEnv 

func (p *RunCommand) IsSetEnv() bool

func (*RunCommand) IsSetJobId 

func (p *RunCommand) IsSetJobId() bool

func (*RunCommand) IsSetSnapshotId 

func (p *RunCommand) IsSetSnapshotId() bool

func (*RunCommand) IsSetTag 

func (p *RunCommand) IsSetTag() bool

func (*RunCommand) IsSetTaskId 

func (p *RunCommand) IsSetTaskId() bool

func (*RunCommand) IsSetTimeoutMs 

func (p *RunCommand) IsSetTimeoutMs() bool

func (*RunCommand) Read 

func (p *RunCommand) Read(iprot thrift.TProtocol) error

func (*RunCommand) String 

func (p *RunCommand) String() string

func (*RunCommand) Write 

func (p *RunCommand) Write(oprot thrift.TProtocol) error

type RunStatus 

type RunStatus struct {
	Status       Status               `thrift:"status,1,required" json:"status"`
	RunId        string               `thrift:"runId,2,required" json:"runId"`
	OutUri       *string              `thrift:"outUri,3" json:"outUri,omitempty"`
	ErrUri       *string              `thrift:"errUri,4" json:"errUri,omitempty"`
	Error        *string              `thrift:"error,5" json:"error,omitempty"`
	ExitCode     *int32               `thrift:"exitCode,6" json:"exitCode,omitempty"`
	SnapshotId   *string              `thrift:"snapshotId,7" json:"snapshotId,omitempty"`
	JobId        *string              `thrift:"jobId,8" json:"jobId,omitempty"`
	TaskId       *string              `thrift:"taskId,9" json:"taskId,omitempty"`
	Tag          *string              `thrift:"tag,10" json:"tag,omitempty"`
	BazelResult_ *bazel.ActionResult_ `thrift:"bazelResult,11" json:"bazelResult,omitempty"`
}

Attributes:

  • Status
  • RunId
  • OutUri
  • ErrUri
  • Error
  • ExitCode
  • SnapshotId
  • JobId
  • TaskId
  • Tag
  • BazelResult_
var WorkerAbortResult_Success_DEFAULT *RunStatus
var WorkerRunResult_Success_DEFAULT *RunStatus

func NewRunStatus 

func NewRunStatus() *RunStatus

func (*RunStatus) GetBazelResult_ 

func (p *RunStatus) GetBazelResult_() *bazel.ActionResult_

func (*RunStatus) GetErrUri 

func (p *RunStatus) GetErrUri() string

func (*RunStatus) GetError 

func (p *RunStatus) GetError() string

func (*RunStatus) GetExitCode 

func (p *RunStatus) GetExitCode() int32

func (*RunStatus) GetJobId 

func (p *RunStatus) GetJobId() string

func (*RunStatus) GetOutUri 

func (p *RunStatus) GetOutUri() string

func (*RunStatus) GetRunId 

func (p *RunStatus) GetRunId() string

func (*RunStatus) GetSnapshotId 

func (p *RunStatus) GetSnapshotId() string

func (*RunStatus) GetStatus 

func (p *RunStatus) GetStatus() Status

func (*RunStatus) GetTag 

func (p *RunStatus) GetTag() string

func (*RunStatus) GetTaskId 

func (p *RunStatus) GetTaskId() string

func (*RunStatus) IsSetBazelResult_ 

func (p *RunStatus) IsSetBazelResult_() bool

func (*RunStatus) IsSetErrUri 

func (p *RunStatus) IsSetErrUri() bool

func (*RunStatus) IsSetError 

func (p *RunStatus) IsSetError() bool

func (*RunStatus) IsSetExitCode 

func (p *RunStatus) IsSetExitCode() bool

func (*RunStatus) IsSetJobId 

func (p *RunStatus) IsSetJobId() bool

func (*RunStatus) IsSetOutUri 

func (p *RunStatus) IsSetOutUri() bool

func (*RunStatus) IsSetSnapshotId 

func (p *RunStatus) IsSetSnapshotId() bool

func (*RunStatus) IsSetTag 

func (p *RunStatus) IsSetTag() bool

func (*RunStatus) IsSetTaskId 

func (p *RunStatus) IsSetTaskId() bool

func (*RunStatus) Read 

func (p *RunStatus) Read(iprot thrift.TProtocol) error

func (*RunStatus) String 

func (p *RunStatus) String() string

func (*RunStatus) Write 

func (p *RunStatus) Write(oprot thrift.TProtocol) error

type Status 

type Status int64
const (
	Status_UNKNOWN  Status = 0
	Status_PENDING  Status = 1
	Status_RUNNING  Status = 2
	Status_COMPLETE Status = 3
	Status_FAILED   Status = 4
	Status_ABORTED  Status = 5
	Status_TIMEDOUT Status = 6
)

func StatusFromString 

func StatusFromString(s string) (Status, error)

func StatusPtr 

func StatusPtr(v Status) *Status

func (Status) MarshalText 

func (p Status) MarshalText() ([]byte, error)

func (Status) String 

func (p Status) String() string

func (*Status) UnmarshalText 

func (p *Status) UnmarshalText(text []byte) error

type Worker 

type Worker interface {
	QueryWorker() (r *WorkerStatus, err error)
	// Parameters:
	//  - Cmd
	Run(cmd *RunCommand) (r *RunStatus, err error)
	// Parameters:
	//  - RunId
	Abort(runId string) (r *RunStatus, err error)
}

type WorkerAbortArgs 

type WorkerAbortArgs struct {
	RunId string `thrift:"runId,1" json:"runId"`
}

Attributes:

  • RunId

func NewWorkerAbortArgs 

func NewWorkerAbortArgs() *WorkerAbortArgs

func (*WorkerAbortArgs) GetRunId 

func (p *WorkerAbortArgs) GetRunId() string

func (*WorkerAbortArgs) Read 

func (p *WorkerAbortArgs) Read(iprot thrift.TProtocol) error

func (*WorkerAbortArgs) String 

func (p *WorkerAbortArgs) String() string

func (*WorkerAbortArgs) Write 

func (p *WorkerAbortArgs) Write(oprot thrift.TProtocol) error

type WorkerAbortResult 

type WorkerAbortResult struct {
	Success *RunStatus `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWorkerAbortResult 

func NewWorkerAbortResult() *WorkerAbortResult

func (*WorkerAbortResult) GetSuccess 

func (p *WorkerAbortResult) GetSuccess() *RunStatus

func (*WorkerAbortResult) IsSetSuccess 

func (p *WorkerAbortResult) IsSetSuccess() bool

func (*WorkerAbortResult) Read 

func (p *WorkerAbortResult) Read(iprot thrift.TProtocol) error

func (*WorkerAbortResult) String 

func (p *WorkerAbortResult) String() string

func (*WorkerAbortResult) Write 

func (p *WorkerAbortResult) Write(oprot thrift.TProtocol) error

type WorkerClient 

type WorkerClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewWorkerClientFactory 

func NewWorkerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *WorkerClient

func NewWorkerClientProtocol 

func NewWorkerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *WorkerClient

func (*WorkerClient) Abort 

func (p *WorkerClient) Abort(runId string) (r *RunStatus, err error)

Parameters:

  • RunId

func (*WorkerClient) QueryWorker 

func (p *WorkerClient) QueryWorker() (r *WorkerStatus, err error)

func (*WorkerClient) Run 

func (p *WorkerClient) Run(cmd *RunCommand) (r *RunStatus, err error)

Parameters:

  • Cmd

type WorkerProcessor 

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

func NewWorkerProcessor 

func NewWorkerProcessor(handler Worker) *WorkerProcessor

func (*WorkerProcessor) AddToProcessorMap 

func (p *WorkerProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*WorkerProcessor) GetProcessorFunction 

func (p *WorkerProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*WorkerProcessor) Process 

func (p *WorkerProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*WorkerProcessor) ProcessorMap 

func (p *WorkerProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type WorkerQueryWorkerArgs 

type WorkerQueryWorkerArgs struct {
}

func NewWorkerQueryWorkerArgs 

func NewWorkerQueryWorkerArgs() *WorkerQueryWorkerArgs

func (*WorkerQueryWorkerArgs) Read 

func (p *WorkerQueryWorkerArgs) Read(iprot thrift.TProtocol) error

func (*WorkerQueryWorkerArgs) String 

func (p *WorkerQueryWorkerArgs) String() string

func (*WorkerQueryWorkerArgs) Write 

func (p *WorkerQueryWorkerArgs) Write(oprot thrift.TProtocol) error

type WorkerQueryWorkerResult 

type WorkerQueryWorkerResult struct {
	Success *WorkerStatus `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWorkerQueryWorkerResult 

func NewWorkerQueryWorkerResult() *WorkerQueryWorkerResult

func (*WorkerQueryWorkerResult) GetSuccess 

func (p *WorkerQueryWorkerResult) GetSuccess() *WorkerStatus

func (*WorkerQueryWorkerResult) IsSetSuccess 

func (p *WorkerQueryWorkerResult) IsSetSuccess() bool

func (*WorkerQueryWorkerResult) Read 

func (p *WorkerQueryWorkerResult) Read(iprot thrift.TProtocol) error

func (*WorkerQueryWorkerResult) String 

func (p *WorkerQueryWorkerResult) String() string

func (*WorkerQueryWorkerResult) Write 

func (p *WorkerQueryWorkerResult) Write(oprot thrift.TProtocol) error

type WorkerRunArgs 

type WorkerRunArgs struct {
	Cmd *RunCommand `thrift:"cmd,1" json:"cmd"`
}

Attributes:

  • Cmd

func NewWorkerRunArgs 

func NewWorkerRunArgs() *WorkerRunArgs

func (*WorkerRunArgs) GetCmd 

func (p *WorkerRunArgs) GetCmd() *RunCommand

func (*WorkerRunArgs) IsSetCmd 

func (p *WorkerRunArgs) IsSetCmd() bool

func (*WorkerRunArgs) Read 

func (p *WorkerRunArgs) Read(iprot thrift.TProtocol) error

func (*WorkerRunArgs) String 

func (p *WorkerRunArgs) String() string

func (*WorkerRunArgs) Write 

func (p *WorkerRunArgs) Write(oprot thrift.TProtocol) error

type WorkerRunResult 

type WorkerRunResult struct {
	Success *RunStatus `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewWorkerRunResult 

func NewWorkerRunResult() *WorkerRunResult

func (*WorkerRunResult) GetSuccess 

func (p *WorkerRunResult) GetSuccess() *RunStatus

func (*WorkerRunResult) IsSetSuccess 

func (p *WorkerRunResult) IsSetSuccess() bool

func (*WorkerRunResult) Read 

func (p *WorkerRunResult) Read(iprot thrift.TProtocol) error

func (*WorkerRunResult) String 

func (p *WorkerRunResult) String() string

func (*WorkerRunResult) Write 

func (p *WorkerRunResult) Write(oprot thrift.TProtocol) error

type WorkerStatus 

type WorkerStatus struct {
	Runs        []*RunStatus `thrift:"runs,1,required" json:"runs"`
	Initialized bool         `thrift:"initialized,2,required" json:"initialized"`
	Error       string       `thrift:"error,3,required" json:"error"`
}

Attributes:

  • Runs
  • Initialized
  • Error
var WorkerQueryWorkerResult_Success_DEFAULT *WorkerStatus

func NewWorkerStatus 

func NewWorkerStatus() *WorkerStatus

func (*WorkerStatus) GetError 

func (p *WorkerStatus) GetError() string

func (*WorkerStatus) GetInitialized 

func (p *WorkerStatus) GetInitialized() bool

func (*WorkerStatus) GetRuns 

func (p *WorkerStatus) GetRuns() []*RunStatus

func (*WorkerStatus) Read 

func (p *WorkerStatus) Read(iprot thrift.TProtocol) error

func (*WorkerStatus) String 

func (p *WorkerStatus) String() string

func (*WorkerStatus) Write 

func (p *WorkerStatus) Write(oprot thrift.TProtocol) error

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.