interfaces

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

type Config interface {
	GetReadTimeout() time.Duration
	GetMaxConcurrentSize() uint64
	GetConcurrentSize() int
}

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

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

type Msg interface {
	GetSubject() string
	IsReply() bool
	ReplyTo() string
	Copy(subject string) Msg
	SetHeader(key, value string)
	Respond([]byte) error
	GetHeader() map[string][]string
	GetData() []byte
	RespondMsg(Msg) error
}

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

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