sundial

package

Go to main page

Versions in this module

v0

v0.11.0

Jan 31, 2024

Changes in this version

+ func PrintWorkflowSummary(c *cli.Context, sdkClient sdkclient.Client, wfId, runId string) error

+ type Row struct

+ Key string

+ Value string

v0.10.7

Nov 17, 2023

v0.10.6

Sep 29, 2023

v0.10.5

Aug 1, 2023

v0.10.4

Jul 26, 2023

v0.10.3

Jul 21, 2023

v0.10.2

Jul 17, 2023

v0.10.1

Jul 12, 2023

v0.10.0

Jun 23, 2023

Changes in this version

+ const AnsiEraseToEnd

+ const AnsiMoveCursorStartLine

+ const AnsiMoveCursorUp

+ const MinFoldingDepth

+ var StatusCancelRequested string = color.YellowString("▷")

+ var StatusCanceled string = color.YellowString("x")

+ var StatusCompleted string = color.GreenString("✓")

+ var StatusContinueAsNew string = color.GreenString("»")

+ var StatusFailed string = color.RedString("!")

+ var StatusIconsLegend = []StatusIcon

+ var StatusRunning string = color.BlueString("▷")

+ var StatusTerminated string = color.RedString("x")

+ var StatusTimedOut string = color.RedString("⏱")

+ var StatusTimerCanceled string = color.YellowString("⧖")

+ var StatusTimerFired string = color.GreenString("⧖")

+ var StatusTimerWaiting string = color.BlueString("⧖")

+ var StatusUnspecifiedScheduled string = "•"

+ func CountBytesPrintWidth(b []byte) int

+ func DiffDuration(start *time.Time, close *time.Time) string

+ func ExecutionStatus(exec ExecutionState) string

+ func FmtDuration(duration time.Duration) string

+ func LineHeight(line []byte, maxWidth int) int

+ func MoveCursorUp(lines int) string

+ func NewTailBoxBoundBuffer(buf *bytes.Buffer, maxLines int, maxWidth int) (*bytes.Buffer, int)

+ func PrintAndExit(writer *TermWriter, tmpl *ExecutionTemplate, update *WorkflowExecutionUpdate) (int, error)

+ func PrintWorkflowTrace(c *cli.Context, wid, rid string, foldStatus []enums.WorkflowExecutionStatus) (int, error)

+ func ProgressString(currentEvents int64, totalEvents int64) string

+ func ReverseLinesBuffer(buf *bytes.Buffer) [][]byte

+ func ShouldFoldStatus(foldStatus []enums.WorkflowExecutionStatus, noFold bool) func(*WorkflowExecutionState, int) bool

+ func StripBytesAnsi(b []byte) []byte

+ type CONSOLE_SCREEN_BUFFER_INFO struct — windows/amd64

+ Attributes WORD

+ CursorPosition COORD

+ MaximumWindowSize COORD

+ Size COORD

+ Window SMALL_RECT

+ type COORD struct — windows/amd64

+ X SHORT

+ Y SHORT

+ type ExecutionTemplate struct

+ func NewExecutionTemplate(w io.Writer, foldStatus []enums.WorkflowExecutionStatus, noFold bool) (*ExecutionTemplate, error)

+ func (t *ExecutionTemplate) Execute(state ExecutionState, depth int) error

+ type SHORT int16 — windows/amd64

+ type SMALL_RECT struct — windows/amd64

+ Bottom SHORT

+ Left SHORT

+ Right SHORT

+ Top SHORT

+ type StateTemplate struct

+ Depth int

+ State ExecutionState

+ type StatusIcon struct

+ Icon string

+ Name string

+ type TermWriter struct

+ func NewTermWriter() *TermWriter

+ func (w *TermWriter) Flush(trim bool) error

+ func (w *TermWriter) GetSize() (int, int)

+ func (w *TermWriter) WithSize(width, height int) *TermWriter

+ func (w *TermWriter) WithTerminalSize() *TermWriter

+ func (w *TermWriter) WithWriter(out io.Writer) *TermWriter

+ func (w *TermWriter) Write(buf []byte) (n int, err error)

+ func (w *TermWriter) WriteString(s string) (n int, err error)

+ type WORD uint16 — windows/amd64

v0.9.0

May 12, 2023

Changes in this version

+ func GetExitCode(exec *WorkflowExecutionState) int

+ func GetFoldStatus(c *cli.Context) ([]enums.WorkflowExecutionStatus, error)

type WorkflowExecutionState

+ func (state *WorkflowExecutionState) GetChildWorkflowByEventId(initiatedEventId int64) (*WorkflowExecutionState, bool)

+ func (state *WorkflowExecutionState) IsClosed() (bool, error)

+ type WorkflowExecutionUpdate struct

+ State *WorkflowExecutionState

+ func (update *WorkflowExecutionUpdate) GetState() *WorkflowExecutionState

+ type WorkflowExecutionUpdateIterator interface

+ HasNext func() bool

+ Next func() (*WorkflowExecutionUpdate, error)

+ func GetWorkflowExecutionUpdates(ctx context.Context, client sdkclient.Client, wfId, runId string, ...) (WorkflowExecutionUpdateIterator, error)

+ type WorkflowExecutionUpdateIteratorImpl struct

+ func (iter *WorkflowExecutionUpdateIteratorImpl) HasNext() bool

+ func (iter *WorkflowExecutionUpdateIteratorImpl) Next() (*WorkflowExecutionUpdate, error)

