adapter

type Consumer interface {
	Receive(ctx context.Context) (Message, error)
	Close() error
}

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

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

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

type MemoryOptions struct {
	BufferSize int
}

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

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

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

type Message interface {
	ID() string
	Key() string
	Envelope() *core.Envelope
	Ack(ctx context.Context) error
	Nack(ctx context.Context, err error) error
}

type Producer interface {
	Publish(ctx context.Context, envelope *core.Envelope) error
	Close() error
}

type Trigger interface {
	Start(ctx context.Context, handler Handler) error
	Stop(ctx context.Context) error
}