pgranger

type DBConfig struct {
	DBName  *string `json:"dbName"`
	Host    *string `json:"host"`
	Port    *int    `json:"port"`
	SSLMode *string `json:"sslMode"`
}

type DBConnConfig struct {
	DBName   string
	Host     string
	Port     int
	Username string
	Password string
	SSLMode  string
}

type DBController interface {
	DB() *sqlx.DB
	URI() string
}

type DBControllerConfig struct {
	DB *DBConfig `json:"db"`
}

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

type DBRunnable interface {
	Run(resChan chan interface{}, errChan chan error)
}

type DBSecret struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

type FanOutContext struct {
	// DBURIToDBRunnable contains mapping from DB URIs to DBRunnables.
	DBURIToDBRunnable map[string]DBRunnable
}

type FanOutResult struct {
	// DBResults contains result per DB.
	DBResults map[string]interface{}
	// ErrorDetails contains error per DB.
	ErrorDetails map[string]error
}

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

type NamespaceConfig struct {
	Ranges []*RangeConfig `json:"ranges"`
}

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

type PointFanOutProcessor interface {
	// Name of the PointFanOutProcessor instance.
	Name() string
	// ProvideShardingFieldNameAndValues provides the sharding field name and values for PGRanger to look up.
	ProvideShardingFieldNameAndValues() (*string, [][]byte)
	// CreateFanOutContextForAllDBs is a callback that will provide runnables for all db shards. Implement this if your
	// use case needs requests to all db shards.
	CreateFanOutContextForAllDBs(dbURIToDBCtrler map[string]DBController) (*FanOutContext, error)
	// CreateFanOutContext is a callback to provide the runnables for specific db shards with input which are decided
	// by pgranger based on output of FetchShardingFieldNameAndValues.
	CreateFanOutContext(
		dbURIs []string,
		dbURIToShardingFieldVals map[string][][]byte,
		dbURIToDBCtrler map[string]DBController,
	) (*FanOutContext, error)
}

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

type RangeConfig struct {
	Begin      *string     `json:"begin"`
	End        *string     `json:"end"`
	PrimaryDB  *DBConfig   `json:"primaryDB"`
	ReplicaDBs []*DBConfig `json:"replicaDBs"`
}

type ShardingConfig struct {
	Version       *int32                      `json:"version"`
	Namespaces    map[string]*NamespaceConfig `json:"namespaces"`
	DBControllers []*DBControllerConfig       `json:"dbControllers"`
}

type SqlxDBFactory interface {
	CreateSqlxDB(dbConfig *DBConfig, dbSecret *DBSecret) (*string, *sqlx.DB, error)
}

type SqlxDBFactoryImpl struct{}