pgmeta

Documentation

Index

• Variables
• func CreateColumn(cfg *raiden.Config, column objects.Column, isPrimary bool) error
• func CreateTable(cfg *raiden.Config, newTable objects.Table) (result objects.Table, err error)
• func CreateType(cfg *raiden.Config, t objects.Type) (objects.Type, error)
• func DefaultAuthInterceptor(accessToken string) func(req *http.Request) error
• func DeleteColumn(cfg *raiden.Config, column objects.Column) error
• func DeleteTable(cfg *raiden.Config, table objects.Table, cascade bool) error
• func DeleteType(cfg *raiden.Config, t objects.Type) error
• func ExecuteQuery[T any](baseUrl, query string, variables any, reqInterceptor net.RequestInterceptor, ...) (result T, err error)
• func GetIndexes(cfg *raiden.Config, schema string) ([]objects.Index, error)
• func GetTableByName(cfg *raiden.Config, name, schema string, includeColumn bool) (result objects.Table, err error)
• func GetTableRelationshipActions(cfg *raiden.Config, schema string) ([]objects.TablesRelationshipAction, error)
• func GetTables(cfg *raiden.Config, includedSchemas []string, includeColumns bool) ([]objects.Table, error)
• func GetTypeByName(cfg *raiden.Config, includedSchema []string, name string) (result objects.Type, err error)
• func GetTypes(cfg *raiden.Config, includedSchemas []string) ([]objects.Type, error)
• func UpdateColumn(cfg *raiden.Config, oldColumn, newColumn objects.Column, ...) error
• func UpdateTable(cfg *raiden.Config, newTable objects.Table, ...) error
• func UpdateType(cfg *raiden.Config, t objects.Type) error
• type ExecuteQueryParam

Variables

var MetaLogger = logger.HcLog().Named("connector.meta")

Functions

func CreateColumn

func CreateColumn(cfg *raiden.Config, column objects.Column, isPrimary bool) error

func CreateTable

func CreateTable(cfg *raiden.Config, newTable objects.Table) (result objects.Table, err error)

func CreateType

func CreateType(cfg *raiden.Config, t objects.Type) (objects.Type, error)

func DefaultAuthInterceptor

func DefaultAuthInterceptor(accessToken string) func(req *http.Request) error

func DeleteColumn

func DeleteColumn(cfg *raiden.Config, column objects.Column) error

func DeleteTable

func DeleteTable(cfg *raiden.Config, table objects.Table, cascade bool) error

func DeleteType

func DeleteType(cfg *raiden.Config, t objects.Type) error

func ExecuteQuery

func ExecuteQuery[T any](baseUrl, query string, variables any, reqInterceptor net.RequestInterceptor, resInterceptor net.ResponseInterceptor) (result T, err error)

func GetIndexes

func GetIndexes(cfg *raiden.Config, schema string) ([]objects.Index, error)

func GetTableByName

func GetTableByName(cfg *raiden.Config, name, schema string, includeColumn bool) (result objects.Table, err error)

func GetTableRelationshipActions

func GetTableRelationshipActions(cfg *raiden.Config, schema string) ([]objects.TablesRelationshipAction, error)

----- relationship action -----

func GetTables

func GetTables(cfg *raiden.Config, includedSchemas []string, includeColumns bool) ([]objects.Table, error)

func GetTypeByName

func GetTypeByName(cfg *raiden.Config, includedSchema []string, name string) (result objects.Type, err error)

func GetTypes

func GetTypes(cfg *raiden.Config, includedSchemas []string) ([]objects.Type, error)

func UpdateColumn

func UpdateColumn(cfg *raiden.Config, oldColumn, newColumn objects.Column, updateItem objects.UpdateColumnItem) error

func UpdateTable

func UpdateTable(cfg *raiden.Config, newTable objects.Table, updateItem objects.UpdateTableParam) error

func UpdateType

func UpdateType(cfg *raiden.Config, t objects.Type) error

Types

type ExecuteQueryParam

type ExecuteQueryParam struct {
	Query     string `json:"query"`
	Variables any    `json:"variables"`
}

----- Execute Query -----