largepayload

README

This fixture starts several workflows (NumberOfWorkflows) with payloads of size 1mb (PayloadSize). These payloads include:

• memo
• activity input
• activity result

Used in:

• Web UI performance testing

Documentation

Index

• func LargePayloadWorkflow(ctx workflow.Context, payloadSize int) (err error)
• type Activities
  • func (a *Activities) CreateLargeResultActivity(ctx context.Context, sizeBytes int) ([]byte, error)
  • func (a *Activities) ProcessLargeInputActivity(ctx context.Context, input []byte) error

Functions

func LargePayloadWorkflow

func LargePayloadWorkflow(ctx workflow.Context, payloadSize int) (err error)

LargePayloadWorkflow workflow definition

Types

type Activities

type Activities struct {
}

func (*Activities) CreateLargeResultActivity

func (a *Activities) CreateLargeResultActivity(ctx context.Context, sizeBytes int) ([]byte, error)

func (*Activities) ProcessLargeInputActivity

func (a *Activities) ProcessLargeInputActivity(ctx context.Context, input []byte) error