persistence

Documentation

Index

• type BeaconsCouchbasePersistence
  • func NewBeaconsCouchbasePersistence() *BeaconsCouchbasePersistence
  • func (c *BeaconsCouchbasePersistence) Create(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)
  • func (c *BeaconsCouchbasePersistence) DeleteById(correlationId string, id string) (*data1.BeaconV1, error)
  • func (c *BeaconsCouchbasePersistence) DeleteByIds(correlationId string, ids []string) error
  • func (c *BeaconsCouchbasePersistence) GetListByIds(correlationId string, ids []string) ([]*data1.BeaconV1, error)
  • func (c *BeaconsCouchbasePersistence) GetOneById(correlationId string, id string) (*data1.BeaconV1, error)
  • func (c *BeaconsCouchbasePersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)
  • func (c *BeaconsCouchbasePersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.BeaconV1DataPage, error)
  • func (c *BeaconsCouchbasePersistence) Update(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)
  • func (c *BeaconsCouchbasePersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.BeaconV1, error)
• type BeaconsFilePersistence
  • func NewBeaconsFilePersistence(path string) *BeaconsFilePersistence
  • func (c *BeaconsFilePersistence) Configure(config *cconf.ConfigParams)
• type BeaconsJsonPostgresPersistence
  • func NewBeaconsJsonPostgresPersistence() *BeaconsJsonPostgresPersistence
  • func (c *BeaconsJsonPostgresPersistence) Create(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)
  • func (c *BeaconsJsonPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.BeaconV1, err error)
  • func (c *BeaconsJsonPostgresPersistence) DeleteByIds(correlationId string, ids []string) (err error)
  • func (c *BeaconsJsonPostgresPersistence) GetListByIds(correlationId string, ids []string) (items []*data1.BeaconV1, err error)
  • func (c *BeaconsJsonPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.BeaconV1, err error)
  • func (c *BeaconsJsonPostgresPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)
  • func (c *BeaconsJsonPostgresPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.BeaconV1DataPage, err error)
  • func (c *BeaconsJsonPostgresPersistence) Update(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)
  • func (c *BeaconsJsonPostgresPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (item *data1.BeaconV1, err error)
• type BeaconsMemoryPersistence
  • func NewBeaconsMemoryPersistence() *BeaconsMemoryPersistence
  • func (c *BeaconsMemoryPersistence) Create(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)
  • func (c *BeaconsMemoryPersistence) DeleteById(correlationId string, id string) (*data1.BeaconV1, error)
  • func (c *BeaconsMemoryPersistence) DeleteByIds(correlationId string, ids []string) error
  • func (c *BeaconsMemoryPersistence) GetListByIds(correlationId string, ids []string) ([]data1.BeaconV1, error)
  • func (c *BeaconsMemoryPersistence) GetOneById(correlationId string, id string) (*data1.BeaconV1, error)
  • func (c *BeaconsMemoryPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)
  • func (c *BeaconsMemoryPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.BeaconV1DataPage, error)
  • func (c *BeaconsMemoryPersistence) Update(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)
  • func (c *BeaconsMemoryPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.BeaconV1, error)
• type BeaconsMongoDbPersistence
  • func NewBeaconsMongoDbPersistence() *BeaconsMongoDbPersistence
  • func (c *BeaconsMongoDbPersistence) Create(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)
  • func (c *BeaconsMongoDbPersistence) DeleteById(correlationId string, id string) (*data1.BeaconV1, error)
  • func (c *BeaconsMongoDbPersistence) DeleteByIds(correlationId string, ids []string) error
  • func (c *BeaconsMongoDbPersistence) GetListByIds(correlationId string, ids []string) ([]*data1.BeaconV1, error)
  • func (c *BeaconsMongoDbPersistence) GetOneById(correlationId string, id string) (*data1.BeaconV1, error)
  • func (c *BeaconsMongoDbPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)
  • func (c *BeaconsMongoDbPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.BeaconV1DataPage, error)
  • func (c *BeaconsMongoDbPersistence) Update(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)
  • func (c *BeaconsMongoDbPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (*data1.BeaconV1, error)
• type BeaconsPostgresPersistence
  • func NewBeaconsPostgresPersistence() *BeaconsPostgresPersistence
  • func (c *BeaconsPostgresPersistence) Create(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)
  • func (c *BeaconsPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.BeaconV1, err error)
  • func (c *BeaconsPostgresPersistence) DeleteByIds(correlationId string, ids []string) (err error)
  • func (c *BeaconsPostgresPersistence) GetListByIds(correlationId string, ids []string) (items []*data1.BeaconV1, err error)
  • func (c *BeaconsPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.BeaconV1, err error)
  • func (c *BeaconsPostgresPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)
  • func (c *BeaconsPostgresPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.BeaconV1DataPage, err error)
  • func (c *BeaconsPostgresPersistence) Update(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)
  • func (c *BeaconsPostgresPersistence) UpdatePartially(correlationId string, id string, data *cdata.AnyValueMap) (item *data1.BeaconV1, err error)
• type IBeaconsPersistence

Types

type BeaconsCouchbasePersistence

type BeaconsCouchbasePersistence struct {
	cpersist.IdentifiableCouchbasePersistence
}

func NewBeaconsCouchbasePersistence

func NewBeaconsCouchbasePersistence() *BeaconsCouchbasePersistence

func (*BeaconsCouchbasePersistence) Create

func (c *BeaconsCouchbasePersistence) Create(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)

func (*BeaconsCouchbasePersistence) DeleteById

func (c *BeaconsCouchbasePersistence) DeleteById(correlationId string, id string) (*data1.BeaconV1, error)

func (*BeaconsCouchbasePersistence) DeleteByIds

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

func (*BeaconsCouchbasePersistence) GetListByIds

func (c *BeaconsCouchbasePersistence) GetListByIds(correlationId string, ids []string) ([]*data1.BeaconV1, error)

func (*BeaconsCouchbasePersistence) GetOneById

func (c *BeaconsCouchbasePersistence) GetOneById(correlationId string, id string) (*data1.BeaconV1, error)

func (*BeaconsCouchbasePersistence) GetOneByUdi

func (c *BeaconsCouchbasePersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)

func (*BeaconsCouchbasePersistence) GetPageByFilter

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

func (*BeaconsCouchbasePersistence) Update

func (c *BeaconsCouchbasePersistence) Update(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)

func (*BeaconsCouchbasePersistence) UpdatePartially

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

type BeaconsFilePersistence

type BeaconsFilePersistence struct {
	BeaconsMemoryPersistence
	// contains filtered or unexported fields
}

func NewBeaconsFilePersistence

func NewBeaconsFilePersistence(path string) *BeaconsFilePersistence

func (*BeaconsFilePersistence) Configure

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

type BeaconsJsonPostgresPersistence

type BeaconsJsonPostgresPersistence struct {
	cpersist.IdentifiableJsonPostgresPersistence
}

func NewBeaconsJsonPostgresPersistence

func NewBeaconsJsonPostgresPersistence() *BeaconsJsonPostgresPersistence

func (*BeaconsJsonPostgresPersistence) Create

func (c *BeaconsJsonPostgresPersistence) Create(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)

func (*BeaconsJsonPostgresPersistence) DeleteById

func (c *BeaconsJsonPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.BeaconV1, err error)

func (*BeaconsJsonPostgresPersistence) DeleteByIds

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

func (*BeaconsJsonPostgresPersistence) GetListByIds

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

func (*BeaconsJsonPostgresPersistence) GetOneById

func (c *BeaconsJsonPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.BeaconV1, err error)

func (*BeaconsJsonPostgresPersistence) GetOneByUdi

func (c *BeaconsJsonPostgresPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)

func (*BeaconsJsonPostgresPersistence) GetPageByFilter

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

func (*BeaconsJsonPostgresPersistence) Update

func (c *BeaconsJsonPostgresPersistence) Update(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)

func (*BeaconsJsonPostgresPersistence) UpdatePartially

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

type BeaconsMemoryPersistence

type BeaconsMemoryPersistence struct {
	cpersist.IdentifiableMemoryPersistence
}

func NewBeaconsMemoryPersistence

func NewBeaconsMemoryPersistence() *BeaconsMemoryPersistence

func (*BeaconsMemoryPersistence) Create

func (c *BeaconsMemoryPersistence) Create(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)

func (*BeaconsMemoryPersistence) DeleteById

func (c *BeaconsMemoryPersistence) DeleteById(correlationId string, id string) (*data1.BeaconV1, error)

func (*BeaconsMemoryPersistence) DeleteByIds

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

func (*BeaconsMemoryPersistence) GetListByIds

func (c *BeaconsMemoryPersistence) GetListByIds(correlationId string, ids []string) ([]data1.BeaconV1, error)

func (*BeaconsMemoryPersistence) GetOneById

func (c *BeaconsMemoryPersistence) GetOneById(correlationId string, id string) (*data1.BeaconV1, error)

func (*BeaconsMemoryPersistence) GetOneByUdi

func (c *BeaconsMemoryPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)

func (*BeaconsMemoryPersistence) GetPageByFilter

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

func (*BeaconsMemoryPersistence) Update

func (c *BeaconsMemoryPersistence) Update(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)

func (*BeaconsMemoryPersistence) UpdatePartially

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

type BeaconsMongoDbPersistence

type BeaconsMongoDbPersistence struct {
	cpersist.IdentifiableMongoDbPersistence
}

func NewBeaconsMongoDbPersistence

func NewBeaconsMongoDbPersistence() *BeaconsMongoDbPersistence

func (*BeaconsMongoDbPersistence) Create

func (c *BeaconsMongoDbPersistence) Create(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)

func (*BeaconsMongoDbPersistence) DeleteById

func (c *BeaconsMongoDbPersistence) DeleteById(correlationId string, id string) (*data1.BeaconV1, error)

func (*BeaconsMongoDbPersistence) DeleteByIds

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

func (*BeaconsMongoDbPersistence) GetListByIds

func (c *BeaconsMongoDbPersistence) GetListByIds(correlationId string, ids []string) ([]*data1.BeaconV1, error)

func (*BeaconsMongoDbPersistence) GetOneById

func (c *BeaconsMongoDbPersistence) GetOneById(correlationId string, id string) (*data1.BeaconV1, error)

func (*BeaconsMongoDbPersistence) GetOneByUdi

func (c *BeaconsMongoDbPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)

func (*BeaconsMongoDbPersistence) GetPageByFilter

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

func (*BeaconsMongoDbPersistence) Update

func (c *BeaconsMongoDbPersistence) Update(correlationId string, item *data1.BeaconV1) (*data1.BeaconV1, error)

func (*BeaconsMongoDbPersistence) UpdatePartially

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

type BeaconsPostgresPersistence

type BeaconsPostgresPersistence struct {
	cpersist.IdentifiablePostgresPersistence
}

func NewBeaconsPostgresPersistence

func NewBeaconsPostgresPersistence() *BeaconsPostgresPersistence

func (*BeaconsPostgresPersistence) Create

func (c *BeaconsPostgresPersistence) Create(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)

func (*BeaconsPostgresPersistence) DeleteById

func (c *BeaconsPostgresPersistence) DeleteById(correlationId string, id string) (item *data1.BeaconV1, err error)

func (*BeaconsPostgresPersistence) DeleteByIds

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

func (*BeaconsPostgresPersistence) GetListByIds

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

func (*BeaconsPostgresPersistence) GetOneById

func (c *BeaconsPostgresPersistence) GetOneById(correlationId string, id string) (item *data1.BeaconV1, err error)

func (*BeaconsPostgresPersistence) GetOneByUdi

func (c *BeaconsPostgresPersistence) GetOneByUdi(correlationId string, udi string) (*data1.BeaconV1, error)

func (*BeaconsPostgresPersistence) GetPageByFilter

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

func (*BeaconsPostgresPersistence) Update

func (c *BeaconsPostgresPersistence) Update(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)

func (*BeaconsPostgresPersistence) UpdatePartially

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

type IBeaconsPersistence

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

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

	GetOneByUdi(correlationId string, udi string) (res *data1.BeaconV1, err error)

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

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

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