Documentation ¶
Index ¶
- Constants
- Variables
- type EventHub
- func (eh *EventHub) DecodeEventMessage(encodedMessage []byte) *events.Event
- func (eh *EventHub) EncodeEventMessage(eventMessage events.Event) []byte
- func (eh *EventHub) Publish(queueName string, messageBody []byte) error
- func (eh *EventHub) RaiseCreateRecordEvent(recordId string)
- func (eh *EventHub) RaiseNotifyCallbackEvent(schemaUrl string, recordId string, protocol string, protocolVersion string, ...)
- func (eh *EventHub) Subscribe(queueName string) chan *nats.Msg
- func (eh *EventHub) Unsubscribe(queueName string) error
Constants ¶
View Source
const (
DISC_DATA_KEY_CALLBACK_URI = "disc-data-callback-url"
)
Variables ¶
View Source
var CreateRecordEventQueue string = "events-create-record"
View Source
var NotifyCallbackQueue string = "events-notify-callback"
Functions ¶
This section is empty.
Types ¶
type EventHub ¶
type EventHub struct { Client *nats.Conn Subs map[string]*nats.Subscription }
func CreateEventHub ¶
func (*EventHub) DecodeEventMessage ¶
func (*EventHub) EncodeEventMessage ¶
func (*EventHub) RaiseCreateRecordEvent ¶
func (*EventHub) RaiseNotifyCallbackEvent ¶
func (*EventHub) Unsubscribe ¶
Click to show internal directories.
Click to hide internal directories.