duey

Documentation

Index

• type EventStreamer
  • func Init() (*EventStreamer, error)
  • func (s *EventStreamer) Publish(subject string, model interface{}) (err error)
  • func (s *EventStreamer) Request(subject string, model interface{}, res interface{}, timeout time.Duration) (err error)
  • func (s *EventStreamer) Stop()
  • func (s *EventStreamer) Subscribe(subject string, callback Handler) (err error)
• type Handler

Types

type EventStreamer

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

func Init

func Init() (*EventStreamer, error)

func (*EventStreamer) Publish

func (s *EventStreamer) Publish(subject string, model interface{}) (err error)

Publish publishes the model argument to the subject queue

func (*EventStreamer) Request

func (s *EventStreamer) Request(subject string, model interface{}, res interface{}, timeout time.Duration) (err error)

Request will request a reply from the subject queue and return the model

func (*EventStreamer) Stop

func (s *EventStreamer) Stop()

func (*EventStreamer) Subscribe

func (s *EventStreamer) Subscribe(subject string, callback Handler) (err error)

Subscribe listens for models sent into the subject queue

type Handler

type Handler interface{}