pubsub

type ILogger interface {
	All(v ...interface{})
	AllF(format string, v ...interface{})
	Debug(v ...interface{})
	DebugF(format string, v ...interface{})
	Info(v ...interface{})
	InfoF(format string, v ...interface{})
	Warning(v ...interface{})
	WarningF(format string, v ...interface{})
	Error(v ...interface{})
	ErrorF(format string, v ...interface{})
}

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

type SubArg struct {
	Topic     interface{}
	SubKey    interface{}
	TopicFunc TopicFunc
	PreArgs   []interface{}
}

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

type TopicFunc func(args ...interface{})