librepository

type AggregateInterface interface {
	Definition() *Definition
	SetRepository(*libdomain.RepositoryInterface)
}

type DatasourceClient interface {
	MigrateAggregate([]*libdomain.AggregateDefinition) error
	// InitDB(writeInfo *libdata.ClusterInfo, readInfo *libdata.ClusterInfo) (*libdata.Cluster, error)
	// CreateTenant(*libdata.Workflow, []*libdata.ModelDefinition, *libdata.Tenant) error
	// GetTenant(*libdata.Workflow, *libdata.Tenant) (*libdata.Tenant, error)
	GetImportRepository() string
	GenerateScanFunc(libdomain.TableInterface) string
	Get(*libdomain.EntityDefinition, *libapplication.Workflow, string) (interface{}, error)
	Select(libdomain.TableInterface, *libapplication.Workflow, []*Filter, []string, *basepb.OptionsListQuery) (interface{}, error)
	Insert(
		libdomain.TableInterface, *libapplication.Workflow, []interface{},
		func([]interface{}) ([]string, map[string]interface{}),
		[]string,
	) (interface{}, error)
	Update(
		libdomain.TableInterface, *libapplication.Workflow, []*Filter, interface{}, *fieldmask.FieldMask,
		func(interface{}, *fieldmask.FieldMask) ([]string, map[string]interface{}), []string,
	) (interface{}, error)
	Delete(libdomain.TableInterface, *libapplication.Workflow, []*Filter) error
	BeginTransaction(*libapplication.Workflow, bool) error
	RollbackTransaction(*libapplication.Workflow) error
	CommitTransaction(*libapplication.Workflow) error
}

type Definition struct {
	Aggregate        libdomain.AggregateInterface
	DatasourceClient DatasourceClient
	CacheClient      libapplication.CacheClient
	GenDomain        string
}

type Definitions struct {
	Prefix        string
	GitRepository string
	// contains filtered or unexported fields
}

type Filter struct {
	Field    string
	Operator interface{}
}