Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPluginPath ¶
func PluginFQNToSchemaName ¶
schemas in postgres are limited to 63 chars - the FQN may be longer than this, in which case trim the length and add a hash to the end to make unique
func SaveConnectionState ¶
func SaveConnectionState(state ConnectionMap) error
Types ¶
type Connection ¶
func NewConnection ¶
func NewConnection() *Connection
type ConnectionConfig ¶
type ConnectionConfig struct {
Connections map[string]*Connection
}
func Load ¶
func Load() (*ConnectionConfig, error)
type ConnectionMap ¶
type ConnectionMap map[string]*installedPlugin
func GetConnectionState ¶
func GetConnectionState(schemas []string) (ConnectionMap, error)
GetConnectionState :: load connection state file, and remove any connections which do not exist in the db
type ConnectionPlugin ¶
type ConnectionPlugin struct {
ConnectionName string
PluginName string
Plugin *grpc.PluginClient
Schema *proto.Schema
}
func CreateConnectionPlugin ¶
func CreateConnectionPlugin(options *ConnectionPluginOptions) (*ConnectionPlugin, error)
type ConnectionPluginOptions ¶
type ConnectionUpdates ¶
type ConnectionUpdates struct {
Update ConnectionMap
Delete ConnectionMap
MissingPlugins []string
// the connections which will exist after the update
RequiredConnections ConnectionMap
}
func GetConnectionsToUpdate ¶
func GetConnectionsToUpdate(schemas []string) (*ConnectionUpdates, error)
GetConnectionsToUpdate :: returns updates to be made to the database to sync with connection config
Click to show internal directories.
Click to hide internal directories.