sysdb

Documentation

Index

• func Close() error
• func DeleteConfig(rq *api.ConfigDeleteRequest) (*api.ConfigDeleteResponse, error)
• func EnableConnector(rq *api.EnableRequest) error
• func GetConfig(attr string) (string, error, bool)
• func Init(filename string) error
• func InitCreate(filename string) error
• func IsConnectorEnabled(spec string) (bool, error)
• func ListConfig(rq *api.ConfigListRequest) (*api.ConfigListResponse, error)
• func UpdateConfig(rq *api.ConfigUpdateRequest) error
• type ColumnSchema
• type DatabaseConnector
  • func ReadDatabaseConnectors() ([]*DatabaseConnector, error)
• type SourceConnector
  • func ReadSourceConnectors() ([]*SourceConnector, error)
• type TableSchema

Functions

func Close

func Close() error

func DeleteConfig

func DeleteConfig(rq *api.ConfigDeleteRequest) (*api.ConfigDeleteResponse, error)

func EnableConnector

func EnableConnector(rq *api.EnableRequest) error

func GetConfig

func GetConfig(attr string) (string, error, bool)

func Init

func Init(filename string) error

func InitCreate

func InitCreate(filename string) error

Init and create: call this instead of Init() when creating a new database.

func IsConnectorEnabled

func IsConnectorEnabled(spec string) (bool, error)

func ListConfig

func ListConfig(rq *api.ConfigListRequest) (*api.ConfigListResponse, error)

func UpdateConfig

func UpdateConfig(rq *api.ConfigUpdateRequest) error

Types

type ColumnSchema

type ColumnSchema struct {
	Name       string
	DType      command.DataType
	DTypeSize  int64
	PrimaryKey int
}

type DatabaseConnector

type DatabaseConnector struct {
	ID              int64
	Name            string
	Type            string
	DBHost          string
	DBPort          string
	DBName          string
	DBAdminUser     string
	DBAdminPassword string
	DBUsers         string
	DBSSLMode       string
	Status          status.Status
}

func ReadDatabaseConnectors

func ReadDatabaseConnectors() ([]*DatabaseConnector, error)

type SourceConnector

type SourceConnector struct {
	ID               int64
	Name             string
	Brokers          string
	Topics           []string
	Group            string
	SchemaPassFilter []string
	SchemaPrefix     string
	Databases        []string
	Status           status.Status
}

func ReadSourceConnectors

func ReadSourceConnectors() ([]*SourceConnector, error)

type TableSchema

type TableSchema struct {
	Column []ColumnSchema
}