internal

Documentation

Index

• Variables
• type Lock
  • func NewLock(opts LockOptions) *Lock
  • func (l *Lock) Close()
  • func (l *Lock) CloseUntil(d time.Duration)
  • func (l *Lock) Lock() (context.CancelFunc, error)
  • func (l *Lock) LockRequest(msg *invokev1.InvokeMethodRequest) (context.CancelFunc, error)
• type LockOptions

Variables

var ErrLockClosed = errors.New("actor lock is closed")

Types

type Lock

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

Lock is a fifo Mutex which respects reentrancy and stack depth.

func NewLock

func NewLock(opts LockOptions) *Lock

func (*Lock) Close

func (l *Lock) Close()

func (*Lock) CloseUntil

func (l *Lock) CloseUntil(d time.Duration)

func (*Lock) Lock

func (l *Lock) Lock() (context.CancelFunc, error)

func (*Lock) LockRequest

func (l *Lock) LockRequest(msg *invokev1.InvokeMethodRequest) (context.CancelFunc, error)

type LockOptions

type LockOptions struct {
	ActorType         string
	ReentrancyEnabled bool
	MaxStackDepth     int
}