storages

Documentation

Index

• type DB
  • func (s DB) ByDate(from, to time.Time) ([]models.Incident, error)
  • func (s DB) Create(incident models.Incident) (models.Incident, error)
  • func (s DB) Creator() func(u *url.URL) (Store, error)
  • func (s DB) Delete(guid string) error
  • func (s DB) Detect(u *url.URL) bool
  • func (s DB) GetDb() *gorm.DB
  • func (s DB) Persistents() ([]models.Incident, error)
  • func (s DB) Ping() error
  • func (s DB) Read(guid string) (models.Incident, error)
  • func (s DB) Subscribe(email string) error
  • func (s DB) Subscribers() ([]string, error)
  • func (s DB) Unsubscribe(email string) error
  • func (s DB) Update(guid string, incident models.Incident) (models.Incident, error)
• type Local
  • func (l Local) ByDate(from, to time.Time) ([]models.Incident, error)
  • func (l Local) Create(incident models.Incident) (models.Incident, error)
  • func (l Local) Creator() func(u *url.URL) (Store, error)
  • func (l Local) Delete(guid string) error
  • func (l Local) Detect(u *url.URL) bool
  • func (l Local) Persistents() ([]models.Incident, error)
  • func (l Local) Ping() error
  • func (l Local) Read(guid string) (models.Incident, error)
  • func (l Local) Subscribe(email string) error
  • func (l Local) Subscribers() ([]string, error)
  • func (l Local) Unsubscribe(email string) error
  • func (l Local) Update(guid string, incident models.Incident) (models.Incident, error)
• type Replicate
  • func NewReplicate(storesInit []Store) *Replicate
  • func NewReplicateWithWaits(storesInit []Store, waitReplay, waitClean time.Duration) *Replicate
  • func (m *Replicate) ByDate(from, to time.Time) ([]models.Incident, error)
  • func (m *Replicate) Create(incident models.Incident) (models.Incident, error)
  • func (m *Replicate) Creator() func(u *url.URL) (Store, error)
  • func (m *Replicate) Delete(guid string) error
  • func (m *Replicate) Detect(u *url.URL) bool
  • func (m *Replicate) Persistents() ([]models.Incident, error)
  • func (m *Replicate) Ping() error
  • func (m *Replicate) Read(guid string) (models.Incident, error)
  • func (m *Replicate) Subscribe(email string) error
  • func (m *Replicate) Subscribers() ([]string, error)
  • func (m *Replicate) Unsubscribe(email string) error
  • func (m *Replicate) Update(guid string, incident models.Incident) (models.Incident, error)
• type Retry
  • func NewRetry(next Store, nbRetry int) *Retry
  • func NewRetryWithSleepTime(next Store, nbRetry int, sleepTime time.Duration) *Retry
  • func (m Retry) ByDate(from, to time.Time) ([]models.Incident, error)
  • func (m Retry) Create(incident models.Incident) (models.Incident, error)
  • func (m Retry) Creator() func(u *url.URL) (Store, error)
  • func (m Retry) Delete(guid string) error
  • func (m Retry) Detect(u *url.URL) bool
  • func (m Retry) Persistents() ([]models.Incident, error)
  • func (m Retry) Ping() error
  • func (m Retry) Read(guid string) (models.Incident, error)
  • func (m Retry) Subscribe(email string) error
  • func (m Retry) Subscribers() ([]string, error)
  • func (m Retry) Unsubscribe(email string) error
  • func (m Retry) Update(guid string, incident models.Incident) (models.Incident, error)
• type S3
  • func (s *S3) ByDate(from, to time.Time) ([]models.Incident, error)
  • func (s *S3) Create(incident models.Incident) (models.Incident, error)
  • func (s *S3) Creator() func(u *url.URL) (Store, error)
  • func (s *S3) Delete(guid string) error
  • func (s S3) Detect(u *url.URL) bool
  • func (s S3) Persistents() ([]models.Incident, error)
  • func (s *S3) Ping() error
  • func (s *S3) Read(guid string) (models.Incident, error)
  • func (s S3) Subscribe(email string) error
  • func (s S3) Subscribers() ([]string, error)
  • func (s S3) Unsubscribe(email string) error
  • func (s *S3) Update(guid string, incident models.Incident) (models.Incident, error)
• type Store
  • func Factory(urls []*url.URL) (Store, error)
• type Subscriber

Types

type DB

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

func (DB) ByDate

func (s DB) ByDate(from, to time.Time) ([]models.Incident, error)

func (DB) Create

func (s DB) Create(incident models.Incident) (models.Incident, error)

func (DB) Creator

func (s DB) Creator() func(u *url.URL) (Store, error)

func (DB) Delete

func (s DB) Delete(guid string) error

func (DB) Detect

func (s DB) Detect(u *url.URL) bool

func (DB) GetDb

func (s DB) GetDb() *gorm.DB

func (DB) Persistents

func (s DB) Persistents() ([]models.Incident, error)

func (DB) Ping

func (s DB) Ping() error

func (DB) Read

func (s DB) Read(guid string) (models.Incident, error)

func (DB) Subscribe

func (s DB) Subscribe(email string) error

func (DB) Subscribers

func (s DB) Subscribers() ([]string, error)

func (DB) Unsubscribe

func (s DB) Unsubscribe(email string) error

func (DB) Update

