publish

Documentation

Index

• type LogAsyncEvent
• type LogAsyncEventMessage
• type LogPublisherFactory
  • func (m *LogPublisherFactory) NewMessage(topic string, data interface{}) *LogAsyncEventMessage
  • func (m *LogPublisherFactory) PublishAsyncEvent(msg *LogAsyncEventMessage) (bool, error)
• type LogPublisherInterface

Types

type LogAsyncEvent

type LogAsyncEvent struct {
	Topic string
}

type LogAsyncEventMessage

type LogAsyncEventMessage struct {
	Topic string
	Data  interface{}
}

type LogPublisherFactory

type LogPublisherFactory struct{}

func (*LogPublisherFactory) NewMessage

func (m *LogPublisherFactory) NewMessage(topic string, data interface{}) *LogAsyncEventMessage

func (*LogPublisherFactory) PublishAsyncEvent

func (m *LogPublisherFactory) PublishAsyncEvent(msg *LogAsyncEventMessage) (bool, error)

type LogPublisherInterface

type LogPublisherInterface interface {
	PublishAsyncEvent(msg *LogAsyncEventMessage) (bool, error)
	NewAsyncEventMessage(msg *LogAsyncEventMessage) *LogAsyncEventMessage
}