godispatch

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

type BusConfig struct {
	Url                       string
	InputQueue                string
	ErrorQueue                string
	RetryQueue                string
	RetryIntervalMilliseconds int32
	RetryLimit                int32
}

type Context struct {
	Delivery *amqp.Delivery
	Message  interface{}
	Log      Logger
	Keys     map[string]interface{}
	Errors   errorMsgs
	// contains filtered or unexported fields
}

type HandlerFunc func(*Context)

type Logger interface {
	Debugf(s string, args ...interface{})
	Debug(s string)
	Infof(s string, args ...interface{})
	Info(s string)
	Warnf(s string, args ...interface{})
	Warn(s string)
	Errorf(s string, args ...interface{})
	Error(s string)
	WithPrefix(s string) Logger
}

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