pubsubconfig

type Config struct {
	Kind           string          `yaml:"kind"`
	GcpPublisher   *GcpPublisher   `yaml:"gcpPublisher"`
	GcpSubscriber  *GcpSubscriber  `yaml:"gcpSubscriber"`
	NatsPublisher  *NatsPublisher  `yaml:"natsPublisher"`
	NatsSubscriber *NatsSubscriber `yaml:"natsSubscriber"`
}

type GcpPublisher struct {
	Project string `yaml:"project"`
}

type GcpSubscriber struct {
	GcpPublisher           `yaml:",inline"`
	MaxExtension           time.Duration `yaml:"maxExtension"`
	MaxExtensionPeriod     time.Duration `yaml:"maxExtensionPeriod"`
	MinExtensionPeriod     time.Duration `yaml:"minExtensionPeriod"`
	NumGoroutines          int           `yaml:"numGoroutines"`
	MaxOutstandingBytes    int           `yaml:"maxOutstandingBytes"`
	MaxOutstandingMessages int           `yaml:"maxOutstandingMessages"`
}

type NatsConnection struct {
	URL string
	// when we connect to nats-mqtt we might need the mqtt passwords
	MqttPasswords          string `env:"NATS_MQTT_TOKEN,overwrite"`
	PublishAsyncMaxPending int    `env:"NATS_JS_MAX_ASYNC_PUBLISH,overwrite,default=256"`
}

type NatsPublisher struct {
	NatsConnection `yaml:",inline"`
}

type NatsSubscriber struct {
	NatsConnection    `yaml:",inline"`
	Stream            string `yaml:"stream"`
	ConsumerName      string `yaml:"consumerName"`
	ConsumerGroupName string `yaml:"consumerGroupName"`
}