func (s DB) Update(guid string, incident models.Incident) (models.Incident, error)

type Local

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

func (Local) ByDate

func (l Local) ByDate(from, to time.Time) ([]models.Incident, error)

func (Local) Create

func (l Local) Create(incident models.Incident) (models.Incident, error)

func (Local) Creator

func (l Local) Creator() func(u *url.URL) (Store, error)

func (Local) Delete

func (l Local) Delete(guid string) error

func (Local) Detect

func (l Local) Detect(u *url.URL) bool

func (Local) Persistents

func (l Local) Persistents() ([]models.Incident, error)

func (Local) Ping

func (l Local) Ping() error

func (Local) Read

func (l Local) Read(guid string) (models.Incident, error)

func (Local) Subscribe

func (l Local) Subscribe(email string) error

func (Local) Subscribers

func (l Local) Subscribers() ([]string, error)

func (Local) Unsubscribe

func (l Local) Unsubscribe(email string) error

func (Local) Update

func (l Local) Update(guid string, incident models.Incident) (models.Incident, error)

type Replicate

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

func NewReplicate

func NewReplicate(storesInit []Store) *Replicate

func NewReplicateWithWaits

func NewReplicateWithWaits(storesInit []Store, waitReplay, waitClean time.Duration) *Replicate

func (*Replicate) ByDate

func (m *Replicate) ByDate(from, to time.Time) ([]models.Incident, error)

func (*Replicate) Create

func (m *Replicate) Create(incident models.Incident) (models.Incident, error)

func (*Replicate) Creator

func (m *Replicate) Creator() func(u *url.URL) (Store, error)

func (*Replicate) Delete

func (m *Replicate) Delete(guid string) error

func (*Replicate) Detect

func (m *Replicate) Detect(u *url.URL) bool

func (*Replicate) Persistents

func (m *Replicate) Persistents() ([]models.Incident, error)

func (*Replicate) Ping

func (m *Replicate) Ping() error

func (*Replicate) Read

func (m *Replicate) Read(guid string) (models.Incident, error)

func (*Replicate) Subscribe

func (m *Replicate) Subscribe(email string) error

func (*Replicate) Subscribers

func (m *Replicate) Subscribers() ([]string, error)

func (*Replicate) Unsubscribe

func (m *Replicate) Unsubscribe(email string) error

func (*Replicate) Update

func (m *Replicate) Update(guid string, incident models.Incident) (models.Incident, error)

type Retry

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

func NewRetry

func NewRetry(next Store, nbRetry int) *Retry

func NewRetryWithSleepTime

func NewRetryWithSleepTime(next Store, nbRetry int, sleepTime time.Duration) *Retry

func (Retry) ByDate

func (m Retry) ByDate(from, to time.Time) ([]models.Incident, error)

func (Retry) Create

func (m Retry) Create(incident models.Incident) (models.Incident, error)

func (Retry) Creator

func (m Retry) Creator() func(u *url.URL) (Store, error)

func (Retry) Delete

func (m Retry) Delete(guid string) error

func (Retry) Detect

func (m Retry) Detect(u *url.URL) bool

func (Retry) Persistents

func (m Retry) Persistents() ([]models.Incident, error)

func (Retry) Ping

func (m Retry) Ping() error

func (Retry) Read

func (m Retry) Read(guid string) (models.Incident, error)

func (Retry) Subscribe

func (m Retry) Subscribe(email string) error

func (Retry) Subscribers

func (m Retry) Subscribers() ([]string, error)

func (Retry) Unsubscribe

func (m Retry) Unsubscribe(email string) error

func (Retry) Update

func (m Retry) Update(guid string, incident models.Incident) (models.Incident, error)

type S3

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

func (*S3) ByDate

func (s *S3) ByDate(from, to time.Time) ([]models.Incident, error)

func (*S3) Create

func (s *S3) Create(incident models.Incident) (models.Incident, error)

func (*S3) Creator

func (s *S3) Creator() func(u *url.URL) (Store, error)

func (*S3) Delete

func (s *S3) Delete(guid string) error

func (S3) Detect

func (s S3) Detect(u *url.URL) bool

func (S3) Persistents

func (s S3) Persistents() ([]models.Incident, error)

func (*S3) Ping

func (s *S3) Ping() error

func (*S3) Read

func (s *S3) Read(guid string) (models.Incident, error)

func (S3) Subscribe

func (s S3) Subscribe(email string) error

func (S3) Subscribers

func (s S3) Subscribers() ([]string, error)

func (S3) Unsubscribe

func (s S3) Unsubscribe(email string) error

func (*S3) Update

func (s *S3) Update(guid string, incident models.Incident) (models.Incident, error)

type Store

type Store interface {
	Creator() func(u *url.URL) (Store, error)
	Detect(u *url.URL) bool

	Create(incident models.Incident) (models.Incident, error)
	Update(guid string, incident models.Incident) (models.Incident, error)
	Delete(guid string) error
	Read(guid string) (models.Incident, error)
	ByDate(from, to time.Time) ([]models.Incident, error)
	Persistents() ([]models.Incident, error)

	Subscribe(email string) error
	Unsubscribe(email string) error
	Subscribers() ([]string, error)

	Ping() error
}

func Factory

func Factory(urls []*url.URL) (Store, error)

type Subscriber

type Subscriber struct {
	Email string `gorm:"primary_key"`
}