azuresynapse

package

v0.0.0-...-0ade494 Latest Latest Go to latest Published: Aug 26, 2022 License: AGPL-3.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/serviceexchange/server

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Init ¶

func Init()

Types ¶

type HandleT ¶

type HandleT struct {
	Db             *sql.DB
	Namespace      string
	ObjectStorage  string
	Warehouse      warehouseutils.WarehouseT
	Uploader       warehouseutils.UploaderI
	ConnectTimeout time.Duration
}

func (*HandleT) AddColumn ¶

func (as *HandleT) AddColumn(tableName, columnName, columnType string) (err error)

func (*HandleT) AlterColumn ¶

func (as *HandleT) AlterColumn(tableName, columnName, columnType string) (err error)

func (*HandleT) Cleanup ¶

func (as *HandleT) Cleanup()

func (*HandleT) Connect ¶

func (as *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)

func (*HandleT) CrashRecover ¶

func (as *HandleT) CrashRecover(warehouse warehouseutils.WarehouseT) (err error)

func (*HandleT) CreateSchema ¶

func (as *HandleT) CreateSchema() (err error)

func (*HandleT) CreateTable ¶

func (as *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)

func (*HandleT) DownloadIdentityRules ¶

func (as *HandleT) DownloadIdentityRules(*misc.GZipWriter) (err error)

func (*HandleT) DownloadLoadFiles ¶

func (as *HandleT) DownloadLoadFiles(tableName string) ([]string, error)

func (*HandleT) DropTable ¶

func (as *HandleT) DropTable(tableName string) (err error)

func (*HandleT) FetchSchema ¶

func (as *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (schema warehouseutils.SchemaT, err error)

FetchSchema queries SYNAPSE and returns the schema associated with provided namespace

func (*HandleT) GetTotalCountInTable ¶

func (as *HandleT) GetTotalCountInTable(tableName string) (total int64, err error)

func (*HandleT) IsEmpty ¶

func (as *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (empty bool, err error)

func (*HandleT) LoadIdentityMappingsTable ¶

func (as *HandleT) LoadIdentityMappingsTable() (err error)

func (*HandleT) LoadIdentityMergeRulesTable ¶

func (as *HandleT) LoadIdentityMergeRulesTable() (err error)

func (*HandleT) LoadTable ¶

func (as *HandleT) LoadTable(tableName string) error

func (*HandleT) LoadTestTable ¶

func (as *HandleT) LoadTestTable(location, tableName string, payloadMap map[string]interface{}, format string) (err error)

func (*HandleT) LoadUserTables ¶

func (as *HandleT) LoadUserTables() map[string]error

func (*HandleT) SetConnectionTimeout ¶

func (as *HandleT) SetConnectionTimeout(timeout time.Duration)

func (*HandleT) Setup ¶

func (as *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)

func (*HandleT) TestConnection ¶

func (as *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) (err error)

Source Files ¶

View all Source files

azure-synapse.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL