http

Documentation

Index

• Constants
• type Origin
  • func (o *Origin) GetRows(ctx context.Context, w psqlfront.CacheWriter, table *psqlfront.Table) error
  • func (o *Origin) GetTables(_ context.Context) ([]*psqlfront.Table, error)
  • func (o *Origin) ID() string
  • func (o *Origin) MigrateTable(ctx context.Context, m psqlfront.CacheMigrator, table *psqlfront.Table) error
• type OriginConfig
  • func (cfg *OriginConfig) NewOrigin(id string) (psqlfront.Origin, error)
  • func (cfg *OriginConfig) Restrict() error
  • func (cfg *OriginConfig) Type() string
• type TableConfig
  • func (cfg *TableConfig) DetectSchema(ctx context.Context) error
  • func (cfg *TableConfig) FetchRows(ctx context.Context) ([][]interface{}, error)
  • func (cfg *TableConfig) Fetcher(ctx context.Context) ([][]string, error)
  • func (cfg *TableConfig) Restrict(schema string) error

Constants

const OriginType = "HTTP"

Types

type Origin

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

func (*Origin) GetRows

func (o *Origin) GetRows(ctx context.Context, w psqlfront.CacheWriter, table *psqlfront.Table) error

func (*Origin) GetTables

func (o *Origin) GetTables(_ context.Context) ([]*psqlfront.Table, error)

func (*Origin) ID

func (o *Origin) ID() string

func (*Origin) MigrateTable

func (o *Origin) MigrateTable(ctx context.Context, m psqlfront.CacheMigrator, table *psqlfront.Table) error

type OriginConfig

type OriginConfig struct {
	Schema string         `yaml:"schema"`
	Tables []*TableConfig `yaml:"tables"`
}

func (*OriginConfig) NewOrigin

func (cfg *OriginConfig) NewOrigin(id string) (psqlfront.Origin, error)

func (*OriginConfig) Restrict

func (cfg *OriginConfig) Restrict() error

func (*OriginConfig) Type

func (cfg *OriginConfig) Type() string

type TableConfig

type TableConfig struct {
	origin.BaseTableConfig `yaml:",inline"`

	URLString                string        `yaml:"url"`
	Format                   string        `yaml:"format"`
	IgnoreLines              int           `yaml:"ignore_lines"`
	TextEncoding             *string       `yaml:"text_encoding"`
	SchemaDetection          bool          `yaml:"schema_detection"`
	DetectedSchemaExpiration time.Duration `yaml:"detected_schema_expiration"`
	URL                      *url.URL      `yaml:"-"`
	LastSchemaDetection      time.Time     `yaml:"-"`
}

func (*TableConfig) DetectSchema

func (cfg *TableConfig) DetectSchema(ctx context.Context) error

func (*TableConfig) FetchRows

func (cfg *TableConfig) FetchRows(ctx context.Context) ([][]interface{}, error)

func (*TableConfig) Fetcher

func (cfg *TableConfig) Fetcher(ctx context.Context) ([][]string, error)

func (*TableConfig) Restrict

func (cfg *TableConfig) Restrict(schema string) error