client

Documentation

Index

• Constants
• func ObjectsFromResult(res *Result) map[string]*Objects
• type Client
  • func New() (*Client, error)
  • func NewFromUrl(url string, sshInfo *shared.SSHInfo) (*Client, error)
  • func (client *Client) Activity() (*Result, error)
  • func (client *Client) Close() error
  • func (client *Client) Databases() ([]string, error)
  • func (client *Client) Info() (*Result, error)
  • func (client *Client) IsIdle() bool
  • func (client *Client) MaterializedView(name string) (*Result, error)
  • func (client *Client) Objects() (*Result, error)
  • func (client *Client) Query(query string) (*Result, error)
  • func (client *Client) Schemas() ([]string, error)
  • func (client *Client) ServerVersion() string
  • func (client *Client) SetReadOnlyMode() error
  • func (client *Client) Table(table string) (*Result, error)
  • func (client *Client) TableConstraints(table string) (*Result, error)
  • func (client *Client) TableIndexes(table string) (*Result, error)
  • func (client *Client) TableInfo(table string) (*Result, error)
  • func (client *Client) TableRows(table string, opts RowsOptions) (*Result, error)
  • func (client *Client) TableRowsCount(table string, opts RowsOptions) (*Result, error)
  • func (client *Client) Test() error
• type Dump
  • func (d *Dump) Export(url string, writer io.Writer) error
• type Objects
• type Pagination
• type Result
  • func (res *Result) CSV() []byte
  • func (res *Result) Format() []map[string]interface{}
  • func (res *Result) JSON() []byte
  • func (res *Result) PrepareBigints()
• type Row
• type RowsOptions
• type Tunnel
  • func NewTunnel(sshInfo *shared.SSHInfo, dbUrl string) (*Tunnel, error)
  • func (tunnel *Tunnel) Close()
  • func (tunnel *Tunnel) Configure() error
  • func (tunnel *Tunnel) Start()

Constants

const (
	PORT_START = 29168
	PORT_LIMIT = 500
)

Functions

func ObjectsFromResult

func ObjectsFromResult(res *Result) map[string]*Objects

Types

type Client

type Client struct {
	External         bool
	History          []history.Record `json:"history"`
	ConnectionString string           `json:"connection_string"`
	// contains filtered or unexported fields
}

func New

func New() (*Client, error)

func NewFromUrl

func NewFromUrl(url string, sshInfo *shared.SSHInfo) (*Client, error)

func (*Client) Activity

func (client *Client) Activity() (*Result, error)

Returns all active queriers on the server

func (*Client) Close

func (client *Client) Close() error

Close database connection

func (*Client) Databases

func (client *Client) Databases() ([]string, error)

func (*Client) Info

func (client *Client) Info() (*Result, error)

func (*Client) IsIdle

func (client *Client) IsIdle() bool

func (*Client) MaterializedView

func (client *Client) MaterializedView(name string) (*Result, error)

func (*Client) Objects

func (client *Client) Objects() (*Result, error)

func (*Client) Query

func (client *Client) Query(query string) (*Result, error)

func (*Client) Schemas

func (client *Client) Schemas() ([]string, error)

func (*Client) ServerVersion

func (client *Client) ServerVersion() string

func (*Client) SetReadOnlyMode

func (client *Client) SetReadOnlyMode() error

func (*Client) Table

func (client *Client) Table(table string) (*Result, error)

func (*Client) TableConstraints

func (client *Client) TableConstraints(table string) (*Result, error)

func (*Client) TableIndexes

func (client *Client) TableIndexes(table string) (*Result, error)

func (*Client) TableInfo

func (client *Client) TableInfo(table string) (*Result, error)

func (*Client) TableRows

func (client *Client) TableRows(table string, opts RowsOptions) (*Result, error)

func (*Client) TableRowsCount

func (client *Client) TableRowsCount(table string, opts RowsOptions) (*Result, error)

func (*Client) Test

func (client *Client) Test() error

type Dump

type Dump struct {
	Table string
}

func (*Dump) Export

func (d *Dump) Export(url string, writer io.Writer) error

type Objects

type Objects struct {
	Tables            []string `json:"table"`
	Views             []string `json:"view"`
	MaterializedViews []string `json:"materialized_view"`
	Sequences         []string `json:"sequence"`
}

type Pagination

type Pagination struct {
	Rows    int64 `json:"rows_count"`
	Page    int64 `json:"page"`
	Pages   int64 `json:"pages_count"`
	PerPage int64 `json:"per_page"`
}

type Result

type Result struct {
	Pagination *Pagination `json:"pagination,omitempty"`
	Columns    []string    `json:"columns"`
	Rows       []Row       `json:"rows"`
}

func (*Result) CSV

func (res *Result) CSV() []byte

func (*Result) Format

func (res *Result) Format() []map[string]interface{}

func (*Result) JSON

func (res *Result) JSON() []byte

func (*Result) PrepareBigints

func (res *Result) PrepareBigints()

Due to big int number limitations in javascript, numbers should be encoded as strings so they could be properly loaded on the frontend.

type Row

type Row []interface{}

type RowsOptions

type RowsOptions struct {
	Where      string // Custom filter
	Offset     int    // Number of rows to skip
	Limit      int    // Number of rows to fetch
	SortColumn string // Column to sort by
	SortOrder  string // Sort direction (ASC, DESC)
}

Struct to hold table rows browsing options

type Tunnel

type Tunnel struct {
	TargetHost string
	TargetPort string
	Port       int
	SSHInfo    *shared.SSHInfo
	Config     *ssh.ClientConfig
	Client     *ssh.Client
	Listener   *net.TCPListener
}

func NewTunnel

func NewTunnel(sshInfo *shared.SSHInfo, dbUrl string) (*Tunnel, error)

func (*Tunnel) Close

func (tunnel *Tunnel) Close()

func (*Tunnel) Configure

func (tunnel *Tunnel) Configure() error

func (*Tunnel) Start

func (tunnel *Tunnel) Start()