nsqadmin

package

Go to main page

Versions in this module

v1

v1.1.0

Aug 19, 2018

Changes in this version

+ const LOG_DEBUG

+ const LOG_ERROR

+ const LOG_FATAL

+ const LOG_INFO

+ const LOG_WARN

+ type Logger lg.Logger

type Options

+ AclHttpHeader string

+ AdminUsers []string

+ AllowConfigFromCIDR string

+ HTTPClientConnectTimeout time.Duration

+ HTTPClientRequestTimeout time.Duration

+ LogLevel string

+ LogPrefix string

+ Verbose bool

v1.1.0-rc1

Jul 31, 2018

v1.0.0-compat

Mar 22, 2017

v0

v0.3.8

May 26, 2016

v0.3.7

Feb 24, 2016

Changes in this version

type Options

+ StatsdCounterFormat string

+ StatsdGaugeFormat string

v0.3.6

Sep 24, 2015

Changes in this version

+ func Asset(name string) ([]byte, error)

+ func AssetDir(name string) ([]string, error)

+ func AssetInfo(name string) (os.FileInfo, error)

+ func AssetNames() []string

+ func MustAsset(name string) []byte

+ func RestoreAsset(dir, name string) error

+ func RestoreAssets(dir, name string) error

type AdminAction

+ URL string

+ Via string

type NSQAdmin

+ func New(opts *Options) *NSQAdmin

+ type Options struct

+ GraphiteURL string

+ HTTPAddress string

+ HTTPClientTLSCert string

+ HTTPClientTLSInsecureSkipVerify bool

+ HTTPClientTLSKey string

+ HTTPClientTLSRootCAFile string

+ Logger logger

+ NSQDHTTPAddresses []string

+ NSQLookupdHTTPAddresses []string

+ NotificationHTTPEndpoint string

+ ProxyGraphite bool

+ StatsdInterval time.Duration

+ StatsdPrefix string

+ UseStatsdPrefixes bool

+ func NewOptions() *Options

v0.3.5

Apr 26, 2015

v0.3.4

Apr 26, 2015

v0.3.3

Apr 26, 2015

Changes in this version

type GraphInterval

+ func (g *GraphInterval) URLOption() template.URL

type GraphOptions

+ GraphiteURL string

type NSQAdmin

+ func (n *NSQAdmin) RealHTTPAddr() *net.TCPAddr

v0.3.2

Feb 8, 2015

v0.3.1

Jan 22, 2015

v0.3.0

Nov 18, 2014

v0.2.31

Aug 26, 2014

v0.2.30

Jul 28, 2014

v0.2.29

Jul 25, 2014

v0.2.28

Apr 29, 2014

v0.2.27

Feb 16, 2014

v0.2.26

Feb 7, 2014

v0.2.25

Feb 6, 2014

Changes in this version

+ func NewHTTPServer(context *Context) *httpServer

+ func NewNSQAdminOptions() *nsqadminOptions

+ type Context struct

+ type NSQAdmin struct

+ func NewNSQAdmin(options *nsqadminOptions) *NSQAdmin

+ func (n *NSQAdmin) Exit()

+ func (n *NSQAdmin) Main()

v0.2.24

Dec 7, 2013

v0.2.23

Oct 23, 2013

Changes in this version

type GraphOptions

+ StatsdPrefix string

type GraphTarget

+ Host func() string

type Node

+ func (n Node) Host() string

type Topic

+ func (t *Topic) Host() string

v0.2.22

Aug 26, 2013

Changes in this version

type AdminAction

+ Node string

+ type Node string

+ func (n Node) Target(key string) (string, string)

v0.2.21

Jun 9, 2013

v0.2.20

May 13, 2013

Changes in this version

type GraphOptions

+ func (g *GraphOptions) Rate(gr GraphTarget) string

+ type GraphTarget interface

+ Target func(key string) (string, string)

type Topics

+ func TopicsFromStrings(s []string) Topics

v0.2.19

Apr 12, 2013

v0.2.18

Feb 28, 2013

Changes in this version

+ func GraphiteGet(request_url string) ([]byte, error)

type ChannelStats

+ func (t *ChannelStats) Rate(g *GraphOptions) string

type Topic

+ func (t *Topic) Rate(g *GraphOptions) string

type TopicHostStats

+ func (t *TopicHostStats) Rate(g *GraphOptions) string

v0.2.17

Feb 8, 2013

Changes in this version

+ func HandleAdminActions()

+ func NotifyAdminAction(actionType string, topicName string, channelName string, req *http.Request)

+ type AdminAction struct

+ Action string

+ Channel string

+ RemoteIP string

+ Timestamp int64

+ Topic string

+ User string

+ UserAgent string

type Producer

+ BroadcastAddress string

+ Hostname string

v0.2.16

Jan 7, 2013

Changes in this version

+ func NewSingleHostReverseProxy(target *url.URL, timeout time.Duration) *httputil.ReverseProxy

type ChannelStats

+ func (c *ChannelStats) LargeGraph(g *GraphOptions, key string) template.URL

+ func (c *ChannelStats) Sparkline(g *GraphOptions, key string) template.URL

+ func (c *ChannelStats) Target(g *GraphOptions, key string) (string, string)

+ type GraphInterval struct

+ Duration time.Duration

+ GraphFrom string

+ GraphUntil string

+ Selected bool

+ Timeframe string

+ func GraphIntervalForTimeframe(t string, selected bool) (*GraphInterval, error)

+ func (g *GraphInterval) UrlOption() template.URL

+ type GraphIntervals []*GraphInterval

+ func DefaultGraphTimeframes(selected string) GraphIntervals

+ type GraphOptions struct

+ AllGraphIntervals []*GraphInterval

+ Configured bool

+ Enabled bool

+ GraphInterval *GraphInterval

+ GraphiteUrl string

+ TimeframeString template.URL

+ UseStatsdPrefix bool

+ func NewGraphOptions(rw http.ResponseWriter, req *http.Request, r *util.ReqParams) *GraphOptions

+ func (g *GraphOptions) LargeGraph(target string, color string) template.URL

+ func (g *GraphOptions) Prefix() string

+ func (g *GraphOptions) Sparkline(target string, color string) template.URL

+ type Topic struct

+ TopicName string

+ func (t *Topic) LargeGraph(g *GraphOptions, key string) template.URL

+ func (t *Topic) Sparkline(g *GraphOptions, key string) template.URL

+ func (t *Topic) Target(g *GraphOptions, key string) (string, string)

type TopicHostStats

+ Aggregate bool

+ func (t *TopicHostStats) LargeGraph(g *GraphOptions, key string) template.URL

+ func (t *TopicHostStats) Sparkline(g *GraphOptions, key string) template.URL

+ func (t *TopicHostStats) Target(g *GraphOptions, key string) (string, string)

+ type Topics []*Topic

+ func TopicsForStrings(s []string) Topics

v0.2.15

Oct 25, 2012

Changes in this version

+ type ChannelStats struct

+ BackendDepth int64

+ ChannelName string

+ ClientCount int

+ Clients []*ClientInfo

+ DeferredCount int64

+ Depth int64

+ HostAddress string

+ HostStats []*ChannelStats

+ InFlightCount int64

+ MemoryDepth int64

+ MessageCount int64

+ Paused bool

+ RequeueCount int64

+ Selected bool

+ TimeoutCount int64

+ Topic string

+ func (c *ChannelStats) AddHostStats(a *ChannelStats)

+ type ChannelStatsByHost struct

+ func (c ChannelStatsByHost) Less(i, j int) bool

+ type ChannelStatsList []*ChannelStats

+ func (c ChannelStatsList) Len() int

+ func (c ChannelStatsList) Swap(i, j int)

+ type ClientInfo struct

+ ClientIdentifier string

+ ClientVersion string

+ ConnectedDuration time.Duration

+ FinishCount int64

+ HostAddress string

+ InFlightCount int

+ MessageCount int64

+ ReadyCount int

+ RequeueCount int64

+ type ClientInfos []*ClientInfo

+ func (c ClientInfos) Len() int

+ func (c ClientInfos) Swap(i, j int)

+ type ClientsByHost struct

+ func (c ClientsByHost) Less(i, j int) bool

+ type Producer struct

+ Address string

+ HttpPort int

+ OutOfDate bool

+ TcpPort int

+ Topics []string

+ Version string

+ VersionObj *Version

+ func (p *Producer) HTTPAddress() string

+ type ProducerList []*Producer

+ func (t ProducerList) Len() int

+ func (t ProducerList) Swap(i, j int)

+ type ProducersByHost struct

+ func (c ProducersByHost) Less(i, j int) bool

+ type TopicHostStats struct

+ BackendDepth int64

+ ChannelCount int

+ Depth int64

+ HostAddress string

+ MemoryDepth int64

+ MessageCount int64

+ Topic string

+ func (t *TopicHostStats) AddHostStats(a *TopicHostStats)

+ type TopicHostStatsByHost struct

+ func (c TopicHostStatsByHost) Less(i, j int) bool

+ type TopicHostStatsList []*TopicHostStats

+ func (t TopicHostStatsList) Len() int

+ func (t TopicHostStatsList) Swap(i, j int)

+ type Version struct

+ func NewVersion(v string) *Version

+ func (v *Version) Less(vv *Version) bool

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