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 Decryptor

      type Decryptor interface {
      	DecryptKey(string) (security.Key, error)
      }

        Decryptor decrypts security keys.

        type Handler

        type Handler func(Conn, []byte) (Response, bool)

          Handler represents a generic emitter request handler

          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

              type Replicator interface {
              	Notify(event.Event, bool)
              	Contains(event.Event) bool
              }

                Replicator replicates an event withih the cluster

                type Response

                type Response interface {
                	ForRequest(uint16)
                }

                  Response represents an emitter response.

                  type Surveyee

                  type Surveyee interface {
                  	OnSurvey(string, []byte) ([]byte, bool)
                  }

                    Surveyee handles the surveys.

                    type Surveyor

                    type Surveyor interface {
                    	Query(string, []byte) (message.Awaiter, error)
                    }

                      Surveyor issues the surveys.

                      Source Files

                      Directories

                      Path Synopsis