pubsub

Documentation

Index

• type PubSub

Types

type PubSub

type PubSub interface {
	Type() string
	IsConnected() bool
	Close()
	Connect() (bool, error)
	Ping()
	Params(params js.Json) error
	Subscribe(channel string, reciveFn func(message.Message))
	Stack(channel string, reciveFn func(message.Message))
	Unsubscribe(channel string)
	Publish(channel string, message interface{})
	SendMessage(clientId string, message interface{}) error
}

PubSub interface