bus

type BusOption func(*BusOpts)

type BusOpts struct {
	Compression CompressionOpts
}

type Channel struct {
	Legacy, Server, Local string
}

type CompressionOpts struct {
	// Zero disables compression; otherwise the gzip level.
	Quality int
	// Payload bytes below which compression is skipped.
	Threshold int
	// Caps an inbound payload after decompression, bounding amplification from a
	// hostile publisher. Zero is unlimited.
	MaxDecompressedSize int
}

type EmptySubscription[MessageType any] struct{}

type MessageBus interface {
	Publish(ctx context.Context, channel Channel, msg proto.Message) error
	Subscribe(ctx context.Context, channel Channel, channelSize int) (Reader, error)
	SubscribeQueue(ctx context.Context, channel Channel, channelSize int) (Reader, error)
}

type PublishHandler func(ctx context.Context, channel Channel, msg proto.Message) error

type PublishInterceptor func(next PublishHandler) PublishHandler

type ReadHandler func() ([]byte, bool)

type Reader interface {
	Close() error
	// contains filtered or unexported methods
}

type SubscribeInterceptor func(ctx context.Context, channel Channel, next ReadHandler) ReadHandler

type Subscription[MessageType proto.Message] interface {
	Channel() <-chan MessageType
	Close() error
}

type TestBusOption func(*TestBusOpts)

type TestBusOpts struct {
	PublishInterceptors   []PublishInterceptor
	SubscribeInterceptors []SubscribeInterceptor
}