interfaces

Documentation

Index

• func ConcurrentSize(config Config) int
• func Data(msg Msg) []byte
• func Header(msg Msg) map[string][]string
• func MaxConcurrentSize(config Config) uint64
• func ReadTimeout(config Config) time.Duration
• func Subject[T subjectGetter](value T) string
• type Client
• type Config
• type Logger
• type Meter
• type Msg
• type MsgHandler
• type Subscription

Functions

func ConcurrentSize

func ConcurrentSize(config Config) int

ConcurrentSize returns config concurrent size.

func Data

func Data(msg Msg) []byte

Data returns message data.

func Header

func Header(msg Msg) map[string][]string

Header returns message header.

func MaxConcurrentSize

func MaxConcurrentSize(config Config) uint64

MaxConcurrentSize returns config maximum concurrent size.

func ReadTimeout

func ReadTimeout(config Config) time.Duration

ReadTimeout returns config read timeout.

func Subject

func Subject[T subjectGetter](value T) string

Subject returns value subject.

Types

type Client

type Client interface {
	Meter
	Context() context.Context
	Logger() Logger
	Config() Config
	QueueSubscribeSync(subject, queue string) (Subscription, error)
	Close() error
}

type Config

type Config interface {
	// Deprecated: use ReadTimeout.
	GetReadTimeout() time.Duration
	// Deprecated: use MaxConcurrentSize.
	GetMaxConcurrentSize() uint64
	// Deprecated: use ConcurrentSize.
	GetConcurrentSize() int
}

type Logger

type Logger interface {
	Error(msg string, args ...any)
	Info(msg string, args ...any)
	Debug(msg string, args ...any)
}

type Meter

type Meter interface {
	Meter() metric.Meter
	WithMeter(metric.Meter)
}

type Msg

type Msg interface {
	// Deprecated: use Subject.
	GetSubject() string
	IsReply() bool
	ReplyTo() string
	Copy(subject string) Msg
	SetHeader(key, value string)
	Respond([]byte) error
	// Deprecated: use Header.
	GetHeader() map[string][]string
	// Deprecated: use Data.
	GetData() []byte
	RespondMsg(Msg) error
}

type MsgHandler

type MsgHandler func(ctx context.Context, msg Msg) error

type Subscription

type Subscription interface {
	NextMsg(timeout time.Duration) (Msg, error)
	Drain() error
	// Deprecated: use Subject.
	GetSubject() string
	Pending() (int64, int64, error)
	Dropped() (int64, error)
	Delivered() (int64, error)
}