+ type WorkflowStateJob struct

+ func NewWorkflowStateJob(ctx context.Context, client sdkclient.Client, state *WorkflowExecutionState, ...) (*WorkflowStateJob, error)

+ func (job *WorkflowStateJob) GetChildJob(event *history.HistoryEvent) (*WorkflowStateJob, error)

+ func (job *WorkflowStateJob) Run(group *pond.TaskGroupWithContext) func() error

+ func (job *WorkflowStateJob) ShouldStart() bool

v0.8.0

Mar 31, 2023

v0.7.0

Mar 29, 2023

v0.6.0

Mar 11, 2023

v0.4.0

Feb 8, 2023

v0.3.0

Jan 27, 2023

v0.2.0

Dec 1, 2022

Changes in this version

+ type ActivityExecutionState struct

+ ActivityId string

+ Attempt int32

+ CloseTime *time.Time

+ Failure *failure.Failure

+ RetryState enums.RetryState

+ StartTime *time.Time

+ Status ActivityExecutionStatus

+ Type *common.ActivityType

+ func NewActivityExecutionState() *ActivityExecutionState

+ func (state *ActivityExecutionState) GetAttempt() int32

+ func (state *ActivityExecutionState) GetDuration() *time.Duration

+ func (state *ActivityExecutionState) GetFailure() *failure.Failure

+ func (state *ActivityExecutionState) GetName() string

+ func (state *ActivityExecutionState) GetRetryState() enums.RetryState

+ func (state *ActivityExecutionState) GetStartTime() *time.Time

+ func (state *ActivityExecutionState) Update(event *history.HistoryEvent)

+ type ActivityExecutionStatus int32

+ var ACTIVITY_EXECUTION_STATUS_CANCELED ActivityExecutionStatus = 7

+ var ACTIVITY_EXECUTION_STATUS_CANCEL_REQUESTED ActivityExecutionStatus = 6

+ var ACTIVITY_EXECUTION_STATUS_COMPLETED ActivityExecutionStatus = 3

+ var ACTIVITY_EXECUTION_STATUS_FAILED ActivityExecutionStatus = 4

+ var ACTIVITY_EXECUTION_STATUS_RUNNING ActivityExecutionStatus = 2

+ var ACTIVITY_EXECUTION_STATUS_SCHEDULED ActivityExecutionStatus = 1

+ var ACTIVITY_EXECUTION_STATUS_TIMED_OUT ActivityExecutionStatus = 5

+ var ACTIVITY_EXECUTION_STATUS_UNSPECIFIED ActivityExecutionStatus = 0

+ type ExecutionState interface

+ GetAttempt func() int32

+ GetDuration func() *time.Duration

+ GetFailure func() *failure.Failure

+ GetName func() string

+ GetRetryState func() enums.RetryState

+ GetStartTime func() *time.Time

+ Update func(*history.HistoryEvent)

+ type TimerExecutionState struct

+ CloseTime *time.Time

+ Name string

+ StartTime *time.Time

+ StartToFireTimeout *time.Duration

+ Status TimerExecutionStatus

+ TimerId string

+ func (t *TimerExecutionState) GetAttempt() int32

+ func (t *TimerExecutionState) GetDuration() *time.Duration

+ func (t *TimerExecutionState) GetFailure() *failure.Failure

+ func (t *TimerExecutionState) GetName() string

+ func (t *TimerExecutionState) GetRetryState() enums.RetryState

+ func (t *TimerExecutionState) GetStartTime() *time.Time

+ func (t *TimerExecutionState) Update(event *history.HistoryEvent)

+ type TimerExecutionStatus int32

+ var TIMER_STATUS_CANCELED TimerExecutionStatus = 2

+ var TIMER_STATUS_FIRED TimerExecutionStatus = 1

+ var TIMER_STATUS_WAITING TimerExecutionStatus = 0

+ type WorkflowExecutionState struct

+ Attempt int32

+ CancelRequest *history.WorkflowExecutionCancelRequestedEventAttributes

+ ChildStates []ExecutionState

+ CloseTime *time.Time

+ Execution *common.WorkflowExecution

+ Failure *failure.Failure

+ HistoryLength int64

+ IsArchived bool

+ LastEventId int64

+ MaximumAttempts int32

+ ParentWorkflowExecution *common.WorkflowExecution

+ RetryState enums.RetryState

+ StartTime *time.Time

+ Status enums.WorkflowExecutionStatus

+ Termination *history.WorkflowExecutionTerminatedEventAttributes

+ Type *common.WorkflowType

+ WorkflowExecutionTimeout *time.Duration

+ func NewWorkflowExecutionState(wfId, runId string) *WorkflowExecutionState

+ func (state *WorkflowExecutionState) FindChildWorkflow(execution *common.WorkflowExecution) *WorkflowExecutionState

+ func (state *WorkflowExecutionState) GetAttempt() int32

+ func (state *WorkflowExecutionState) GetDuration() *time.Duration

+ func (state *WorkflowExecutionState) GetFailure() *failure.Failure

+ func (state *WorkflowExecutionState) GetName() string

+ func (state *WorkflowExecutionState) GetNumberOfEvents() (int64, int64)

+ func (state *WorkflowExecutionState) GetRetryState() enums.RetryState

+ func (state *WorkflowExecutionState) GetStartTime() *time.Time

+ func (state *WorkflowExecutionState) IsCompleted() bool

+ func (state *WorkflowExecutionState) Update(event *history.HistoryEvent)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL