internal

Documentation

Index

• Constants
• type Runnable
• type RunnableContainer
  • func WrapRunnable(runnable Runnable, submitTime clock.MonotonicTime) *RunnableContainer
  • func (c *RunnableContainer) Info() RuntimeInfo
  • func (c *RunnableContainer) OnLaunched()
  • func (c *RunnableContainer) OnStopped()
  • func (c *RunnableContainer) Status() RunnableStatus
• type RunnableID
• type RunnableStatus
• type RuntimeInfo

Constants

const (
	TaskSubmitted = RunnableStatus(iota + 1)
	TaskRunning
	TaskClosing
)

Defines all RunnableStatus

Types

type Runnable

type Runnable interface {
	Run(ctx context.Context) error
	ID() RunnableID
}

Runnable defines an interface that can be run in task runner

type RunnableContainer

type RunnableContainer struct {
	Runnable
	// contains filtered or unexported fields
}

RunnableContainer implements Runnable, and maintains some more running information

func WrapRunnable

func WrapRunnable(runnable Runnable, submitTime clock.MonotonicTime) *RunnableContainer

WrapRunnable creates a new RunnableContainer from a Runnable interface

func (*RunnableContainer) Info

func (c *RunnableContainer) Info() RuntimeInfo

Info returns the info of RunnableContainer

func (*RunnableContainer) OnLaunched

func (c *RunnableContainer) OnLaunched()

OnLaunched is the callback when the runnable instance is launched.

func (*RunnableContainer) OnStopped

func (c *RunnableContainer) OnStopped()

OnStopped is the callback when the runnable instance is stopped

func (*RunnableContainer) Status

func (c *RunnableContainer) Status() RunnableStatus

Status returns the status of RunnableContainer

type RunnableID

type RunnableID = string

RunnableID is a unique id for the runnable

type RunnableStatus

type RunnableStatus = int32

RunnableStatus is the runtime container status

type RuntimeInfo

type RuntimeInfo struct {
	SubmitTime clock.MonotonicTime
}

RuntimeInfo records some information related to the runnable object