ebbandflow

Documentation

Index

• func EbbAndFlowTrackWorkflow(ctx workflow.Context, params *ebbandflow.WorkflowParams) (*ebbandflow.WorkflowOutput, error)
• type Activities
  • func (a Activities) MeasureLatencyActivity(ctx context.Context, activityAction *kitchensink.ExecuteActivityAction) (ActivityExecutionResult, error)
• type ActivityExecutionResult

Functions

func EbbAndFlowTrackWorkflow

func EbbAndFlowTrackWorkflow(ctx workflow.Context, params *ebbandflow.WorkflowParams) (*ebbandflow.WorkflowOutput, error)

EbbAndFlowTrackWorkflow executes activities and returns their schedule-to-start times with fairness data

Types

type Activities

type Activities struct{}

func (Activities) MeasureLatencyActivity

func (a Activities) MeasureLatencyActivity(
	ctx context.Context,
	activityAction *kitchensink.ExecuteActivityAction,
) (ActivityExecutionResult, error)

type ActivityExecutionResult

type ActivityExecutionResult struct {
	ScheduledTime   time.Time `json:"scheduledTime"`
	ActualStartTime time.Time `json:"actualStartTime"`
}