batchfuture

Documentation

Index

• type BatchFuture
  • func NewBatchFuture(ctx workflow.Context, batchSize int, ...) (*BatchFuture, error)
  • func (b *BatchFuture) Get(ctx workflow.Context, valuePtr interface{}) error
  • func (b *BatchFuture) GetFutures() []workflow.Future
  • func (b *BatchFuture) IsReady() bool

Types

type BatchFuture

type BatchFuture struct {
	// contains filtered or unexported fields
}

BatchFuture is an implementation of public BatchFuture interface.

func NewBatchFuture

func NewBatchFuture(ctx workflow.Context, batchSize int, factories []func(ctx workflow.Context) workflow.Future) (*BatchFuture, error)

func (*BatchFuture) Get

func (b *BatchFuture) Get(ctx workflow.Context, valuePtr interface{}) error

Get assigns the result of the futures to the valuePtr. NOTE: valuePtr must be a pointer to a slice, or nil. If valuePtr is a pointer to a slice, the slice will be resized to the length of the futures. Each element of the slice will be assigned with the underlying Future.Get() and thus behaves the same way. If valuePtr is nil, no assignment will be made. If error occurs, values will be set on successful futures and the errors of failed futures will be returned.

func (*BatchFuture) GetFutures

func (b *BatchFuture) GetFutures() []workflow.Future

func (*BatchFuture) IsReady

func (b *BatchFuture) IsReady() bool