events

Documentation

Index

• type EventStreamProducer
  • func (esp *EventStreamProducer) RaiseEventAllowed(resourceType string, attributes []string) bool
  • func (esp *EventStreamProducer) RaiseEventForUpdate(eventModelDao m.EventModelDao, resource util.Resource, ...) error
  • func (esp *EventStreamProducer) RaiseEventIf(allowed bool, eventType string, payload []byte, headers []kafka.Header) error
• type EventStreamSender
  • func (esp *EventStreamSender) RaiseEvent(eventType string, payload []byte, headers []kafka.Header) error
• type Sender

Types

type EventStreamProducer

type EventStreamProducer struct {
	Sender
}

func (*EventStreamProducer) RaiseEventAllowed

func (esp *EventStreamProducer) RaiseEventAllowed(resourceType string, attributes []string) bool

func (*EventStreamProducer) RaiseEventForUpdate

func (esp *EventStreamProducer) RaiseEventForUpdate(eventModelDao m.EventModelDao, resource util.Resource, updateAttributes []string, headers []kafka.Header) error

func (*EventStreamProducer) RaiseEventIf

func (esp *EventStreamProducer) RaiseEventIf(allowed bool, eventType string, payload []byte, headers []kafka.Header) error

type EventStreamSender

type EventStreamSender struct {
}

func (*EventStreamSender) RaiseEvent

func (esp *EventStreamSender) RaiseEvent(eventType string, payload []byte, headers []kafka.Header) error

type Sender

type Sender interface {
	RaiseEvent(eventType string, payload []byte, headers []kafka.Header) error
}