specs

type Backend int

type Backends []Backend

type Destination struct {
	Name           string    `json:"name,omitempty"`
	Version        string    `json:"version,omitempty"`
	Path           string    `json:"path,omitempty"`
	Registry       Registry  `json:"registry,omitempty"`
	WriteMode      WriteMode `json:"write_mode,omitempty"`
	BatchSize      int       `json:"batch_size,omitempty"`
	BatchSizeBytes int       `json:"batch_size_bytes,omitempty"`
	Spec           any       `json:"spec,omitempty"`
}

type Kind int

type Registry int

type Scheduler int

type Schedulers []Scheduler

type Source struct {
	// Name of the source plugin to use
	Name string `json:"name,omitempty"`
	// Version of the source plugin to use
	Version string `json:"version,omitempty"`
	// Path is the canonical path to the source plugin in a given registry
	// For example:
	// in github the path will be: org/repo
	// For the local registry the path will be the path to the binary: ./path/to/binary
	// For the gRPC registry the path will be the address of the gRPC server: host:port
	Path string `json:"path,omitempty"`
	// Registry can be github,local,grpc.
	Registry            Registry `json:"registry,omitempty"`
	Concurrency         uint64   `json:"concurrency,omitempty"`
	TableConcurrency    uint64   `json:"table_concurrency,omitempty"`    // deprecated: use Concurrency instead
	ResourceConcurrency uint64   `json:"resource_concurrency,omitempty"` // deprecated: use Concurrency instead
	// Tables to sync from the source plugin
	Tables []string `json:"tables,omitempty"`
	// SkipTables defines tables to skip when syncing data. Useful if a glob pattern is used in Tables
	SkipTables []string `json:"skip_tables,omitempty"`
	// Destinations are the names of destination plugins to send sync data to
	Destinations []string `json:"destinations,omitempty"`

	// Backend is the name of the state backend to use
	Backend Backend `json:"backend,omitempty"`
	// BackendSpec contains any backend-specific configuration
	BackendSpec any `json:"backend_spec,omitempty"`
	// Scheduler defines the scheduling algorithm that should be used to sync data
	Scheduler Scheduler `json:"scheduler,omitempty"`
	// Spec defines plugin specific configuration
	// This is different in every source plugin.
	Spec any `json:"spec,omitempty"`
}

type Spec struct {
	Kind Kind `json:"kind"`
	Spec any  `json:"spec"`
}

type SpecReader struct {
	Sources      map[string]*Source
	Destinations map[string]*Destination
}

type WriteMode int