throughputstress

Documentation

Index

• Constants
• func ThroughputStressChild(ctx workflow.Context) error
• func ThroughputStressWorkflow(ctx workflow.Context, params *throughputstress.WorkflowParams) (throughputstress.WorkflowOutput, error)
• type Activities
  • func (a *Activities) Payload(_ context.Context, in *PayloadActivityInput) ([]byte, error)
  • func (a *Activities) SelfDescribe(ctx context.Context) error
  • func (a *Activities) SelfQuery(ctx context.Context, queryType string) error
  • func (a *Activities) SelfSignal(ctx context.Context, signalName string) error
  • func (a *Activities) SelfUpdate(ctx context.Context, updateName string) error
• type PayloadActivityInput
  • func MakePayloadInput(inSize, outSize int) *PayloadActivityInput

Constants

const (
	UpdateSleep         = "sleep"
	UpdateActivity      = "activity"
	UpdateLocalActivity = "localActivity"
	ASignal             = "someSignal"
)

Functions

func ThroughputStressChild

func ThroughputStressChild(ctx workflow.Context) error

func ThroughputStressWorkflow

func ThroughputStressWorkflow(ctx workflow.Context, params *throughputstress.WorkflowParams) (throughputstress.WorkflowOutput, error)

ThroughputStressWorkflow is meant to mimic the throughputstress scenario from bench-go of days past, but in a less-opaque way. We do not ask why it is the way it is, it is not our place to question the inscrutable ways of the old code.

Types

type Activities

type Activities struct {
	Client client.Client
}

func (*Activities) Payload

func (a *Activities) Payload(_ context.Context, in *PayloadActivityInput) ([]byte, error)

Payload serves no purpose other than to accept inputs and return outputs of a specific size.

func (*Activities) SelfDescribe

func (a *Activities) SelfDescribe(ctx context.Context) error

func (*Activities) SelfQuery

func (a *Activities) SelfQuery(ctx context.Context, queryType string) error

func (*Activities) SelfSignal

func (a *Activities) SelfSignal(ctx context.Context, signalName string) error

func (*Activities) SelfUpdate

func (a *Activities) SelfUpdate(ctx context.Context, updateName string) error

type PayloadActivityInput

type PayloadActivityInput struct {
	IgnoredInputData []byte
	// DesiredOutputSize determines the size of the output data in bytes, filled randomly.
	DesiredOutputSize int
}

func MakePayloadInput

func MakePayloadInput(inSize, outSize int) *PayloadActivityInput