etcdsnapshot

Documentation

Index

• func Creator(ctx context.Context, configUntyped plugins.ConfigDecoder) (physical.Database, error)
• type Config
• type Database
  • func (d Database) GetTable(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)
  • func (d Database) ListTables(ctx context.Context) ([]string, error)
• type DatasourceExecuting
  • func (d *DatasourceExecuting) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type Schema

Functions

func Creator

func Creator(ctx context.Context, configUntyped plugins.ConfigDecoder) (physical.Database, error)

Types

type Config

type Config struct {
}

type Database

type Database struct {
}

func (Database) GetTable

func (d Database) GetTable(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)

func (Database) ListTables

func (d Database) ListTables(ctx context.Context) ([]string, error)

type DatasourceExecuting

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

func (*DatasourceExecuting) Run

func (d *DatasourceExecuting) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type Schema

type Schema int

const (
	SchemaContent Schema = iota
	SchemaMeta    Schema = iota
)