offline

type CSVSource struct {
	Reader    *bufio.Reader
	Delimiter rune
}

type CreateTableOpt struct {
	TableName  string
	EntityName string
	Features   types.FeatureList
	TableType  types.TableType
}

type ExportOpt struct {
	SnapshotTables map[int]string
	CdcTables      map[int]string
	Features       map[int]types.FeatureList
	UnixMilli      int64
	EntityName     string
	Limit          *uint64
}

type ImportOpt struct {
	EntityName        string
	SnapshotTableName string
	Header            []string
	Features          types.FeatureList
	Revision          *int64
	Source            *CSVSource
	Category          types.Category
}

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

type PushOpt struct {
	GroupID      int
	Revision     int64
	EntityName   string
	FeatureNames []string
	Records      []types.StreamRecord
}

type RevisionRange struct {
	MinRevision   int64
	MaxRevision   int64
	SnapshotTable string
	CdcTable      string
}

type SnapshotOpt struct {
	Group        types.Group
	Features     types.FeatureList
	Revision     int64
	PrevRevision int64
}

type Store interface {
	Join(ctx context.Context, opt JoinOpt) (*types.JoinResult, error)
	Export(ctx context.Context, opt ExportOpt) (*types.ExportResult, error)
	Import(ctx context.Context, opt ImportOpt) (int64, error)
	Push(ctx context.Context, opt PushOpt) error

	CreateTable(ctx context.Context, opt CreateTableOpt) error
	TableSchema(ctx context.Context, opt TableSchemaOpt) (*types.DataTableSchema, error)
	Snapshot(ctx context.Context, opt SnapshotOpt) error

	Ping(ctx context.Context) error
	io.Closer
}

type TableSchemaOpt struct {
	TableName      string
	CheckTimeRange bool
}