events

package
v0.0.0-...-28f18a2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2015 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL