nsqadmin

package
v0.0.0-...-38a8d4c Latest Latest
Warning

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

Go to latest
Published: Feb 16, 2024 License: GPL-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Copyright © 2024 Aaron Johnson <acjohnson@pcdomain.com>

This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NsqAdminCall

func NsqAdminCall(nsqadminAddr string, httpHeaders string, payload []byte, url string, method string) (string, error)

Types

type NsqNode

type NsqNode struct {
	Hostname         string   `json:"hostname"`
	BroadcastAddress string   `json:"broadcast_address"`
	TcpPort          int      `json:"tcp_port"`
	Version          string   `json:"version"`
	RemoteAddresses  []string `json:"remote_addresses"`
}

type NsqNodeResponse

type NsqNodeResponse struct {
	Nodes []NsqNode `json:"nodes"`
}

func GetNsqNodes

func GetNsqNodes(nsqadminAddr string, httpHeaders string) (NsqNodeResponse, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL