client

package

v0.0.0-...-5e70cb1 Latest Latest Go to latest Published: Mar 14, 2023 License: MPL-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func Configure(ctx context.Context, logger zerolog.Logger, spec specs.Source, _ source.Options) (schema.ClientMeta, error)

func Identifier(name string) string

func SQLType(t schema.ValueType) string

func SchemaType(tableName string, columnName string, dataType string, columnType string) (schema.ValueType, error)

type Client struct {
	Tables schema.Tables
	// contains filtered or unexported fields
}

func (*Client) ID() string

func (c *Client) Sync(ctx context.Context, metrics *source.Metrics, res chan<- *schema.Resource) error

type Spec struct {
	ConnectionString string `json:"connection_string,omitempty"`
}

func (*Spec) SetDefaults()

func (s *Spec) Validate() error

type Transformer struct{}

this is used for tests

func (*Transformer) TransformBool(v *schema.Bool) any

func (*Transformer) TransformBytea(v *schema.Bytea) any

func (*Transformer) TransformCIDR(v *schema.CIDR) any

func (*Transformer) TransformCIDRArray(v *schema.CIDRArray) any

func (*Transformer) TransformFloat8(v *schema.Float8) any

func (*Transformer) TransformInet(v *schema.Inet) any

func (*Transformer) TransformInetArray(v *schema.InetArray) any

func (*Transformer) TransformInt8(v *schema.Int8) any

func (*Transformer) TransformInt8Array(v *schema.Int8Array) any

func (*Transformer) TransformJSON(v *schema.JSON) any

func (*Transformer) TransformMacaddr(v *schema.Macaddr) any

func (*Transformer) TransformMacaddrArray(v *schema.MacaddrArray) any

func (*Transformer) TransformText(v *schema.Text) any

func (*Transformer) TransformTextArray(v *schema.TextArray) any

func (*Transformer) TransformTimestamptz(v *schema.Timestamptz) any

func (*Transformer) TransformUUID(v *schema.UUID) any

func (*Transformer) TransformUUIDArray(v *schema.UUIDArray) any