Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Authorizer ¶
type Authorizer interface {
Authorize(*security.Channel, uint8) (contract.Contract, security.Key, bool)
}
Authorizer service performs authorization checks.
type Conn ¶
type Conn interface { io.Closer message.Subscriber CanSubscribe(message.Ssid, []byte) bool CanUnsubscribe(message.Ssid, []byte) bool LocalID() security.ID Username() string Track(contract.Contract) Links() map[string]string GetLink([]byte) []byte AddLink(string, *security.Channel) }
Conn represents a connection interface.
type Notifier ¶
type Notifier interface { NotifySubscribe(message.Subscriber, *event.Subscription) NotifyUnsubscribe(message.Subscriber, *event.Subscription) }
Notifier notifies the cluster about publish/subscribe events.
type PubSub ¶
type PubSub interface { Publish(*message.Message, func(message.Subscriber) bool) int64 Subscribe(message.Subscriber, *event.Subscription) bool Unsubscribe(message.Subscriber, *event.Subscription) bool Handle(string, Handler) }
PubSub represents a pubsub service.
type Replicator ¶
Replicator replicates an event withih the cluster
type Response ¶
type Response interface {
ForRequest(uint16)
}
Response represents an emitter response.
Click to show internal directories.
Click to hide internal directories.