inbox

Documentation

Index

• Constants
• type Inbox
  • func NewInbox[T constraints.Signed, V any](initialSize T) *Inbox[V]
  • func (slf *Inbox[V]) Push(env V)
  • func (slf *Inbox[V]) Start(processor Processor[V])
  • func (slf *Inbox[V]) Stop() error
• type Processor

Constants

const (
	IDLE int32 = iota
	RUNNING
)

Types

type Inbox

type Inbox[V any] struct {
	// contains filtered or unexported fields
}

func NewInbox

func NewInbox[T constraints.Signed, V any](initialSize T) *Inbox[V]

func (*Inbox[V]) Push

func (slf *Inbox[V]) Push(env V)

func (*Inbox[V]) Start

func (slf *Inbox[V]) Start(processor Processor[V])

func (*Inbox[V]) Stop

func (slf *Inbox[V]) Stop() error

type Processor

type Processor[V any] interface {
	Invoke(envelopes []V)
}