handler

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

const (
	NotifyUserID = "NOTIFICATION"
)

Functions

func Register

func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es v1.Eventstore, command *command.Commands, queries *query.Queries, systemDefaults sd.SystemDefaults, dir http.FileSystem, apiDomain string) []queryv1.Handler

Types

type Config

type Config struct {
	MinimumCycleDuration types.Duration
}

type Configs

type Configs map[string]*Config

type Notification

type Notification struct {
	AesCrypto crypto.EncryptionAlgorithm
	// contains filtered or unexported fields
}

func (*Notification) AggregateTypes

func (_ *Notification) AggregateTypes() []models.AggregateType

func (*Notification) CurrentSequence

func (n *Notification) CurrentSequence() (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 (h *Notification) LockDuration() time.Duration

func (*Notification) MinimumCycleDuration

func (h *Notification) MinimumCycleDuration() time.Duration

func (*Notification) OnError

func (n *Notification) OnError(event *models.Event, err error) error

func (*Notification) OnSuccess

func (n *Notification) OnSuccess() error

func (*Notification) QueryLimit

func (h *Notification) QueryLimit() uint64

func (*Notification) Reduce

func (n *Notification) Reduce(event *models.Event) (err error)

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() (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 (h *NotifyUser) LockDuration() time.Duration

func (*NotifyUser) MinimumCycleDuration

func (h *NotifyUser) MinimumCycleDuration() time.Duration

func (*NotifyUser) OnError

func (p *NotifyUser) OnError(event *es_models.Event, err error) error

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

func (u *NotifyUser) Reduce(event *es_models.Event) (err error)

func (*NotifyUser) Subscription

func (p *NotifyUser) Subscription() *v1.Subscription

func (*NotifyUser) ViewModel

func (p *NotifyUser) ViewModel() string