data

Documentation

Index

• type Dal
• type MongoDal
  • func New(connectionString string, dataBaseName string) (*MongoDal, error)
  • func (m *MongoDal) DeleteDeadLetterItems(dead []*entities.DeadLetterItem) error
  • func (m *MongoDal) DeleteRegistration(registration *entities.Registration) error
  • func (m *MongoDal) GetDeadLetterItemsReadyForRetry() ([]*entities.DeadLetterItem, error)
  • func (m *MongoDal) GetRegistrationByEventAndCallback(event string, callback_url string) (*entities.Registration, error)
  • func (m *MongoDal) GetRegistrationsByEvent(event string) ([]*entities.Registration, error)
  • func (m *MongoDal) UpsertDeadLetterItem(dead *entities.DeadLetterItem) error
  • func (m *MongoDal) UpsertEventStore(event *entities.EventStoreItem) error
  • func (m *MongoDal) UpsertRegistration(registration *entities.Registration) error

Types

type Dal

type Dal interface {
	GetRegistrationsByEvent(event string) ([]*entities.Registration, error)
	GetRegistrationByEventAndCallback(event string, callback_url string) (*entities.Registration, error)
	UpsertRegistration(registration *entities.Registration) error
	DeleteRegistration(registration *entities.Registration) error

	UpsertEventStore(event *entities.EventStoreItem) error

	UpsertDeadLetterItem(dead *entities.DeadLetterItem) error
	GetDeadLetterItemsReadyForRetry() ([]*entities.DeadLetterItem, error)
	DeleteDeadLetterItems(dead []*entities.DeadLetterItem) error
}

type MongoDal

type MongoDal struct {
	// contains filtered or unexported fields
}

func New

func New(connectionString string, dataBaseName string) (*MongoDal, error)

func (*MongoDal) DeleteDeadLetterItems

func (m *MongoDal) DeleteDeadLetterItems(dead []*entities.DeadLetterItem) error

func (*MongoDal) DeleteRegistration

func (m *MongoDal) DeleteRegistration(registration *entities.Registration) error

func (*MongoDal) GetDeadLetterItemsReadyForRetry

func (m *MongoDal) GetDeadLetterItemsReadyForRetry() ([]*entities.DeadLetterItem, error)

func (*MongoDal) GetRegistrationByEventAndCallback

func (m *MongoDal) GetRegistrationByEventAndCallback(event string, callback_url string) (*entities.Registration, error)

func (*MongoDal) GetRegistrationsByEvent

func (m *MongoDal) GetRegistrationsByEvent(event string) ([]*entities.Registration, error)

func (*MongoDal) UpsertDeadLetterItem

func (m *MongoDal) UpsertDeadLetterItem(dead *entities.DeadLetterItem) error

func (*MongoDal) UpsertEventStore

func (m *MongoDal) UpsertEventStore(event *entities.EventStoreItem) error

func (*MongoDal) UpsertRegistration

func (m *MongoDal) UpsertRegistration(registration *entities.Registration) error