pubsub

README

pubsub

Documentation

Index

• func SetLoggerInstance(logger ILogger) bool
• type ILogger
• type ObServer
  • func NewObServer(enableSafeMode bool, subArgs ...SubArg) (*ObServer, error)
  • func (t *ObServer) Publish(topic interface{}, enableCo bool, args ...interface{}) (retErr error)
  • func (t *ObServer) Subscribe(topic interface{}, subKey interface{}, topicFunc TopicFunc, ...) (retErr error)
  • func (t *ObServer) Unsubscribe(topic interface{}, subKey interface{}) (retErr error)
• type SubArg
• type Subject
• type TopicFunc

Functions

func SetLoggerInstance

func SetLoggerInstance(logger ILogger) bool

Types

type ILogger

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

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

func NewObServer

func NewObServer(enableSafeMode bool, subArgs ...SubArg) (*ObServer, error)

func (*ObServer) Publish

func (t *ObServer) Publish(topic interface{}, enableCo bool, args ...interface{}) (retErr error)

func (*ObServer) Subscribe

func (t *ObServer) Subscribe(topic interface{}, subKey interface{}, topicFunc TopicFunc, preArgs ...interface{}) (retErr error)

func (*ObServer) Unsubscribe

func (t *ObServer) Unsubscribe(topic interface{}, subKey interface{}) (retErr error)

type SubArg

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

type Subject

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

type TopicFunc

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