Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const BadQuboleReturnCodeError + const DefaultClusterPrimaryLabel + const ResyncDuration + func Abort(ctx context.Context, tCtx core.TaskExecutionContext, ...) error + func BuildResourceConfig(cfg []config.ClusterConfig) map[core.ResourceNamespace]int + func ConstructTaskInfo(e ExecutionState) *core.TaskInfo + func ConstructTaskLog(e ExecutionState) *idlCore.TaskLog + func Finalize(ctx context.Context, tCtx core.TaskExecutionContext, _ ExecutionState, ...) error + func GetMockTaskExecutionContext() core.TaskExecutionContext + func GetMockTaskExecutionMetadata() core.TaskExecutionMetadata + func GetQueryInfo(ctx context.Context, tCtx core.TaskExecutionContext) (formattedQuery string, cluster string, tags []string, timeoutSec uint32, ...) + func GetSingleHiveQueryTaskTemplate() idlCore.TaskTemplate + func InTerminalState(e ExecutionState) bool + func InitializeHiveExecutor(ctx context.Context, iCtx core.SetupContext, cfg *config.Config, ...) (core.Plugin, error) + func IsNotYetSubmitted(e ExecutionState) bool + func MapExecutionStateToPhaseInfo(state ExecutionState, _ client.QuboleClient) core.PhaseInfo + func QuboleHiveExecutorLoader(ctx context.Context, iCtx core.SetupContext) (core.Plugin, error) + type ExecutionPhase int + const PhaseNotStarted + const PhaseQueryFailed + const PhaseQuerySucceeded + const PhaseQueued + const PhaseSubmitted + const PhaseWriteOutputFile + func QuboleStatusToExecutionPhase(s client.QuboleStatus) (ExecutionPhase, error) + func (p ExecutionPhase) IsTerminal() bool + func (p ExecutionPhase) String() string + type ExecutionState struct + AllocationTokenRequestStartTime time.Time + CommandID string + CreationFailureCount int + Phase ExecutionPhase + SyncFailureCount int + URI string + func GetAllocationToken(ctx context.Context, tCtx core.TaskExecutionContext, ...) (ExecutionState, error) + func HandleExecutionState(ctx context.Context, tCtx core.TaskExecutionContext, ...) (ExecutionState, error) + func KickOffQuery(ctx context.Context, tCtx core.TaskExecutionContext, ...) (ExecutionState, error) + func MonitorQuery(ctx context.Context, tCtx core.TaskExecutionContext, ...) (ExecutionState, error) + func WriteOutputs(ctx context.Context, tCtx core.TaskExecutionContext, ...) (ExecutionState, error) + type ExecutionStateCacheItem struct + Identifier string + func (e ExecutionStateCacheItem) ID() string + func (e ExecutionStateCacheItem) IsTerminal() bool + type QuboleHiveExecutionsCache struct + func NewQuboleHiveExecutionsCache(ctx context.Context, quboleClient client.QuboleClient, ...) (QuboleHiveExecutionsCache, error) + func (q *QuboleHiveExecutionsCache) SyncQuboleQuery(ctx context.Context, batch cache.Batch) (updatedBatch []cache.ItemSyncResponse, err error) + type QuboleHiveExecutor struct + func NewQuboleHiveExecutor(ctx context.Context, cfg *config.Config, quboleClient client.QuboleClient, ...) (QuboleHiveExecutor, error) + func (q QuboleHiveExecutor) Abort(ctx context.Context, tCtx core.TaskExecutionContext) error + func (q QuboleHiveExecutor) Finalize(ctx context.Context, tCtx core.TaskExecutionContext) error + func (q QuboleHiveExecutor) GetID() string + func (q QuboleHiveExecutor) GetProperties() core.PluginProperties + func (q QuboleHiveExecutor) Handle(ctx context.Context, tCtx core.TaskExecutionContext) (core.Transition, error) + type QuboleHiveExecutorMetrics struct + AllocationGranted labeled.Counter + AllocationNotGranted labeled.Counter + ResourceReleaseFailed labeled.Counter + ResourceReleased labeled.Counter + ResourceWaitTime prometheus.Summary + Scope promutils.Scope
Go to main page