Documentation
¶
Index ¶
- type DBSchemaStreamParser
- func (p *DBSchemaStreamParser) GetSupportedTypes() []string
- func (p *DBSchemaStreamParser) Parse(ctx context.Context, content []byte, metadata map[string]any) (*core.Document, error)
- func (p *DBSchemaStreamParser) ParseStream(ctx context.Context, r io.Reader, metadata map[string]any) (<-chan *core.Document, error)
- func (p *DBSchemaStreamParser) Supports(contentType string) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBSchemaStreamParser ¶
type DBSchemaStreamParser struct {
// contains filtered or unexported fields
}
DBSchemaStreamParser implements a database schema parser for SQL DDL
func DefaultDBSchemaStreamParser ¶ added in v1.1.3
func DefaultDBSchemaStreamParser() *DBSchemaStreamParser
DefaultDBSchemaStreamParser creates a new database schema parser
func (*DBSchemaStreamParser) GetSupportedTypes ¶
func (p *DBSchemaStreamParser) GetSupportedTypes() []string
GetSupportedTypes returns the supported file formats
func (*DBSchemaStreamParser) Parse ¶
func (p *DBSchemaStreamParser) Parse(ctx context.Context, content []byte, metadata map[string]any) (*core.Document, error)
Parse implements core.Parser interface.
func (*DBSchemaStreamParser) ParseStream ¶
func (p *DBSchemaStreamParser) ParseStream(ctx context.Context, r io.Reader, metadata map[string]any) (<-chan *core.Document, error)
ParseStream reads the incoming io.Reader and yields chunks of the document via a channel
func (*DBSchemaStreamParser) Supports ¶
func (p *DBSchemaStreamParser) Supports(contentType string) bool
Source Files
Click to show internal directories.
Click to hide internal directories.