package diagnostic

import "github.com/dotcloud/docker/libnetwork/diagnostic"

Index ¶

• func DebugHTTPForm(r *http.Request)
• func HTTPReply(w http.ResponseWriter, r *HTTPResult, j *JSONOutput) (int, error)
• type ErrorCmd
• func (e *ErrorCmd) String() string
• type HTTPHandlerFunc
• type HTTPResult
• func CommandSucceed(result StringInterface) *HTTPResult
• func FailCommand(err error) *HTTPResult
• func WrongCommand(message, usage string) *HTTPResult
• func (h *HTTPResult) String() string
• type JSONOutput
• func ParseHTTPFormOptions(r *http.Request) (bool, *JSONOutput)
• type NetworkStatsResult
• func (n *NetworkStatsResult) String() string
• type PeerEntryObj
• func (p *PeerEntryObj) String() string
• type Server
• func New() *Server
• func (s *Server) DisableDiagnostic()
• func (s *Server) EnableDiagnostic(ip string, port int)
• func (s *Server) Init()
• func (s *Server) IsDiagnosticEnabled() bool
• func (s *Server) RegisterHandler(ctx interface{}, hdlrs map[string]HTTPHandlerFunc)
• func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type StringCmd
• func (s *StringCmd) String() string
• type StringInterface
• type TableEndpointsResult
• type TableEntryObj
• func (t *TableEntryObj) String() string
• type TableObj
• func (t *TableObj) String() string
• type TablePeersResult
• type UsageCmd
• func (u *UsageCmd) String() string

Functions ¶

func DebugHTTPForm ¶

func DebugHTTPForm(r *http.Request)

DebugHTTPForm helper to print the form url parameters

func HTTPReply ¶

func HTTPReply(w http.ResponseWriter, r *HTTPResult, j *JSONOutput) (int, error)

HTTPReply helper function that takes care of sending the message out

Types ¶

type ErrorCmd ¶

type ErrorCmd struct {
	Error string `json:"error"`
}

ErrorCmd command with error

func (*ErrorCmd) String ¶

func (e *ErrorCmd) String() string

type HTTPHandlerFunc ¶

type HTTPHandlerFunc func(interface{}, http.ResponseWriter, *http.Request)

HTTPHandlerFunc TODO

type HTTPResult ¶

type HTTPResult struct {
	Message string          `json:"message"`
	Details StringInterface `json:"details"`
}

HTTPResult Diagnostic Server HTTP result operation

func CommandSucceed ¶

func CommandSucceed(result StringInterface) *HTTPResult

CommandSucceed creates a success message

func FailCommand ¶

func FailCommand(err error) *HTTPResult

FailCommand creates a failure message with error

func WrongCommand ¶

func WrongCommand(message, usage string) *HTTPResult

WrongCommand creates a wrong command response

func (*HTTPResult) String ¶

func (h *HTTPResult) String() string

type JSONOutput ¶

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

JSONOutput contains details on JSON output printing

func ParseHTTPFormOptions ¶

func ParseHTTPFormOptions(r *http.Request) (bool, *JSONOutput)

ParseHTTPFormOptions easily parse the JSON printing options

type NetworkStatsResult ¶

type NetworkStatsResult struct {
	Entries  int `json:"entries"`
	QueueLen int `jsoin:"qlen"`
}

NetworkStatsResult network db stats related to entries and queue len for a network

func (*NetworkStatsResult) String ¶

func (n *NetworkStatsResult) String() string

type PeerEntryObj ¶

type PeerEntryObj struct {
	Index int    `json:"-"`
	Name  string `json:"-=name"`
	IP    string `json:"ip"`
}

PeerEntryObj entry in the networkdb peer table

func (*PeerEntryObj) String ¶

func (p *PeerEntryObj) String() string

type Server ¶

type Server struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Server when the debug is enabled exposes a This data structure is protected by the Agent mutex so does not require and additional mutex here

func New ¶

func New() *Server

New creates a new diagnostic server

func (*Server) DisableDiagnostic ¶

func (s *Server) DisableDiagnostic()

DisableDiagnostic stop the dubug and closes the tcp socket

func (*Server) EnableDiagnostic ¶

func (s *Server) EnableDiagnostic(ip string, port int)

EnableDiagnostic opens a TCP socket to debug the passed network DB

func (*Server) Init ¶

func (s *Server) Init()

Init initialize the mux for the http handling and register the base hooks

func (*Server) IsDiagnosticEnabled ¶

func (s *Server) IsDiagnosticEnabled() bool

IsDiagnosticEnabled returns true when the debug is enabled

func (*Server) RegisterHandler ¶

func (s *Server) RegisterHandler(ctx interface{}, hdlrs map[string]HTTPHandlerFunc)

RegisterHandler allows to register new handlers to the mux and to a specific path

func (*Server) ServeHTTP ¶

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP this is the method called bu the ListenAndServe, and is needed to allow us to use our custom mux

type StringCmd ¶

type StringCmd struct {
	Info string `json:"info"`
}

StringCmd command with info string

func (*StringCmd) String ¶

func (s *StringCmd) String() string

type StringInterface ¶

type StringInterface interface {
	String() string
}

StringInterface interface that has to be implemented by messages

type TableEndpointsResult ¶

type TableEndpointsResult struct {
	TableObj
	Elements []TableEntryObj `json:"entries"`
}

TableEndpointsResult fully typed message for proper unmarshaling on the client side

type TableEntryObj ¶

type TableEntryObj struct {
	Index int    `json:"-"`
	Key   string `json:"key"`
	Value string `json:"value"`
	Owner string `json:"owner"`
}

TableEntryObj network db table entry object

func (*TableEntryObj) String ¶

func (t *TableEntryObj) String() string

type TableObj ¶

type TableObj struct {
	Length   int               `json:"size"`
	Elements []StringInterface `json:"entries"`
}

TableObj network db table object

func (*TableObj) String ¶

func (t *TableObj) String() string

type TablePeersResult ¶

type TablePeersResult struct {
	TableObj
	Elements []PeerEntryObj `json:"entries"`
}

TablePeersResult fully typed message for proper unmarshaling on the client side

type UsageCmd ¶

type UsageCmd struct {
	Usage string `json:"usage"`
}

UsageCmd command with usage field

func (*UsageCmd) String ¶

func (u *UsageCmd) String() string

Source Files ¶

server.go types.go