futures

Documentation

Index

• Constants
• type After
  • func NewAfter(suspensionCtx context.Context, entry *wire.SleepEntryMessage, ...) *After
  • func (a *After) Done() error
• type Awakeable
  • func NewAwakeable(suspensionCtx context.Context, invocationID []byte, ...) *Awakeable
  • func (c *Awakeable) Id() string
  • func (c *Awakeable) Result() ([]byte, error)
• type Promise
  • func NewPromise(suspensionCtx context.Context, invocationID []byte, ...) *Promise
  • func (c *Promise) Result() ([]byte, error)
• type ResponseFuture
  • func NewResponseFuture(suspensionCtx context.Context, entry *wire.CallEntryMessage, entryIndex uint32, ...) *ResponseFuture
  • func (r *ResponseFuture) Response() ([]byte, error)
• type Selectable
• type Selector
  • func Select(suspensionCtx context.Context, futs ...Selectable) *Selector
  • func (s *Selector) Indexes() []uint32
  • func (s *Selector) Remaining() bool
  • func (s *Selector) Select() (uint32, bool)
  • func (s *Selector) Take(winningEntryIndex uint32) Selectable

Constants

const AWAKEABLE_IDENTIFIER_PREFIX = "prom_1"

Types

type After

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

func NewAfter

func NewAfter(suspensionCtx context.Context, entry *wire.SleepEntryMessage, entryIndex uint32) *After

func (*After) Done

func (a *After) Done() error

type Awakeable

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

func NewAwakeable

func NewAwakeable(suspensionCtx context.Context, invocationID []byte, entry *wire.AwakeableEntryMessage, entryIndex uint32) *Awakeable

func (*Awakeable) Id

func (c *Awakeable) Id() string

func (*Awakeable) Result

func (c *Awakeable) Result() ([]byte, error)

type Promise

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

func NewPromise

func NewPromise(suspensionCtx context.Context, invocationID []byte, getPromise func() (*wire.GetPromiseEntryMessage, uint32)) *Promise

func (*Promise) Result

func (c *Promise) Result() ([]byte, error)

type ResponseFuture

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

func NewResponseFuture

func NewResponseFuture(suspensionCtx context.Context, entry *wire.CallEntryMessage, entryIndex uint32, newProtocolViolation func(error) any) *ResponseFuture

func (*ResponseFuture) Response

func (r *ResponseFuture) Response() ([]byte, error)

type Selectable

type Selectable interface {
	// contains filtered or unexported methods
}

type Selector

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

func Select

func Select(suspensionCtx context.Context, futs ...Selectable) *Selector

func (*Selector) Indexes

func (s *Selector) Indexes() []uint32

func (*Selector) Remaining

func (s *Selector) Remaining() bool

func (*Selector) Select

func (s *Selector) Select() (uint32, bool)

func (*Selector) Take

func (s *Selector) Take(winningEntryIndex uint32) Selectable