nsqadmin

package
v0.3.3 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2015 License: MIT Imports: 29 Imported by: 0

README

nsqadmin

nsqadmin is a Web UI to view aggregated cluster stats in realtime and perform various administrative tasks.

Read the docs

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHTTPServer added in v0.2.25

func NewHTTPServer(ctx *Context) *httpServer

func NewNSQAdminOptions added in v0.2.25

func NewNSQAdminOptions() *nsqadminOptions

func NewSingleHostReverseProxy added in v0.2.16

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

this is similar to httputil.NewSingleHostReverseProxy except it passes along basic auth

Types

type AdminAction added in v0.2.17

type AdminAction struct {
	Action    string `json:"action"`
	Topic     string `json:"topic"`
	Channel   string `json:"channel,omitempty"`
	Node      string `json:"node,omitempty"`
	Timestamp int64  `json:"timestamp"`
	User      string `json:"user,omitempty"`
	RemoteIP  string `json:"remote_ip"`
	UserAgent string `json:"user_agent"`
}

type Context added in v0.2.25

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

type GraphInterval added in v0.2.16

type GraphInterval struct {
	Selected   bool
	Timeframe  string        // the UI string
	GraphFrom  string        // ?from=.
	GraphUntil string        // ?until=.
	Duration   time.Duration // for sort order
}

func GraphIntervalForTimeframe added in v0.2.16

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

func (*GraphInterval) URLOption added in v0.3.3

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

type GraphIntervals added in v0.2.16

type GraphIntervals []*GraphInterval

func DefaultGraphTimeframes added in v0.2.16

func DefaultGraphTimeframes(selected string) GraphIntervals

type GraphOptions added in v0.2.16

type GraphOptions struct {
	Configured        bool
	Enabled           bool
	GraphiteURL       string
	TimeframeString   template.URL
	AllGraphIntervals []*GraphInterval
	GraphInterval     *GraphInterval
	// contains filtered or unexported fields
}

func NewGraphOptions added in v0.2.16

func NewGraphOptions(rw http.ResponseWriter, req *http.Request,
	r *http_api.ReqParams, ctx *Context) *GraphOptions

func (*GraphOptions) LargeGraph added in v0.2.16

func (g *GraphOptions) LargeGraph(gr GraphTarget, key string) template.URL

func (*GraphOptions) Prefix added in v0.2.16

func (g *GraphOptions) Prefix(host string, metricType string) string

func (*GraphOptions) Rate added in v0.2.20

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

func (*GraphOptions) Sparkline added in v0.2.16

func (g *GraphOptions) Sparkline(gr GraphTarget, key string) template.URL

type GraphTarget added in v0.2.20

type GraphTarget interface {
	Target(key string) ([]string, string)
	Host() string
}

type NSQAdmin added in v0.2.25

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

func NewNSQAdmin added in v0.2.25

func NewNSQAdmin(opts *nsqadminOptions) *NSQAdmin

func (*NSQAdmin) Exit added in v0.2.25

func (n *NSQAdmin) Exit()

func (*NSQAdmin) Main added in v0.2.25

func (n *NSQAdmin) Main()

func (*NSQAdmin) RealHTTPAddr added in v0.3.3

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

type Node added in v0.2.22

type Node string

func (Node) Host added in v0.2.23

func (n Node) Host() string

func (Node) Target added in v0.2.22

func (n Node) Target(key string) ([]string, string)

type Topic added in v0.2.16

type Topic struct {
	TopicName string
}

func (*Topic) Host added in v0.2.23

func (t *Topic) Host() string

func (*Topic) Target added in v0.2.16

func (t *Topic) Target(key string) ([]string, string)

type Topics added in v0.2.16

type Topics []*Topic

func TopicsFromStrings added in v0.2.20

func TopicsFromStrings(s []string) Topics

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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