workflow

Documentation

Index

• Variables
• func CronActivity(ctx context.Context) error
• func CronWorkflow(ctx workflow.Context) error
• func NewContextPropagator() workflow.ContextPropagator
• func PublishEventActivity(ctx context.Context) error
• func PublishEventWorkflow(ctx workflow.Context) error
• func SetManager(m *Manager)
• func WithdrawActivity(ctx context.Context) error
• type Manager
• type Values

Variables

var PropagateKey = contextKey{}

PropagateKey is the key used to store the value in the Context object

Functions

func CronActivity

func CronActivity(ctx context.Context) error

func CronWorkflow

func CronWorkflow(ctx workflow.Context) error

CronWorkflow is a cron workflow definition.

func NewContextPropagator

func NewContextPropagator() workflow.ContextPropagator

NewContextPropagator returns a context propagator that propagates a set of string key-value pairs across a workflow

func PublishEventActivity

func PublishEventActivity(ctx context.Context) error

PublishEventActivity ...

func PublishEventWorkflow

func PublishEventWorkflow(ctx workflow.Context) error

PublishEventWorkflow ...

func SetManager

func SetManager(m *Manager)

SetManager allow extenal to pass Manager instance to workflow. The manager instance will be used in the package.

func WithdrawActivity

func WithdrawActivity(ctx context.Context) error

WithdrawActivity ...

Types

type Manager

type Manager struct {
	Config       config.Configuration
	WalletClient walletProto.WalletServiceClient
	EventClient  eventProto.EventServiceClient
}

Manager is a group of grpc clients.

type Values

type Values struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

Values is a struct holding values