pgw

type AlterRoleQuery struct {
	Role            string                 `json:"role"`
	Superuser       bool                   `json:"superuser"`
	NoSuperuser     bool                   `json:"nosuperuser"`
	CreateDB        bool                   `json:"createdb"`
	NoCreateDB      bool                   `json:"nocreatedb"`
	CreateRole      bool                   `json:"createrole"`
	NoCreateRole    bool                   `json:"nocreaterole"`
	CreateUser      bool                   `json:"createuser"`
	NoCreateUser    bool                   `json:"nocreateuser"`
	Inherit         bool                   `json:"inherit"`
	NoInherit       bool                   `json:"noinherit"`
	Login           bool                   `json:"login"`
	NoLogin         bool                   `json:"nologin"`
	Replication     bool                   `json:"replication"`
	NoReplication   bool                   `json:"noreplication"`
	ConnectionLimit int                    `json:"connection_limit"`
	Password        AlterRoleQueryPassword `json:"password"`
}

type AlterRoleQueryPassword struct {
	Value       string `json:"value"`
	Unencrypted bool   `json:"unencrypted"`
}

type Client struct {
	pg.DB
	// contains filtered or unexported fields
}

type ClientOpt func(*Client)

type DropTablesQuery struct {
	Tables  []string
	Cascade bool
}

type ErrChan struct {
	C chan error
	// contains filtered or unexported fields
}

type Procedure interface {
	// Ctx returns the context for deadlines and cancellation
	Ctx() context.Context
	// FinishedC returns a channel that will be closed if the procedure
	// completes successfully
	FinishedC() *StructChan
	// ErrC returns a channel which will return an error if the procedure
	// fails
	ErrC() *ErrChan
	// Run runs the procedure's work function
	Run() error
	// Wait takes a timeout waits for the procedure to complete. It will return
	// any error that it encounters on the ErrC or if the timeout is rea
	// an error if the Ctx deadline is reached.
	Wait() error
	// Close performs any cleanup actions that need to be performed
	Close()
}

type ProcedureChan struct {
	C chan Procedure
	// contains filtered or unexported fields
}

type SerialProcedureRunner struct {
	C *ProcedureChan
	// contains filtered or unexported fields
}

type StructChan struct {
	C chan struct{}
	// contains filtered or unexported fields
}