Documentation ¶
Index ¶
- Constants
- func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, ...) []queryv1.Handler
- type Config
- type Configs
- type Notification
- func (_ *Notification) AggregateTypes() []models.AggregateType
- func (n *Notification) CurrentSequence(instanceID string) (uint64, error)
- func (n *Notification) EventQuery() (*models.SearchQuery, error)
- func (h *Notification) Eventstore() v1.Eventstore
- func (h *Notification) LockDuration() time.Duration
- func (h *Notification) MinimumCycleDuration() time.Duration
- func (n *Notification) OnError(event *models.Event, err error) error
- func (n *Notification) OnSuccess() error
- func (h *Notification) QueryLimit() uint64
- func (n *Notification) Reduce(event *models.Event) (err error)
- func (n *Notification) Subscription() *v1.Subscription
- func (n *Notification) ViewModel() string
- type NotifyUser
- func (_ *NotifyUser) AggregateTypes() []es_models.AggregateType
- func (p *NotifyUser) CurrentSequence(instanceID string) (uint64, error)
- func (p *NotifyUser) EventQuery() (*es_models.SearchQuery, error)
- func (h *NotifyUser) Eventstore() v1.Eventstore
- func (h *NotifyUser) LockDuration() time.Duration
- func (h *NotifyUser) MinimumCycleDuration() time.Duration
- func (p *NotifyUser) OnError(event *es_models.Event, err error) error
- func (u *NotifyUser) OnSuccess() error
- func (u *NotifyUser) ProcessOrg(event *es_models.Event) (err error)
- func (u *NotifyUser) ProcessUser(event *es_models.Event) (err error)
- func (h *NotifyUser) QueryLimit() uint64
- func (u *NotifyUser) Reduce(event *es_models.Event) (err error)
- func (p *NotifyUser) Subscription() *v1.Subscription
- func (p *NotifyUser) ViewModel() string
Constants ¶
View Source
const (
NotifyUserID = "NOTIFICATION"
)
Variables ¶
This section is empty.
Functions ¶
func Register ¶
func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es v1.Eventstore, command *command.Commands, queries *query.Queries, externalPort uint16, externalSecure bool, dir http.FileSystem, assetsPrefix string, userEncryption crypto.EncryptionAlgorithm, smtpEncryption crypto.EncryptionAlgorithm, smsEncryption crypto.EncryptionAlgorithm, ) []queryv1.Handler
Types ¶
type Notification ¶
type Notification struct {
// contains filtered or unexported fields
}
func (*Notification) AggregateTypes ¶
func (_ *Notification) AggregateTypes() []models.AggregateType
func (*Notification) CurrentSequence ¶
func (n *Notification) CurrentSequence(instanceID string) (uint64, error)
func (*Notification) EventQuery ¶
func (n *Notification) EventQuery() (*models.SearchQuery, error)
func (*Notification) Eventstore ¶
func (h *Notification) Eventstore() v1.Eventstore
func (*Notification) LockDuration ¶
func (*Notification) MinimumCycleDuration ¶
func (*Notification) OnSuccess ¶
func (n *Notification) OnSuccess() error
func (*Notification) QueryLimit ¶
func (h *Notification) QueryLimit() uint64
func (*Notification) Subscription ¶
func (n *Notification) Subscription() *v1.Subscription
func (*Notification) ViewModel ¶
func (n *Notification) ViewModel() string
type NotifyUser ¶
type NotifyUser struct {
// contains filtered or unexported fields
}
func (*NotifyUser) AggregateTypes ¶
func (_ *NotifyUser) AggregateTypes() []es_models.AggregateType
func (*NotifyUser) CurrentSequence ¶
func (p *NotifyUser) CurrentSequence(instanceID string) (uint64, error)
func (*NotifyUser) EventQuery ¶
func (p *NotifyUser) EventQuery() (*es_models.SearchQuery, error)
func (*NotifyUser) Eventstore ¶
func (h *NotifyUser) Eventstore() v1.Eventstore
func (*NotifyUser) LockDuration ¶
func (*NotifyUser) MinimumCycleDuration ¶
func (*NotifyUser) OnSuccess ¶
func (u *NotifyUser) OnSuccess() error
func (*NotifyUser) ProcessOrg ¶
func (u *NotifyUser) ProcessOrg(event *es_models.Event) (err error)
func (*NotifyUser) ProcessUser ¶
func (u *NotifyUser) ProcessUser(event *es_models.Event) (err error)
func (*NotifyUser) QueryLimit ¶
func (h *NotifyUser) QueryLimit() uint64
func (*NotifyUser) Subscription ¶
func (p *NotifyUser) Subscription() *v1.Subscription
func (*NotifyUser) ViewModel ¶
func (p *NotifyUser) ViewModel() string
Click to show internal directories.
Click to hide internal directories.