common

type CBDocumentKey struct {
	Parts []DocumentKeyPart
	// contains filtered or unexported fields
}

type DocumentKeyPart struct {
	Value string
	Kind  DocumentKind // string | field | UUID
}

type DocumentKind string

type ICBDocumentKey interface {
	SetKeyHashed()
	Set(key []DocumentKeyPart)
	IsSet() bool
	GetKey() []DocumentKeyPart
	GetNonCompoundPrimaryKeyOnly() string
}

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

type ISource[Options any] interface {
	Init(opts *Options, documentKey ICBDocumentKey) error
	StreamData(context.Context, chan map[string]interface{}) error
	GetCouchbaseIndexesQuery(bucket string, scope string, collection string) ([]Index, error)
}

type Index struct {
	Name  string
	Query string
	Error error
}