persistence

Documentation

Index

• type BeaconsFilePersistence
  • func NewBeaconsFilePersistence(path string) *BeaconsFilePersistence
  • func (c *BeaconsFilePersistence) Configure(config *cconf.ConfigParams)
• 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) 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)
• type BeaconsMongoDbPersistence
  • func NewBeaconsMongoDbPersistence() *BeaconsMongoDbPersistence
  • func (c *BeaconsMongoDbPersistence) Create(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)
  • func (c *BeaconsMongoDbPersistence) DeleteById(correlationId string, id string) (result *data1.BeaconV1, err error)
  • func (c *BeaconsMongoDbPersistence) GetOneById(correlationId string, id string) (item *data1.BeaconV1, err error)
  • func (c *BeaconsMongoDbPersistence) GetOneByUdi(correlationId string, udi string) (result *data1.BeaconV1, err error)
  • func (c *BeaconsMongoDbPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (page *data1.BeaconV1DataPage, err error)
  • func (c *BeaconsMongoDbPersistence) Update(correlationId string, item *data1.BeaconV1) (result *data1.BeaconV1, err error)
• type IBeaconsPersistence

Types

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 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) 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)

type BeaconsMongoDbPersistence

type BeaconsMongoDbPersistence struct {
	mpersist.IdentifiableMongoDbPersistence
}

func NewBeaconsMongoDbPersistence

func NewBeaconsMongoDbPersistence() *BeaconsMongoDbPersistence

func (*BeaconsMongoDbPersistence) Create

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

func (*BeaconsMongoDbPersistence) DeleteById

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

func (*BeaconsMongoDbPersistence) GetOneById

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

func (*BeaconsMongoDbPersistence) GetOneByUdi

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

func (*BeaconsMongoDbPersistence) GetPageByFilter

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

func (*BeaconsMongoDbPersistence) Update

func (c *BeaconsMongoDbPersistence) Update(correlationId string, item *data1.BeaconV1) (result *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)
}