rabbit

Documentation

Index

• Constants
• type Client
  • func NewClient(uri string, logger *slog.Logger) Client
• type Encoder
• type ExchangeType
• type MessageCallback
• type Options
  • func (opt *Options) String() string
• type Publisher

Constants

const (
	Fanout ExchangeType = "fanout"
	Direct              = "direct"
	Topic               = "topic"
)

Types

type Client

type Client interface {
	Listen(ctx context.Context, opt *Options, callback MessageCallback) error
	Publisher(opt *Options) Publisher
}

func NewClient

func NewClient(uri string, logger *slog.Logger) Client

type Encoder

type Encoder interface {
	MimeType() string
	Encode(interface{}) (string, []byte, error)
}

type ExchangeType

type ExchangeType string

type MessageCallback

type MessageCallback func([]byte) error

type Options

type Options struct {
	Type       ExchangeType
	Exchange   string
	Queue      string
	RoutingKey string
	AutoAck    bool
	Durable    bool
}

func (*Options) String

func (opt *Options) String() string

type Publisher

type Publisher interface {
	Publishing(key, mineType string, data []byte) error
	PublishJson(string, interface{}) error
	Publish(encoder Encoder, data interface{}) error
}