broker

README

Moved to github.com/illchi

illchi

Federated P2P message broker

Documentation

Index

• Constants
• Variables
• type Authenticator
• type Broker
  • func New(config Config) (broker Broker, err error)
• type Config
• type ID
  • func (id ID) String() string
• type Statics
  • func (s *Statics) JSON() []byte

Constants

const Version = "0.1.1"

Variables

var CertsCacheDir = ""

var ErrBadContentLength = errors.New("bad content length")

var ErrConflictID = errors.New("conflict id")

var HostName = ""

Types

type Authenticator

type Authenticator func(Broker, *fasthttp.RequestCtx) error

type Broker

type Broker interface {
	Close() error
	Listen() error
	Stat() *Statics
}

func New

func New(config Config) (broker Broker, err error)

type Config

type Config struct {
	Addr          string
	Origin        string
	Authenticator Authenticator
	Cert, Key     []byte
}

type ID

type ID uint32

func (ID) String

func (id ID) String() string

type Statics

type Statics struct {
	UpTime      int32  `json:"uptime"`
	Connections int32  `json:"conns"`
	Version     string `json:"v"`
}

Statics is Server status and Statics

func (*Statics) JSON

func (s *Statics) JSON() []byte