Run NodesReference

pubsub

Package pubsub

import "github.com/luxfi/node/pubsub"

Types

AddAddresses

AddAddresses command to add addresses

Deprecated: The pubsub server is deprecated.

Command

Command execution command

Deprecated: The pubsub server is deprecated.

func (c *Command) String() string

Filter

FilterParam

func NewFilterParam() *FilterParam
func (f *FilterParam) Add(bl ...[]byte) error
func (f *FilterParam) Check(addr []byte) bool
func (f *FilterParam) Filter() bloom.Filter
func (f *FilterParam) Len() int
func (f *FilterParam) NewSet()
func (f *FilterParam) SetFilter(filter bloom.Filter) bloom.Filter

Filterer

NewBloom

NewBloom command for a new bloom filter

Deprecated: The pubsub server is deprecated.

func (c *NewBloom) IsParamsValid() bool

NewSet

NewSet command for a new map set

Deprecated: The pubsub server is deprecated.

Server

Server maintains the set of active clients and sends messages to the clients.

func New(log log.Logger) *Server
func (s *Server) Publish(parser Filterer)
func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)