nsqadmin

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

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

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()

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

Aug 26, 2013

Changes in this version

type AdminAction

+ Node string

+ type Node string

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

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

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

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

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

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