natsmq

type Config struct {
	ClientId   string             `json:"client_id" yaml:"client_id"`
	ClusterId  string             `json:"clusterId" yaml:"cluster_id"`
	BrokerId   string             `json:"brokerId" yaml:"broker_id"`
	Broker     string             `json:"brokers" yaml:"broker"`
	User       string             `json:"user" yaml:"user"`
	Password   string             `json:"password" yaml:"password"`
	Token      string             `json:"token" yaml:"token"`
	Channels   map[string]string  `json:"channels" yaml:"channels"`
	AckTimeout int64              `json:"ack_timeout" yaml:"ack_timeout"`
	TLS        SSL                `json:"tls" yaml:"tls"`
	NatsConn   []nats.Option      `json:"-" yaml:"-"`
	StanConn   []stan.Option      `json:"-" yaml:"-"`
	Logger     *zap.SugaredLogger `json:"-" yaml:"-"`
	Tracer     opentracing.Tracer `json:"-" yaml:"-"`
}

type MessageInfo struct {
	Nuid      string `json:"nuid" yaml:"nuid"`
	Channel   string `json:"channel" yaml:"channel"`
	Sequence  uint64 `json:"sequence" yaml:"sequence"`
	Timestamp int64  `json:"timestamp" yaml:"timestamp"`
}

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

type NatsSubHandler func(ctx context.Context, data []byte, reply string) error

type NatsSubOpts struct {
	Sub     nats.SubscriptionType `json:"-" yaml:"-"`
	Subject string                `json:"subject" yaml:"subject"`
	*Config
}

type SSL struct {
	Enabled  bool   `json:"enabled" yaml:"enabled"`
	CaPath   string `json:"ca" yaml:"ca"`
	KeyPath  string `json:"key" yaml:"key"`
	CertPath string `json:"cert" yaml:"cert"`
	Verify   bool   `json:"verify" yaml:"verify"`
	AuthType string `json:"auth_type" yaml:"auth_type"`
}

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

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

type StanSubHandler func(ctx context.Context, data []byte, info *MessageInfo) error

type StanSubOpts struct {
	Opts    []stan.SubscriptionOption `json:"-" yaml:"-"`
	Channel string                    `json:"channel" yaml:"channel"`
	*Config
}