Documentation ¶
Index ¶
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) RefreshCache ¶ added in v0.3.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.