events

Documentation

Index

• Constants
• func Close() error
• func Debug(msg string) error
• func Error(msg string, err error) error
• func GetCallingFunctionName(path string, line int, ok bool) string
• func Info(msg string) error
• func Init() error
• func Trace(msg string) error
• type EventConsumer
  • func NewEventConsumer() (*EventConsumer, error)
  • func (e *EventConsumer) Close() error
  • func (e *EventConsumer) Consume() (<-chan mapping.ApplicationEvent, <-chan error)
• type EventPublisher
  • func NewEventPublisher() (*EventPublisher, error)
  • func (e *EventPublisher) Close() error
  • func (e *EventPublisher) PublishDebug(msg string) error
  • func (e *EventPublisher) PublishError(msg string) error
  • func (e *EventPublisher) PublishEvent(msg *mapping.ApplicationEvent) error
  • func (e *EventPublisher) PublishInfo(msg string) error
  • func (e *EventPublisher) PublishTrace(msg string) error

Constants

const (
	ErrorLevel    = "error"
	InfoLevel     = "info"
	DebugLevel    = "debug"
	TraceLevel    = "trace"
	UnknownCaller = "LOG"
)

Functions

func Close

func Close() error

func Debug

func Debug(msg string) error

func Error

func Error(msg string, err error) error

func GetCallingFunctionName

func GetCallingFunctionName(path string, line int, ok bool) string

func Info

func Info(msg string) error

func Init

func Init() error

func Trace

func Trace(msg string) error

Types

type EventConsumer

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

func NewEventConsumer

func NewEventConsumer() (*EventConsumer, error)

func (*EventConsumer) Close

func (e *EventConsumer) Close() error

func (*EventConsumer) Consume

func (e *EventConsumer) Consume() (<-chan mapping.ApplicationEvent, <-chan error)

type EventPublisher

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

func NewEventPublisher

func NewEventPublisher() (*EventPublisher, error)

func (*EventPublisher) Close

func (e *EventPublisher) Close() error

func (*EventPublisher) PublishDebug

func (e *EventPublisher) PublishDebug(msg string) error

func (*EventPublisher) PublishError

func (e *EventPublisher) PublishError(msg string) error

func (*EventPublisher) PublishEvent

func (e *EventPublisher) PublishEvent(msg *mapping.ApplicationEvent) error

func (*EventPublisher) PublishInfo

func (e *EventPublisher) PublishInfo(msg string) error

func (*EventPublisher) PublishTrace

func (e *EventPublisher) PublishTrace(msg string) error