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
- type TableConfig
Constants ¶
View Source
const OriginType = "HTTP"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Origin ¶
type Origin struct {
// contains filtered or unexported fields
}
func (*Origin) MigrateTable ¶ added in v0.2.0
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 ¶ added in v0.2.0
func (cfg *TableConfig) DetectSchema(ctx context.Context) error
func (*TableConfig) FetchRows ¶ added in v0.2.0
func (cfg *TableConfig) FetchRows(ctx context.Context) ([][]interface{}, error)
func (*TableConfig) Fetcher ¶ added in v0.2.0
func (cfg *TableConfig) Fetcher(ctx context.Context) ([][]string, error)
func (*TableConfig) Restrict ¶ added in v0.2.0
func (cfg *TableConfig) Restrict(schema string) error
Click to show internal directories.
Click to hide internal directories.