state

Aug 24, 2023

Changes in this version

+ var DefaultProjectID = "default"

+ var Projects = map[string]*Project

+ type Project struct

+ Connections map[string]*Connection

+ Directory string

+ EnvFile string

+ ID string

+ NoRestriction bool

+ Queries map[string]*Query

+ Roles RoleMap

+ RolesFile string

+ TokenFile string

+ TokenValues map[string]Token

+ Tokens TokenMap

+ func DefaultProject() (proj *Project)

+ func LoadProject(id string) (proj *Project)

+ func NewProject(id, directory string, noRestriction bool) (proj *Project)

+ func (p *Project) GetConnInstance(connName, databaseName string) (conn database.Connection, err error)

+ func (p *Project) GetConnObject(connName, databaseName string) (connObj connection.Connection, err error)

+ func (p *Project) GetRoleMap(roles []string) (rm RoleMap)

+ func (p *Project) LoadConnections(force bool) (err error)

+ func (p *Project) LoadRoles(force bool) (err error)

+ func (p *Project) LoadTokens(force bool) (err error)

+ func (p *Project) NewQuery(ctx context.Context) *Query

+ func (p *Project) ResolveToken(value string) (token Token, ok bool)

+ func (p *Project) SchemaAll(connection, schema string) (table database.Table)

+ func (p *Project) TokenAdd(name string, token Token) (err error)

+ func (p *Project) TokenGet(name string, token Token) (err error)

+ func (p *Project) TokenRemove(name string) (err error)

+ func (p *Project) TokenSave() (err error)

+ func (p *Project) TokenToggle(name string) (disabled bool, err error)

type Query

+ Project string

Mar 18, 2023

Changes in this version

type Query

+ Connection database.Connection

+ IsGenerated bool

+ func (q *Query) Submit() (err error)

Mar 13, 2023

Changes in this version

+ func ClearOldQueries()

type Query

+ func (q *Query) ProcessCustomReq(conn database.Connection) (err error)

Jan 5, 2023

Changes in this version

+ var AllowAllRoleMap = RoleMap

+ var NoRestriction = false

Jan 4, 2023

Changes in this version

+ var RudderstackURL = ""

Jan 4, 2023

Changes in this version

+ var TelemetryURL = ""

Jan 3, 2023

Changes in this version

type Connection

+ Source string

type RoleMap

+ func (rm RoleMap) HasAccess(connection string) bool

Jan 1, 2023

Changes in this version

+ var Roles = RoleMap

+ var TokenValues = map[string]Token

+ var Tokens = TokenMap

+ func LoadRoles(force bool) (err error)

+ func LoadTokens(force bool) (err error)

type RoleMap

+ func GetRoleMap(roles []string) (rm RoleMap)

+ func (rm RoleMap) CanSQL(connection string) bool

+ type Token struct

+ Disabled bool

+ IssuedAt time.Time

+ Roles []string

+ Token string

+ func NewToken(roles []string) Token

+ func ResolveToken(value string) (token Token, ok bool)

+ type TokenMap map[string]Token

+ func (tm *TokenMap) Save() (err error)

+ func (tm TokenMap) Add(name string, token Token) (err error)

+ func (tm TokenMap) Get(name string, token Token) (err error)

+ func (tm TokenMap) Remove(name string) (err error)

+ func (tm TokenMap) Toggle(name string) (disabled bool, err error)

Dec 31, 2022

Changes in this version

+ var Version = "dev"

Dec 30, 2022

Changes in this version

+ var Connections = map[string]*Connection

+ var HomeDir = ""

+ var HomeDirEnvFile = ""

+ var Queries = map[string]*Query

+ func CloseConnections()

+ func GetConnInstance(connName, databaseName string) (conn database.Connection, err error)

+ func GetConnObject(connName, databaseName string) (connObj connection.Connection, err error)

+ func LoadConnections(force bool) (err error)

+ func SchemaAll(connection, schema string) database.Table

+ type AllowSQLValue string

+ const AllowSQLAny

+ const AllowSQLDisable

+ type Connection struct

+ Conn connection.Connection

+ Props map[string]string

+ func (c *Connection) DefaultDB() string

+ type Grant struct

+ AllowRead []string

+ AllowSQL AllowSQLValue

+ AllowWrite []string

+ func (gt Grant) GetReadable(connection string) (tables []database.Table)

+ func (gt Grant) GetWritable(connection string) (tables []database.Table)

+ type Headers []string

+ func (h *Headers) Scan(value interface{}) error

+ func (h Headers) Value() (driver.Value, error)

+ type Permission string

+ const PermissionNone

+ const PermissionRead

+ const PermissionReadWrite

+ const PermissionWrite

+ func (p Permission) CanRead() bool

+ func (p Permission) CanWrite() bool

+ type Permissions map[string]Permission

+ type Query struct

+ Affected int64

+ Conn string

+ Context g.Context

+ Database string

+ Done chan struct{}

+ End int64

+ Err error

+ Error string

+ Headers Headers

+ ID string

+ Limit int

+ Result *sqlx.Rows

+ Start int64

+ Status QueryStatus

+ Stream *iop.Datastream

+ Text string

+ UpdatedDt time.Time

+ func NewQuery(ctx context.Context) *Query

+ func SubmitOrGetQuery(q *Query, cont bool) (query *Query, err error)

+ func (q *Query) Cancel() (err error)

+ func (q *Query) Close(cancel bool) (err error)

+ func (q *Query) ProcessResult() (err error)

+ type QueryStatus string

+ const QueryStatusCancelled

+ const QueryStatusCompleted

+ const QueryStatusErrored

+ const QueryStatusFetched

+ const QueryStatusSubmitted

+ type Role map[string]Grant

+ func (r Role) CanRead(connection string, table database.Table) bool

+ func (r Role) CanSQL(connection string) bool

+ func (r Role) CanWrite(connection string, table database.Table) bool

+ type RoleMap map[string]Role

+ func (rm RoleMap) GetPermissions(connection string) (perms Permissions)

+ type Row []interface

+ func (r *Row) Scan(value interface{}) error

+ func (r Row) Value() (driver.Value, error)

+ type Rows [][]interface

+ func (r *Rows) Scan(value interface{}) error

+ func (r Rows) Value() (driver.Value, error)