Documentation
¶
Index ¶
Constants ¶
View Source
const (
InMemoryBusMaximumInFlightMessage = 4096
)
Variables ¶
View Source
var GlobalDecoderRegistry = NewRegistry()
Functions ¶
This section is empty.
Types ¶
type DecoderFunc ¶ added in v0.1.3
func NewDecoder ¶ added in v0.1.3
func NewDecoder[T any]() DecoderFunc
type DecoderRegistry ¶ added in v0.1.3
type DecoderRegistry struct {
// contains filtered or unexported fields
}
func NewRegistry ¶ added in v0.1.3
func NewRegistry() *DecoderRegistry
func (*DecoderRegistry) Decode ¶ added in v0.1.3
func (r *DecoderRegistry) Decode(kind string, buf []byte) (any, error)
func (*DecoderRegistry) Register ¶ added in v0.1.3
func (r *DecoderRegistry) Register(kind string, decoderFunc DecoderFunc) *DecoderRegistry
type InMemoryBus ¶
type InMemoryBus struct{}
func NewInMemoryBus ¶
func NewInMemoryBus() *InMemoryBus
type InMemoryMailbox ¶ added in v0.1.3
type InMemoryMailbox struct {
// contains filtered or unexported fields
}
func NewInMemoryMailbox ¶ added in v0.1.3
func NewInMemoryMailbox() *InMemoryMailbox
func (*InMemoryMailbox) Emit ¶ added in v0.1.3
func (i *InMemoryMailbox) Emit(ctx context.Context, message Message) error
func (*InMemoryMailbox) ReadC ¶ added in v0.1.3
func (i *InMemoryMailbox) ReadC(ctx context.Context) (<-chan Message, context.CancelFunc)
type Message ¶
func Unmarshall ¶ added in v0.1.3
Click to show internal directories.
Click to hide internal directories.