connector

Documentation

Index

• type Postgresql
  • func New(ctx context.Context, dsn string, schemas []string, includeColumns bool, ...) (*Postgresql, error)
  • func (c *Postgresql) Asset(ctx context.Context, asset *v2.AssetRef) (string, io.ReadCloser, error)
  • func (c *Postgresql) Metadata(ctx context.Context) (*v2.ConnectorMetadata, error)
  • func (o *Postgresql) ResourceSyncers(ctx context.Context) []connectorbuilder.ResourceSyncer
  • func (c *Postgresql) Validate(ctx context.Context) (annotations.Annotations, error)

Types

type Postgresql

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

func New

func New(ctx context.Context, dsn string, schemas []string, includeColumns bool, includeLargeObjects bool) (*Postgresql, error)

func (*Postgresql) Asset

func (c *Postgresql) Asset(ctx context.Context, asset *v2.AssetRef) (string, io.ReadCloser, error)

func (*Postgresql) Metadata

func (c *Postgresql) Metadata(ctx context.Context) (*v2.ConnectorMetadata, error)

func (*Postgresql) ResourceSyncers

func (o *Postgresql) ResourceSyncers(ctx context.Context) []connectorbuilder.ResourceSyncer

func (*Postgresql) Validate

func (c *Postgresql) Validate(ctx context.Context) (annotations.Annotations, error)