persistence

Documentation

Index

• type EventLogFilePersistence
  • func NewEventLogFilePersistence(path string) *EventLogFilePersistence
  • func (c *EventLogFilePersistence) Configure(config *cconf.ConfigParams)
• type EventLogMemoryPersistence
  • func NewEventLogMemoryPersistence() *EventLogMemoryPersistence
  • func (c *EventLogMemoryPersistence) Create(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)
  • func (c *EventLogMemoryPersistence) DeleteById(correlationId string, id string) (*data1.SystemEventV1, error)
  • func (c *EventLogMemoryPersistence) GetOneById(correlationId string, id string) (*data1.SystemEventV1, error)
  • func (c *EventLogMemoryPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.SystemEventV1DataPage, error)
  • func (c *EventLogMemoryPersistence) Update(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)
• type EventLogMongoDbPersistence
  • func NewEventLogMongoDbPersistence() *EventLogMongoDbPersistence
  • func (c *EventLogMongoDbPersistence) Create(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)
  • func (c *EventLogMongoDbPersistence) DeleteById(correlationId string, id string) (*data1.SystemEventV1, error)
  • func (c *EventLogMongoDbPersistence) GetOneById(correlationId string, id string) (*data1.SystemEventV1, error)
  • func (c *EventLogMongoDbPersistence) GetPageByFilter(correlationId string, filter *cdata.FilterParams, paging *cdata.PagingParams) (*data1.SystemEventV1DataPage, error)
  • func (c *EventLogMongoDbPersistence) Update(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)
• type IEventLogPersistence

Types

type EventLogFilePersistence

type EventLogFilePersistence struct {
	EventLogMemoryPersistence
	// contains filtered or unexported fields
}

func NewEventLogFilePersistence

func NewEventLogFilePersistence(path string) *EventLogFilePersistence

func (*EventLogFilePersistence) Configure

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

type EventLogMemoryPersistence

type EventLogMemoryPersistence struct {
	cpersist.IdentifiableMemoryPersistence
}

func NewEventLogMemoryPersistence

func NewEventLogMemoryPersistence() *EventLogMemoryPersistence

func (*EventLogMemoryPersistence) Create

func (c *EventLogMemoryPersistence) Create(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)

func (*EventLogMemoryPersistence) DeleteById

func (c *EventLogMemoryPersistence) DeleteById(correlationId string, id string) (*data1.SystemEventV1, error)

func (*EventLogMemoryPersistence) GetOneById

func (c *EventLogMemoryPersistence) GetOneById(correlationId string, id string) (*data1.SystemEventV1, error)

func (*EventLogMemoryPersistence) GetPageByFilter

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

func (*EventLogMemoryPersistence) Update

func (c *EventLogMemoryPersistence) Update(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)

type EventLogMongoDbPersistence

type EventLogMongoDbPersistence struct {
	mpersist.IdentifiableMongoDbPersistence
}

func NewEventLogMongoDbPersistence

func NewEventLogMongoDbPersistence() *EventLogMongoDbPersistence

func (*EventLogMongoDbPersistence) Create

func (c *EventLogMongoDbPersistence) Create(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)

func (*EventLogMongoDbPersistence) DeleteById

func (c *EventLogMongoDbPersistence) DeleteById(correlationId string, id string) (*data1.SystemEventV1, error)

func (*EventLogMongoDbPersistence) GetOneById

func (c *EventLogMongoDbPersistence) GetOneById(correlationId string, id string) (*data1.SystemEventV1, error)

func (*EventLogMongoDbPersistence) GetPageByFilter

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

func (*EventLogMongoDbPersistence) Update

func (c *EventLogMongoDbPersistence) Update(correlationId string, item *data1.SystemEventV1) (*data1.SystemEventV1, error)

type IEventLogPersistence

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

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

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

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

	DeleteById(correlationId string, id string) (item *data1.SystemEventV1, err error)
}