message

package

v0.1.0 Latest Latest Go to latest Published: Jun 16, 2022 License: MIT Imports: 8 Imported by: 0

Details

View Source

const (
	InMemoryBusMaximumInFlightMessage = 4096
)

This section is empty.

This section is empty.

type Bus interface {
	Emit(ctx context.Context, message Message) error
	Read(ctx context.Context) (<-chan Message, context.CancelFunc)
}

type Handler func(ctx context.Context, message Message) (Message, error)

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

func NewInMemoryBus() *InMemoryBus

func (i *InMemoryBus) Emit(ctx context.Context, message Message) error

func (i *InMemoryBus) Read(ctx context.Context) (<-chan Message, context.CancelFunc)

type Message struct {
	ID      xid.ID
	Kind    string
	Payload any
}

func New(kind string, payload any) Message

func (m Message) CreatedAt() time.Time

func (m Message) Node() []byte

type NoOpBus struct{}

func NewNoopBus() *NoOpBus

func (NoOpBus) Emit(_ context.Context, _ Message) error

func (NoOpBus) Read(_ context.Context) (<-chan Message, context.CancelFunc)

type Registry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (r *Registry) Register(kind string, handler Handler) uint32

func (r *Registry) Unregister(kind string, slot uint32) error

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

func (r *RegistrySlot) Register(handler Handler) uint32

func (r *RegistrySlot) Unregister(slot uint32) error