libmq

package

v0.2.11 Latest Latest Go to latest Published: Sep 25, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tuihub/librarian

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type MQ
- func NewMQ(c *conf.MQ, dbc *conf.Database, cachec *conf.Cache, app *libapp.Settings, ...) (*MQ, func(), error)
type Option
- func WithConsumePoisoned() Option
type Options
type Topic
- func NewTopic[T any](topic string, consumerFunc func(context.Context, *T) error, opts ...Option) *Topic[T]
type TopicInterface

Constants ¶

This section is empty.

Variables ¶

View Source

var ProviderSet = wire.NewSet(NewMQ)

Functions ¶

This section is empty.

Types ¶

type MQ ¶

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

func NewMQ ¶

func NewMQ(
	c *conf.MQ,
	dbc *conf.Database,
	cachec *conf.Cache,
	app *libapp.Settings,
	obs *libobserve.BuiltInObserver,
) (*MQ, func(), error)

func (*MQ) Publish ¶

func (a *MQ) Publish(ctx context.Context, topic string, payload []byte) error

func (*MQ) RegisterTopic ¶

func (a *MQ) RegisterTopic(topic TopicInterface) error

RegisterTopic register Topic to MQ If a message keep fail after retry, It will be sent to the PoisonQueue. PoisonQueue will retry messages in a very low rate.

func (*MQ) Start ¶

func (a *MQ) Start(ctx context.Context) error

func (*MQ) Stop ¶

func (a *MQ) Stop(ctx context.Context) error

type Option ¶ added in v0.1.0

type Option func(o *Options)

Option represents a store option function.

func WithConsumePoisoned ¶ added in v0.1.0

func WithConsumePoisoned() Option

type Options ¶ added in v0.1.0

type Options struct {
	ConsumePoisoned bool
}

type Topic ¶

type Topic[T any] struct {
	// contains filtered or unexported fields
}

func NewTopic ¶

func NewTopic[T any](topic string, consumerFunc func(context.Context, *T) error, opts ...Option) *Topic[T]

func (*Topic[T]) Consume ¶

func (t *Topic[T]) Consume(ctx context.Context, i []byte) error

func (*Topic[T]) GetOptions ¶ added in v0.1.0

func (t *Topic[T]) GetOptions() *Options

func (*Topic[T]) LocalCall ¶ added in v0.2.1

func (t *Topic[T]) LocalCall(ctx context.Context, i T) error

func (*Topic[T]) Name ¶

func (t *Topic[T]) Name() string

func (*Topic[T]) Publish ¶ added in v0.1.0

func (t *Topic[T]) Publish(ctx context.Context, i T) error

func (*Topic[T]) PublishFallsLocalCall ¶ added in v0.2.10

func (t *Topic[T]) PublishFallsLocalCall(ctx context.Context, i T) error

func (*Topic[T]) SetMQ ¶

func (t *Topic[T]) SetMQ(mq *MQ)

type TopicInterface ¶ added in v0.1.0

type TopicInterface interface {
	Name() string
	Consume(context.Context, []byte) error
	SetMQ(*MQ)
	GetOptions() *Options
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL