nsqlookupd

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 26, 2023 License: MIT Imports: 20 Imported by: 55

README

nsqlookupd

nsqlookupd is the daemon that manages topology metadata and serves client requests to discover the location of topics at runtime.

Read the docs

Documentation

Index

Constants

View Source 
const (
	LOG_DEBUG = lg.DEBUG
	LOG_INFO  = lg.INFO
	LOG_WARN  = lg.WARN
	LOG_ERROR = lg.ERROR
	LOG_FATAL = lg.FATAL
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientV1 

type ClientV1 struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewClientV1 

func NewClientV1(conn net.Conn) *ClientV1

func (*ClientV1) String 

func (c *ClientV1) String() string

type Logger added in v1.1.0 

type Logger lg.Logger

type LookupProtocolV1 

type LookupProtocolV1 struct {
	// contains filtered or unexported fields
}

func (*LookupProtocolV1) Exec 

func (p *LookupProtocolV1) Exec(client *ClientV1, reader *bufio.Reader, params []string) ([]byte, error)

func (*LookupProtocolV1) IDENTIFY 

func (p *LookupProtocolV1) IDENTIFY(client *ClientV1, reader *bufio.Reader, params []string) ([]byte, error)

func (*LookupProtocolV1) IOLoop 

func (p *LookupProtocolV1) IOLoop(c protocol.Client) error

func (*LookupProtocolV1) NewClient added in v1.2.1 

func (p *LookupProtocolV1) NewClient(conn net.Conn) protocol.Client

func (*LookupProtocolV1) PING 

func (p *LookupProtocolV1) PING(client *ClientV1, params []string) ([]byte, error)

func (*LookupProtocolV1) REGISTER 

func (p *LookupProtocolV1) REGISTER(client *ClientV1, reader *bufio.Reader, params []string) ([]byte, error)

func (*LookupProtocolV1) UNREGISTER 

func (p *LookupProtocolV1) UNREGISTER(client *ClientV1, reader *bufio.Reader, params []string) ([]byte, error)

type NSQLookupd 

type NSQLookupd struct {
	sync.RWMutex

	DB *RegistrationDB
	// contains filtered or unexported fields
}

func New added in v0.3.6 

func New(opts *Options) (*NSQLookupd, error)

func (*NSQLookupd) Exit 

func (l *NSQLookupd) Exit()

func (*NSQLookupd) Main 

func (l *NSQLookupd) Main() error

Main starts an instance of nsqlookupd and returns an error if there was a problem starting up.

func (*NSQLookupd) RealHTTPAddr added in v0.3.3 

func (l *NSQLookupd) RealHTTPAddr() *net.TCPAddr

func (*NSQLookupd) RealTCPAddr added in v0.3.3 

func (l *NSQLookupd) RealTCPAddr() *net.TCPAddr

type Options added in v0.3.6 

type Options struct {
	LogLevel  lg.LogLevel `flag:"log-level"`
	LogPrefix string      `flag:"log-prefix"`
	Logger    Logger

	TCPAddress       string `flag:"tcp-address"`
	HTTPAddress      string `flag:"http-address"`
	BroadcastAddress string `flag:"broadcast-address"`

	InactiveProducerTimeout time.Duration `flag:"inactive-producer-timeout"`
	TombstoneLifetime       time.Duration `flag:"tombstone-lifetime"`
}

func NewOptions added in v0.3.6 

func NewOptions() *Options

type PeerInfo added in v0.2.18 

type PeerInfo struct {
	RemoteAddress    string `json:"remote_address"`
	Hostname         string `json:"hostname"`
	BroadcastAddress string `json:"broadcast_address"`
	TCPPort          int    `json:"tcp_port"`
	HTTPPort         int    `json:"http_port"`
	Version          string `json:"version"`
	// contains filtered or unexported fields
}

type Producer 

type Producer struct {
	// contains filtered or unexported fields
}

func (*Producer) IsTombstoned added in v0.2.17 

func (p *Producer) IsTombstoned(lifetime time.Duration) bool

func (*Producer) String 

func (p *Producer) String() string

func (*Producer) Tombstone added in v0.2.17 

func (p *Producer) Tombstone()

type ProducerMap added in v1.1.0 

type ProducerMap map[string]*Producer

type Producers 

type Producers []*Producer

func ProducerMap2Slice added in v1.1.0 

func ProducerMap2Slice(pm ProducerMap) Producers

func (Producers) FilterByActive added in v0.2.17 

func (pp Producers) FilterByActive(inactivityTimeout time.Duration, tombstoneLifetime time.Duration) Producers

func (Producers) PeerInfo added in v0.2.18 

func (pp Producers) PeerInfo() []*PeerInfo

type Registration 

type Registration struct {
	Category string
	Key      string
	SubKey   string
}

func (Registration) IsMatch 

func (k Registration) IsMatch(category string, key string, subkey string) bool

type RegistrationDB 

type RegistrationDB struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRegistrationDB 

func NewRegistrationDB() *RegistrationDB

func (*RegistrationDB) AddProducer added in v0.2.17 

func (r *RegistrationDB) AddProducer(k Registration, p *Producer) bool

add a producer to a registration

func (*RegistrationDB) AddRegistration added in v0.2.16 

func (r *RegistrationDB) AddRegistration(k Registration)

add a registration key

func (*RegistrationDB) FindProducers 

func (r *RegistrationDB) FindProducers(category string, key string, subkey string) Producers

func (*RegistrationDB) FindRegistrations 

func (r *RegistrationDB) FindRegistrations(category string, key string, subkey string) Registrations

func (*RegistrationDB) LookupRegistrations 

func (r *RegistrationDB) LookupRegistrations(id string) Registrations

func (*RegistrationDB) RemoveProducer added in v0.2.17 

func (r *RegistrationDB) RemoveProducer(k Registration, id string) (bool, int)

remove a producer from a registration

func (*RegistrationDB) RemoveRegistration 

func (r *RegistrationDB) RemoveRegistration(k Registration)

remove a Registration and all it's producers

type Registrations 

type Registrations []Registration

func (Registrations) Filter 

func (rr Registrations) Filter(category string, key string, subkey string) Registrations

func (Registrations) Keys 

func (rr Registrations) Keys() []string

func (Registrations) SubKeys 

func (rr Registrations) SubKeys() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.