utils

Documentation

Index

• Constants
• Variables
• func AssertDockerIsRunning() error
• func AssertPortIsAvailable(port string) error
• func AssertSupabaseStartIsRunning()
• func DockerExec(ctx context.Context, container string, cmd []string) (io.Reader, error)
• func DockerRemoveAll()
• func DockerRun(ctx context.Context, name string, config *container.Config, ...) (io.Reader, error)
• func GetCurrentBranch() (string, error)
• func GetCurrentTimestamp() string
• func GetGitRoot() (*string, error)
• func IsBranchNameReserved(branch string) bool
• func LoadConfig()
• func ProcessDiffOutput(p *tea.Program, out io.Reader) ([]byte, error)
• func ProcessPsqlOutput(out io.Reader, p *tea.Program) error
• func ProcessPullOutput(out io.ReadCloser, p *tea.Program) error
• type DiffDependencies
• type DiffEntry
• type ProgressMsg
• type PsqlMsg
• type StatusMsg

Constants

const (
	ShadowDbName   = "supabase_shadow"
	PgbouncerImage = "edoburu/pgbouncer:1.15.0"
	KongImage      = "library/kong:2.1"
	GotrueImage    = "supabase/gotrue:v2.2.6"
	RealtimeImage  = "supabase/realtime:v0.18.0"
	PostgrestImage = "postgrest/postgrest:v8.0.0"
	StorageImage   = "supabase/storage-api:v0.9.3"
	DifferImage    = "supabase/pgadmin-schema-diff:cli-0.0.4"
	PgmetaImage    = "supabase/postgres-meta:v0.28.0"

	// Args: dbname
	TerminateDbSqlFmt = `ALTER DATABASE "%[1]s" CONNECTION LIMIT 0;
SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE datname = '%[1]s';
`
)

Variables

var (
	Docker = func() *client.Client {
		docker, err := client.NewClientWithOpts(client.WithAPIVersionNegotiation())
		if err != nil {
			fmt.Fprintln(os.Stderr, "❌ Failed to initialize Docker client.")
			os.Exit(1)
		}
		return docker
	}()

	ApiPort     string
	DbPort      string
	PgmetaPort  string
	DbVersion   string
	DbImage     string
	ProjectId   string
	NetId       string
	DbId        string
	PgbouncerId string
	KongId      string
	GotrueId    string
	RealtimeId  string
	RestId      string
	StorageId   string
	DifferId    string
	PgmetaId    string
)

Functions

func AssertDockerIsRunning

func AssertDockerIsRunning() error

func AssertPortIsAvailable

func AssertPortIsAvailable(port string) error

func AssertSupabaseStartIsRunning

func AssertSupabaseStartIsRunning()

func DockerExec

func DockerExec(ctx context.Context, container string, cmd []string) (io.Reader, error)

func DockerRemoveAll

func DockerRemoveAll()

func DockerRun

func DockerRun(
	ctx context.Context,
	name string,
	config *container.Config,
	hostConfig *container.HostConfig,
) (io.Reader, error)

func GetCurrentBranch

func GetCurrentBranch() (string, error)

func GetCurrentTimestamp

func GetCurrentTimestamp() string

func GetGitRoot

func GetGitRoot() (*string, error)

func IsBranchNameReserved

func IsBranchNameReserved(branch string) bool

func LoadConfig

func LoadConfig()

func ProcessDiffOutput

func ProcessDiffOutput(p *tea.Program, out io.Reader) ([]byte, error)

func ProcessPsqlOutput

func ProcessPsqlOutput(out io.Reader, p *tea.Program) error

func ProcessPullOutput

func ProcessPullOutput(out io.ReadCloser, p *tea.Program) error

Types

type DiffDependencies

type DiffDependencies struct {
	Type string `json:"type"`
}

type DiffEntry

type DiffEntry struct {
	Type             string             `json:"type"`
	Status           string             `json:"status"`
	DiffDdl          string             `json:"diff_ddl"`
	GroupName        string             `json:"group_name"`
	Dependencies     []DiffDependencies `json:"dependencies"`
	SourceSchemaName *string            `json:"source_schema_name"`
}

type ProgressMsg

type ProgressMsg *float64

type PsqlMsg

type PsqlMsg *string

type StatusMsg

type StatusMsg string