offline

type ExportOpt struct {
	DataTable    string
	EntityName   string
	FeatureNames []string
	Limit        *uint64
}

type ImportOpt struct {
	Entity        *types.Entity
	Features      types.FeatureList
	Header        []string
	Revision      *int64
	DataTableName string

	// CsvReader must not contain header
	CsvReader *csv.Reader
}

type JoinOneGroupOpt struct {
	GroupName           string
	Features            types.FeatureList
	RevisionRanges      []*metadata.RevisionRange
	Entity              types.Entity
	EntityRowsTableName string
}

type JoinOpt struct {
	Entity           types.Entity
	EntityRows       <-chan types.EntityRow
	FeatureMap       map[string]types.FeatureList
	RevisionRangeMap map[string][]*metadata.RevisionRange
}

type Store interface {
	Join(ctx context.Context, opt JoinOpt) (*types.JoinResult, error)
	Export(ctx context.Context, opt ExportOpt) (<-chan *types.RawFeatureValueRecord, error)
	Import(ctx context.Context, opt ImportOpt) (int64, error)

	TypeTag(dbType string) (string, error)
	io.Closer
}