nats

type Config struct {
	ClusterName     string
	ClusterID       string
	PingParams      PingParameter
	PubAckWait      time.Duration
	NatsServer      string
	NatsURL         string
	NatsPort        string
	MaxInFlight     int
	ConnLostHandler func(conn stan.Conn, reason error)
	MessageHandler  func(msg *stan.Msg)
	ConnNats        stan.Conn
	SubsOpts        SubsOptionsHandler
}

type Message struct {
	Payload []byte
	Subject string
}

type MessageCh struct {
	Msg  *stan.Msg
	Data []byte
}

type NatsServiceRepo interface {
	ReConnect(opt ...Options) error
	Close() error
	QueueSubscribe(subject, qgroup string, cb stan.MsgHandler,
		opts ...stan.SubscriptionOption) (stan.Subscription, error)
	Subscribe(subject string, cb stan.MsgHandler,
		opts ...stan.SubscriptionOption) (stan.Subscription, error)
	Publish(obj Message) error
	SetMessageHandler(fn func(msg *stan.Msg))
	MessageHandler() stan.MsgHandler
	ConnectedUrl() string
	ConnectedAddr() string
	ConnectedServerId() string
	DeliverAllAvailable() stan.SubscriptionOption
	GetOpts() *Config
}

type Options func(*Config)

type PingParameter struct {
	TTLA int
	TTLB int
}

type SubsOptHandler func(*SubsOptionsHandler)

type SubsOptionsHandler struct {
	DurableName, MaxInFlight,
	AckWait, ManualAckMode,
	StartWithLastReceived,
	StartAtSequence stan.SubscriptionOption
	SubWrapper func(ch chan<- interface{}) func(msg *stan.Msg)
}