pubsub

type NatsPublishClient interface {
	Publish(req *PublishRequest) (string, error)
}

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

type PubSubClient struct {
	Conn        stan.Conn
	AckDuration int
	// contains filtered or unexported fields
}

type PubSubConfig struct {
	NatsServerHost string `env:"NATS_SERVER_HOST" envDefault:"nats://localhost:4222"`
	ClusterId      string `env:"CLUSTER_ID" envDefault:"devtron-stan"`
	ClientId       string `env:"CLIENT_ID" envDefault:"orchestrator"`
	AckDuration    string `env:"ACK_DURATION" envDefault:"30"`
}

type PublishRequest struct {
	Topic   string          `json:"topic"`
	Payload json.RawMessage `json:"payload"`
}