persistence

Documentation

Index

• type EntitiesCouchbasePersistence
  • func NewEntitiesCouchbasePersistence() *EntitiesCouchbasePersistence
  • func (c *EntitiesCouchbasePersistence) Create(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)
  • func (c *EntitiesCouchbasePersistence) DeleteById(correlationId string, id string) (*data1.EntityV1, error)
  • func (c *EntitiesCouchbasePersistence) DeleteByIds(correlationId string, ids []string) error
  • func (c *EntitiesCouchbasePersistence) GetListByIds(correlationId string, ids []string) ([]*data1.EntityV1, error)
  • func (c *EntitiesCouchbasePersistence) GetOneById(correlationId string, id string) (*data1.EntityV1, error)
  • func (c *EntitiesCouchbasePersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)
  • func (c *EntitiesCouchbasePersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.EntityV1DataPage, error)
  • func (c *EntitiesCouchbasePersistence) Update(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)
  • func (c *EntitiesCouchbasePersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.EntityV1, error)
• type EntitiesFilePersistence
  • func NewEntitiesFilePersistence(path string) *EntitiesFilePersistence
  • func (c *EntitiesFilePersistence) Configure(config *cconf.ConfigParams)
• type EntitiesJsonPostgresPersistence
  • func NewEntitiesJsonPostgresPersistence() *EntitiesJsonPostgresPersistence
  • func (c *EntitiesJsonPostgresPersistence) Create(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)
  • func (c *EntitiesJsonPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.EntityV1, err error)
  • func (c *EntitiesJsonPostgresPersistence) DeleteByIds(correlationId string, ids []string) (err error)
  • func (c *EntitiesJsonPostgresPersistence) GetListByIds(correlationId string, ids []string) (items []*data1.EntityV1, err error)
  • func (c *EntitiesJsonPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.EntityV1, err error)
  • func (c *EntitiesJsonPostgresPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)
  • func (c *EntitiesJsonPostgresPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.EntityV1DataPage, err error)
  • func (c *EntitiesJsonPostgresPersistence) Update(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)
  • func (c *EntitiesJsonPostgresPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (item *data1.EntityV1, err error)
• type EntitiesMemoryPersistence
  • func NewEntitiesMemoryPersistence() *EntitiesMemoryPersistence
  • func (c *EntitiesMemoryPersistence) Create(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)
  • func (c *EntitiesMemoryPersistence) DeleteById(correlationId string, id string) (*data1.EntityV1, error)
  • func (c *EntitiesMemoryPersistence) DeleteByIds(correlationId string, ids []string) error
  • func (c *EntitiesMemoryPersistence) GetListByIds(correlationId string, ids []string) ([]data1.EntityV1, error)
  • func (c *EntitiesMemoryPersistence) GetOneById(correlationId string, id string) (*data1.EntityV1, error)
  • func (c *EntitiesMemoryPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)
  • func (c *EntitiesMemoryPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.EntityV1DataPage, error)
  • func (c *EntitiesMemoryPersistence) Update(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)
  • func (c *EntitiesMemoryPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.EntityV1, error)
• type EntitiesMongoDbPersistence
  • func NewEntitiesMongoDbPersistence() *EntitiesMongoDbPersistence
  • func (c *EntitiesMongoDbPersistence) Create(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)
  • func (c *EntitiesMongoDbPersistence) DeleteById(correlationId string, id string) (*data1.EntityV1, error)
  • func (c *EntitiesMongoDbPersistence) DeleteByIds(correlationId string, ids []string) error
  • func (c *EntitiesMongoDbPersistence) GetListByIds(correlationId string, ids []string) ([]*data1.EntityV1, error)
  • func (c *EntitiesMongoDbPersistence) GetOneById(correlationId string, id string) (*data1.EntityV1, error)
  • func (c *EntitiesMongoDbPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)
  • func (c *EntitiesMongoDbPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.EntityV1DataPage, error)
  • func (c *EntitiesMongoDbPersistence) Update(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)
  • func (c *EntitiesMongoDbPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.EntityV1, error)
• type EntitiesPostgresPersistence
  • func NewEntitiesPostgresPersistence() *EntitiesPostgresPersistence
  • func (c *EntitiesPostgresPersistence) Create(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)
  • func (c *EntitiesPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.EntityV1, err error)
  • func (c *EntitiesPostgresPersistence) DeleteByIds(correlationId string, ids []string) (err error)
  • func (c *EntitiesPostgresPersistence) GetListByIds(correlationId string, ids []string) (items []*data1.EntityV1, err error)
  • func (c *EntitiesPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.EntityV1, err error)
  • func (c *EntitiesPostgresPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)
  • func (c *EntitiesPostgresPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.EntityV1DataPage, err error)
  • func (c *EntitiesPostgresPersistence) Update(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)
  • func (c *EntitiesPostgresPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (item *data1.EntityV1, err error)
• type IEntitiesPersistence

Types

type EntitiesCouchbasePersistence

type EntitiesCouchbasePersistence struct {
	cpersist.IdentifiableCouchbasePersistence
}

func NewEntitiesCouchbasePersistence

func NewEntitiesCouchbasePersistence() *EntitiesCouchbasePersistence

func (*EntitiesCouchbasePersistence) Create

func (c *EntitiesCouchbasePersistence) Create(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)

func (*EntitiesCouchbasePersistence) DeleteById

func (c *EntitiesCouchbasePersistence) DeleteById(correlationId string, id string) (*data1.EntityV1, error)

func (*EntitiesCouchbasePersistence) DeleteByIds

func (c *EntitiesCouchbasePersistence) DeleteByIds(correlationId string, ids []string) error

func (*EntitiesCouchbasePersistence) GetListByIds

func (c *EntitiesCouchbasePersistence) GetListByIds(correlationId string, ids []string) ([]*data1.EntityV1, error)

func (*EntitiesCouchbasePersistence) GetOneById

func (c *EntitiesCouchbasePersistence) GetOneById(correlationId string, id string) (*data1.EntityV1, error)

func (*EntitiesCouchbasePersistence) GetOneByName

func (c *EntitiesCouchbasePersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)

func (*EntitiesCouchbasePersistence) GetPageByFilter

func (c *EntitiesCouchbasePersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.EntityV1DataPage, error)

func (*EntitiesCouchbasePersistence) Update

func (c *EntitiesCouchbasePersistence) Update(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)

func (*EntitiesCouchbasePersistence) UpdatePartially

func (c *EntitiesCouchbasePersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.EntityV1, error)

type EntitiesFilePersistence

type EntitiesFilePersistence struct {
	EntitiesMemoryPersistence
	// contains filtered or unexported fields
}

func NewEntitiesFilePersistence

func NewEntitiesFilePersistence(path string) *EntitiesFilePersistence

func (*EntitiesFilePersistence) Configure

func (c *EntitiesFilePersistence) Configure(config *cconf.ConfigParams)

type EntitiesJsonPostgresPersistence

type EntitiesJsonPostgresPersistence struct {
	cpersist.IdentifiableJsonPostgresPersistence
}

func NewEntitiesJsonPostgresPersistence

func NewEntitiesJsonPostgresPersistence() *EntitiesJsonPostgresPersistence

func (*EntitiesJsonPostgresPersistence) Create

func (c *EntitiesJsonPostgresPersistence) Create(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)

func (*EntitiesJsonPostgresPersistence) DeleteById

func (c *EntitiesJsonPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.EntityV1, err error)

func (*EntitiesJsonPostgresPersistence) DeleteByIds

func (c *EntitiesJsonPostgresPersistence) DeleteByIds(correlationId string, ids []string) (err error)

func (*EntitiesJsonPostgresPersistence) GetListByIds

func (c *EntitiesJsonPostgresPersistence) GetListByIds(correlationId string, ids []string) (items []*data1.EntityV1, err error)

func (*EntitiesJsonPostgresPersistence) GetOneById

func (c *EntitiesJsonPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.EntityV1, err error)

func (*EntitiesJsonPostgresPersistence) GetOneByName

func (c *EntitiesJsonPostgresPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)

func (*EntitiesJsonPostgresPersistence) GetPageByFilter

func (c *EntitiesJsonPostgresPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.EntityV1DataPage, err error)

func (*EntitiesJsonPostgresPersistence) Update

func (c *EntitiesJsonPostgresPersistence) Update(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)

func (*EntitiesJsonPostgresPersistence) UpdatePartially

func (c *EntitiesJsonPostgresPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (item *data1.EntityV1, err error)

type EntitiesMemoryPersistence

type EntitiesMemoryPersistence struct {
	cpersist.IdentifiableMemoryPersistence
}

func NewEntitiesMemoryPersistence

func NewEntitiesMemoryPersistence() *EntitiesMemoryPersistence

func (*EntitiesMemoryPersistence) Create

func (c *EntitiesMemoryPersistence) Create(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)

func (*EntitiesMemoryPersistence) DeleteById

func (c *EntitiesMemoryPersistence) DeleteById(correlationId string, id string) (*data1.EntityV1, error)

func (*EntitiesMemoryPersistence) DeleteByIds

func (c *EntitiesMemoryPersistence) DeleteByIds(correlationId string, ids []string) error

func (*EntitiesMemoryPersistence) GetListByIds

func (c *EntitiesMemoryPersistence) GetListByIds(correlationId string, ids []string) ([]data1.EntityV1, error)

func (*EntitiesMemoryPersistence) GetOneById

func (c *EntitiesMemoryPersistence) GetOneById(correlationId string, id string) (*data1.EntityV1, error)

func (*EntitiesMemoryPersistence) GetOneByName

func (c *EntitiesMemoryPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)

func (*EntitiesMemoryPersistence) GetPageByFilter

func (c *EntitiesMemoryPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.EntityV1DataPage, error)

func (*EntitiesMemoryPersistence) Update

func (c *EntitiesMemoryPersistence) Update(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)

func (*EntitiesMemoryPersistence) UpdatePartially

func (c *EntitiesMemoryPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.EntityV1, error)

type EntitiesMongoDbPersistence

type EntitiesMongoDbPersistence struct {
	cpersist.IdentifiableMongoDbPersistence
}

func NewEntitiesMongoDbPersistence

func NewEntitiesMongoDbPersistence() *EntitiesMongoDbPersistence

func (*EntitiesMongoDbPersistence) Create

func (c *EntitiesMongoDbPersistence) Create(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)

func (*EntitiesMongoDbPersistence) DeleteById

func (c *EntitiesMongoDbPersistence) DeleteById(correlationId string, id string) (*data1.EntityV1, error)

func (*EntitiesMongoDbPersistence) DeleteByIds

func (c *EntitiesMongoDbPersistence) DeleteByIds(correlationId string, ids []string) error

func (*EntitiesMongoDbPersistence) GetListByIds

func (c *EntitiesMongoDbPersistence) GetListByIds(correlationId string, ids []string) ([]*data1.EntityV1, error)

func (*EntitiesMongoDbPersistence) GetOneById

func (c *EntitiesMongoDbPersistence) GetOneById(correlationId string, id string) (*data1.EntityV1, error)

func (*EntitiesMongoDbPersistence) GetOneByName

func (c *EntitiesMongoDbPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)

func (*EntitiesMongoDbPersistence) GetPageByFilter

func (c *EntitiesMongoDbPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.EntityV1DataPage, error)

func (*EntitiesMongoDbPersistence) Update

func (c *EntitiesMongoDbPersistence) Update(correlationId string, item *data1.EntityV1) (*data1.EntityV1, error)

func (*EntitiesMongoDbPersistence) UpdatePartially

func (c *EntitiesMongoDbPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.EntityV1, error)

type EntitiesPostgresPersistence

type EntitiesPostgresPersistence struct {
	cpersist.IdentifiablePostgresPersistence
}

func NewEntitiesPostgresPersistence

func NewEntitiesPostgresPersistence() *EntitiesPostgresPersistence

func (*EntitiesPostgresPersistence) Create

func (c *EntitiesPostgresPersistence) Create(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)

func (*EntitiesPostgresPersistence) DeleteById

func (c *EntitiesPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.EntityV1, err error)

func (*EntitiesPostgresPersistence) DeleteByIds

func (c *EntitiesPostgresPersistence) DeleteByIds(correlationId string, ids []string) (err error)

func (*EntitiesPostgresPersistence) GetListByIds

func (c *EntitiesPostgresPersistence) GetListByIds(correlationId string, ids []string) (items []*data1.EntityV1, err error)

func (*EntitiesPostgresPersistence) GetOneById

func (c *EntitiesPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.EntityV1, err error)

func (*EntitiesPostgresPersistence) GetOneByName

func (c *EntitiesPostgresPersistence) GetOneByName(correlationId string, name string) (*data1.EntityV1, error)

func (*EntitiesPostgresPersistence) GetPageByFilter

func (c *EntitiesPostgresPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.EntityV1DataPage, err error)

func (*EntitiesPostgresPersistence) Update

func (c *EntitiesPostgresPersistence) Update(correlationId string, item *data1.EntityV1) (result *data1.EntityV1, err error)

func (*EntitiesPostgresPersistence) UpdatePartially

func (c *EntitiesPostgresPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (item *data1.EntityV1, err error)

type IEntitiesPersistence

type IEntitiesPersistence interface {
	GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.EntityV1DataPage, err error)

	GetOneById(correlationId string, id string) (res *data1.EntityV1, err error)

	GetOneByName(correlationId string, name string) (res *data1.EntityV1, err error)

	Create(correlationId string, item *data1.EntityV1) (res *data1.EntityV1, err error)

	Update(correlationId string, item *data1.EntityV1) (res *data1.EntityV1, err error)

	DeleteById(correlationId string, id string) (res *data1.EntityV1, err error)
}