isconn

type Config struct {
	NatsURL                string
	ServiceName            string
	ServiceVersion         string
	ServiceSubjectPrefix   string
	ConnectTimeout         time.Duration
	ReconnectWait          time.Duration
	TotalWait              time.Duration
	ReconnectBufSize       int
	PublishRetryWait       time.Duration
	MaxWaitResp            time.Duration
	MaxWaitJsPull          time.Duration
	RatryFailedMsgChanSize int
}

type Logger interface {
	Info(args ...interface{})
	Infof(template string, args ...interface{})
	Error(args ...interface{})
	Errorf(template string, args ...interface{})
}

type Manager struct {
	NC  *nats.Conn
	JS  nats.JetStreamContext
	Pub *Publisher
	Sub *Subscriber
	Svc *Service
	// contains filtered or unexported fields
}

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

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

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