common

type Analyzer[T any] interface {
	Init(index []T, suk IDocumentKey)
	AnalyzeData(data map[string]interface{})
	GetCouchbaseQuery(bucket, scope, collection string) []Index
}

type DocumentKey struct {
	Key          string
	NotComposite bool
	UUIDSet      bool
	HasString    bool
}

type DocumentKind string

type IDestination interface {
	Init(opts *option.Options) (IDocumentKey, error)
	ProcessData(map[string]interface{}) error
	Complete() error
	CreateIndexes(indexes []Index) error
}

type IDocumentKey interface {
	Set(kind DocumentKind, value string)
	Get() string
}

type ISource[Index any, Options any] interface {
	Init(opts *Options) error
	StreamData(context.Context, chan map[string]interface{}) error
	GetIndexes(ctx context.Context) ([]Index, error)
}

type Index struct {
	Name  string
	Query string
	Error error
}