postgres

Documentation

Index

• Variables
• func CreateIndexes(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, ...) error
• func CreateTables(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, ...) error
• func DropIndexes(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, ...) error
• func InitiateSchema(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, ...) error
• func New(logger *zap.Logger, metrics *metrics.BlockMetrics, db *sqlx.DB, ...) (*store, error)
• type DSN
  • func ParseDSN(dsn string) (*DSN, error)
  • func (c *DSN) DSN() string
  • func (c *DSN) String() string

Variables

var SystemTables = []string{"poi2$", "cursor"}

Functions

func CreateIndexes

func CreateIndexes(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, onlyTables []string, logger *zap.Logger) error

func CreateTables

func CreateTables(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, logger *zap.Logger) error

func DropIndexes

func DropIndexes(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, onlyTables []string, logger *zap.Logger) error

func InitiateSchema

func InitiateSchema(ctx context.Context, db *sqlx.DB, subgraph *subgraph.Definition, schema string, logger *zap.Logger) error

func New

func New(
	logger *zap.Logger,
	metrics *metrics.BlockMetrics,
	db *sqlx.DB,
	subgraphSchema string,
	subgraphDeploymentID string,
	subgraph *subgraph.Definition,
	entitiesNeverReadFromDB map[string]bool,
	withTransaction bool,
) (*store, error)

Types

type DSN

type DSN struct {
	// contains filtered or unexported fields
}

func ParseDSN

func ParseDSN(dsn string) (*DSN, error)

func (*DSN) DSN

func (c *DSN) DSN() string

func (*DSN) String

func (c *DSN) String() string