kumnats

type EventType string

type Logger interface {
	Error(args ...interface{})
	Errorf(format string, args ...interface{})
}

type NATS interface {
	Publish(subject string, value []byte) error
	Subscribe(subject string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) (stan.Subscription, error)
	QueueSubscribe(subject, queueGroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) (stan.Subscription, error)
	Close() error
}

type NatsCallback func(conn NATS)

type NatsMessage struct {
	ID     int64     `json:"id"`
	UserID int64     `json:"user_id"`
	Type   EventType `json:"type"`
	Body   string    `json:"body,omitempty"`
	Time   string    `json:"time"`
}

type Option func(*Options) error

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