actor

README

actor

experiments

Documentation

Index

• func Start[T any](ctx context.Context, mailbox Mailbox[T], callbacks Callbacks[T], ...)
• type Callbacks
• type Mailbox
• type MailboxSize
• type Option
  • func WithAbsoluteTimeout(timeout time.Duration) Option
  • func WithIdleTimeout(timeout time.Duration) Option
  • func WithRespawnAfter(respawnAfter RequestCount) Option
• type RequestCount

Functions

func Start

func Start[T any](ctx context.Context, mailbox Mailbox[T], callbacks Callbacks[T], options ...Option)

Types

type Callbacks

type Callbacks[T any] interface {
	Received(T)
	Stopped()
}

type Mailbox

type Mailbox[T any] <-chan T

type MailboxSize

type MailboxSize int

type Option

type Option func(actorOptions) actorOptions

func WithAbsoluteTimeout

func WithAbsoluteTimeout(timeout time.Duration) Option

func WithIdleTimeout

func WithIdleTimeout(timeout time.Duration) Option

func WithRespawnAfter

func WithRespawnAfter(respawnAfter RequestCount) Option

type RequestCount

type RequestCount int