procx

type Driver struct {
	Name      DriverName       `json:"name"`
	AWS       *DriverAWS       `json:"aws"`
	Cassandra *DriverCassandra `json:"cassandra"`
	Centauri  *DriverCentauri  `json:"centauri"`
	GCP       *DriverGCP       `json:"gcp"`
	Psql      *DriverPsql      `json:"psql"`
	Mongo     *DriverMongo     `json:"mongo"`
	Mysql     *DriverMysql     `json:"mysql"`
	RabbitMQ  *DriverRabbitMQ  `json:"rabbitmq"`
	Redis     *DriverRedis     `json:"redis"`
}

type DriverAWS struct {
	Region      string `json:"region"`
	RoleARN     string `json:"roleArn"`
	SQSQueueURL string `json:"sqsQueueUrl"`
}

type DriverCassandra struct {
	Hosts           []string  `json:"hosts"`
	User            string    `json:"user"`
	Password        string    `json:"password"`
	Keyspace        string    `json:"keyspace"`
	Consistency     string    `json:"consistency"`
	QueryReturnsKey *bool     `json:"queryReturnsKey"`
	RetrieveQuery   *SqlQuery `json:"retrieveQuery"`
	FailureQuery    *SqlQuery `json:"failureQuery"`
	ClearQuery      *SqlQuery `json:"clearQuery"`
	Key             *string   `json:"key"`
}

type DriverCentauri struct {
	PrivateKey []byte  `json:"privateKey"`
	PeerURL    string  `json:"peerUrl"`
	Channel    *string `json:"channel"`
	Key        *string `json:"key"`
}

type DriverGCP struct {
	ProjectID        string `json:"projectId"`
	SubscriptionName string `json:"subscriptionName"`
	// contains filtered or unexported fields
}

type DriverMongo struct {
	Host          string  `json:"host"`
	Port          int     `json:"port"`
	User          string  `json:"user"`
	Password      string  `json:"password"`
	DBName        string  `json:"dbName"`
	Collection    string  `json:"collection"`
	RetrieveQuery *string `json:"retrieveQuery"`
	FailureQuery  *string `json:"failureQuery"`
	ClearQuery    *string `json:"clearQuery"`
	Key           *string `json:"key"`
}

type DriverMysql struct {
	Host            string    `json:"host"`
	Port            int       `json:"port"`
	User            string    `json:"user"`
	Password        string    `json:"password"`
	DBName          string    `json:"dbName"`
	QueryReturnsKey *bool     `json:"queryReturnsKey"`
	RetrieveQuery   *SqlQuery `json:"retrieveQuery"`
	FailureQuery    *SqlQuery `json:"failureQuery"`
	ClearQuery      *SqlQuery `json:"clearQuery"`
	Key             *string   `json:"key"`
}

type DriverName string

type DriverPsql struct {
	Host            string    `json:"host"`
	Port            int       `json:"port"`
	User            string    `json:"user"`
	Password        string    `json:"password"`
	DBName          string    `json:"dbName"`
	SSLMode         string    `json:"sslMode"`
	QueryReturnsKey *bool     `json:"queryReturnsKey"`
	RetrieveQuery   *SqlQuery `json:"retrieveQuery"`
	FailureQuery    *SqlQuery `json:"failureQuery"`
	ClearQuery      *SqlQuery `json:"clearQuery"`
	Key             *string   `json:"key"`
}

type DriverRabbitMQ struct {
	URL   string `json:"url"`
	Queue string `json:"queue"`
}

type DriverRedis struct {
	Host     string `json:"host"`
	Port     string `json:"port"`
	Password string `json:"password"`
	Key      string `json:"key"`
}

type ProcX struct {
	DriverName    DriverName `json:"driverName"`
	Driver        *Driver    `json:"driver"`
	PassWorkAsArg bool       `json:"passWorkAsArg"`
	HostEnv       bool       `json:"hostEnv"`
	Bin           string     `json:"bin"`
	Args          []string   `json:"args"`
	// contains filtered or unexported fields
}

type SqlQuery struct {
	Query  string `json:"query"`
	Params []any  `json:"params"`
}