client

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2024 License: Apache-2.0 Imports: 11 Imported by: 10

Documentation

Index

Constants

View Source 
const (
	// APIVersion is the default version of NGINX Plus API supported by the client.
	APIVersion = 9
)

Variables

View Source 
var (
	ErrParameterRequired = errors.New("parameter is required")
	ErrServerNotFound    = errors.New("server not found")
	ErrServerExists      = errors.New("server already exists")
	ErrNotSupported      = errors.New("not supported")
	ErrInvalidTimeout    = errors.New("invalid timeout")
)

Functions

This section is empty.

Types

type CacheStats added in v0.9.0 

type CacheStats struct {
	Responses uint64
	Bytes     uint64
}

CacheStats are basic cache stats.

type Caches added in v0.9.0 

type Caches = map[string]HTTPCache

Caches is a map of cache stats by cache zone.

type Connections 

type Connections struct {
	Accepted uint64
	Dropped  uint64
	Active   uint64
	Idle     uint64
}

Connections represents connection related stats.

type ExtendedCacheStats added in v0.9.0 

type ExtendedCacheStats struct {
	CacheStats
	ResponsesWritten uint64 `json:"responses_written"`
	BytesWritten     uint64 `json:"bytes_written"`
}

ExtendedCacheStats are extended cache stats.

type HTTPCache added in v0.9.0 

type HTTPCache struct {
	Size        uint64
	MaxSize     uint64 `json:"max_size"`
	Cold        bool
	Hit         CacheStats
	Stale       CacheStats
	Updating    CacheStats
	Revalidated CacheStats
	Miss        CacheStats
	Expired     ExtendedCacheStats
	Bypass      ExtendedCacheStats
}

HTTPCache represents a zone's HTTP Cache.

type HTTPCodes added in v0.10.0 

type HTTPCodes struct {
	HTTPContinue              uint64 `json:"100,omitempty"`
	HTTPSwitchingProtocols    uint64 `json:"101,omitempty"`
	HTTPProcessing            uint64 `json:"102,omitempty"`
	HTTPOk                    uint64 `json:"200,omitempty"`
	HTTPCreated               uint64 `json:"201,omitempty"`
	HTTPAccepted              uint64 `json:"202,omitempty"`
	HTTPNoContent             uint64 `json:"204,omitempty"`
	HTTPPartialContent        uint64 `json:"206,omitempty"`
	HTTPSpecialResponse       uint64 `json:"300,omitempty"`
	HTTPMovedPermanently      uint64 `json:"301,omitempty"`
	HTTPMovedTemporarily      uint64 `json:"302,omitempty"`
	HTTPSeeOther              uint64 `json:"303,omitempty"`
	HTTPNotModified           uint64 `json:"304,omitempty"`
	HTTPTemporaryRedirect     uint64 `json:"307,omitempty"`
	HTTPBadRequest            uint64 `json:"400,omitempty"`
	HTTPUnauthorized          uint64 `json:"401,omitempty"`
	HTTPForbidden             uint64 `json:"403,omitempty"`
	HTTPNotFound              uint64 `json:"404,omitempty"`
	HTTPNotAllowed            uint64 `json:"405,omitempty"`
	HTTPRequestTimeOut        uint64 `json:"408,omitempty"`
	HTTPConflict              uint64 `json:"409,omitempty"`
	HTTPLengthRequired        uint64 `json:"411,omitempty"`
	HTTPPreconditionFailed    uint64 `json:"412,omitempty"`
	HTTPRequestEntityTooLarge uint64 `json:"413,omitempty"`
	HTTPRequestURITooLarge    uint64 `json:"414,omitempty"`
	HTTPUnsupportedMediaType  uint64 `json:"415,omitempty"`
	HTTPRangeNotSatisfiable   uint64 `json:"416,omitempty"`
	HTTPTooManyRequests       uint64 `json:"429,omitempty"`
	HTTPClose                 uint64 `json:"444,omitempty"`
	HTTPRequestHeaderTooLarge uint64 `json:"494,omitempty"`
	HTTPSCertError            uint64 `json:"495,omitempty"`
	HTTPSNoCert               uint64 `json:"496,omitempty"`
	HTTPToHTTPS               uint64 `json:"497,omitempty"`
	HTTPClientClosedRequest   uint64 `json:"499,omitempty"`
	HTTPInternalServerError   uint64 `json:"500,omitempty"`
	HTTPNotImplemented        uint64 `json:"501,omitempty"`
	HTTPBadGateway            uint64 `json:"502,omitempty"`
	HTTPServiceUnavailable    uint64 `json:"503,omitempty"`
	HTTPGatewayTimeOut        uint64 `json:"504,omitempty"`
	HTTPInsufficientStorage   uint64 `json:"507,omitempty"`
}

HTTPCodes represents HTTP response codes.

type HTTPLimitConnections added in v0.10.0 

type HTTPLimitConnections map[string]LimitConnection

HTTPLimitConnections represents limit connections related stats.

type HTTPLimitRequest added in v0.10.0 

type HTTPLimitRequest struct {
	Passed         uint64
	Delayed        uint64
	Rejected       uint64
	DelayedDryRun  uint64 `json:"delayed_dry_run"`
	RejectedDryRun uint64 `json:"rejected_dry_run"`
}

HTTPLimitRequest represents HTTP Requests Rate Limiting.

type HTTPLimitRequests added in v0.10.0 

type HTTPLimitRequests map[string]HTTPLimitRequest

HTTPLimitRequests represents limit requests related stats.

type HTTPRequests 

type HTTPRequests struct {
	Total   uint64
	Current uint64
}

HTTPRequests represents HTTP request related stats.

type HealthChecks 

type HealthChecks struct {
	Checks     uint64
	Fails      uint64
	Unhealthy  uint64
	LastPassed bool `json:"last_passed"`
}

HealthChecks represents health check related stats for a peer.

type KeyValPairs 

type KeyValPairs map[string]string

KeyValPairs are the key-value pairs stored in a zone.

type KeyValPairsByZone 

type KeyValPairsByZone map[string]KeyValPairs

KeyValPairsByZone are the KeyValPairs for all zones, by zone name.

type LimitConnection added in v0.10.0 

type LimitConnection struct {
	Passed         uint64
	Rejected       uint64
	RejectedDryRun uint64 `json:"rejected_dry_run"`
}

LimitConnection represents Connections Limiting.

type LocationZone added in v0.5.0 

type LocationZone struct {
	Requests  int64
	Responses Responses
	Discarded int64
	Received  int64
	Sent      int64
}

LocationZone represents location_zones related stats.

type LocationZones added in v0.5.0 

type LocationZones map[string]LocationZone

LocationZones represents location_zones related stats.

type NginxClient 

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

NginxClient lets you access NGINX Plus API.

func NewNginxClient 

func NewNginxClient(apiEndpoint string, opts ...Option) (*NginxClient, error)

NewNginxClient creates a new NginxClient.

func (*NginxClient) AddHTTPServer 

func (client *NginxClient) AddHTTPServer(upstream string, server UpstreamServer) error

AddHTTPServer adds the server to the upstream.

func (*NginxClient) AddKeyValPair 

func (client *NginxClient) AddKeyValPair(zone string, key string, val string) error

AddKeyValPair adds a new key/value pair to a given HTTP zone.

func (*NginxClient) AddStreamKeyValPair 

func (client *NginxClient) AddStreamKeyValPair(zone string, key string, val string) error

AddStreamKeyValPair adds a new key/value pair to a given Stream zone.

func (*NginxClient) AddStreamServer 

func (client *NginxClient) AddStreamServer(upstream string, server StreamUpstreamServer) error

AddStreamServer adds the stream server to the upstream.

func (*NginxClient) CheckIfStreamUpstreamExists 

func (client *NginxClient) CheckIfStreamUpstreamExists(upstream string) error

CheckIfStreamUpstreamExists checks if the stream upstream exists in NGINX. If the upstream doesn't exist, it returns the error.

func (*NginxClient) CheckIfUpstreamExists 

func (client *NginxClient) CheckIfUpstreamExists(upstream string) error

CheckIfUpstreamExists checks if the upstream exists in NGINX. If the upstream doesn't exist, it returns the error.

func (*NginxClient) DeleteHTTPServer 

func (client *NginxClient) DeleteHTTPServer(upstream string, server string) error

DeleteHTTPServer the server from the upstream.

func (*NginxClient) DeleteKeyValPairs 

func (client *NginxClient) DeleteKeyValPairs(zone string) error

DeleteKeyValPairs deletes all the key-value pairs in a given HTTP zone.

func (*NginxClient) DeleteKeyValuePair 

func (client *NginxClient) DeleteKeyValuePair(zone string, key string) error

DeleteKeyValuePair deletes the key/value pair for a key in a given HTTP zone.

func (*NginxClient) DeleteStreamKeyValPairs 

func (client *NginxClient) DeleteStreamKeyValPairs(zone string) error

DeleteStreamKeyValPairs deletes all the key-value pairs in a given Stream zone.

func (*NginxClient) DeleteStreamKeyValuePair 

func (client *NginxClient) DeleteStreamKeyValuePair(zone string, key string) error

DeleteStreamKeyValuePair deletes the key/value pair for a key in a given Stream zone.

func (*NginxClient) DeleteStreamServer 

func (client *NginxClient) DeleteStreamServer(upstream string, server string) error

DeleteStreamServer the server from the upstream.

func (*NginxClient) GetAllKeyValPairs 

func (client *NginxClient) GetAllKeyValPairs() (KeyValPairsByZone, error)

GetAllKeyValPairs fetches all key/value pairs for all HTTP zones.

func (*NginxClient) GetAllStreamKeyValPairs 

func (client *NginxClient) GetAllStreamKeyValPairs() (KeyValPairsByZone, error)

GetAllStreamKeyValPairs fetches all key/value pairs for all Stream zones.

func (*NginxClient) GetAvailableEndpoints added in v1.1.0 

func (client *NginxClient) GetAvailableEndpoints() ([]string, error)

GetAvailableEndpoints returns available endpoints in the API.

func (*NginxClient) GetAvailableStreamEndpoints added in v1.1.0 

func (client *NginxClient) GetAvailableStreamEndpoints() ([]string, error)

GetAvailableStreamEndpoints returns available stream endpoints in the API.

func (*NginxClient) GetCaches added in v0.9.0 

func (client *NginxClient) GetCaches() (*Caches, error)

GetCaches returns Cache stats.

func (*NginxClient) GetConnections added in v0.7.0 

func (client *NginxClient) GetConnections() (*Connections, error)

GetConnections returns Connections stats.

func (*NginxClient) GetHTTPConnectionsLimit added in v0.10.0 

func (client *NginxClient) GetHTTPConnectionsLimit() (*HTTPLimitConnections, error)

GetHTTPConnectionsLimit returns http/limit_conns stats.

func (*NginxClient) GetHTTPLimitReqs added in v0.10.0 

func (client *NginxClient) GetHTTPLimitReqs() (*HTTPLimitRequests, error)

GetHTTPLimitReqs returns http/limit_reqs stats.

func (*NginxClient) GetHTTPRequests added in v0.7.0 

func (client *NginxClient) GetHTTPRequests() (*HTTPRequests, error)

GetHTTPRequests returns http/requests stats.

func (*NginxClient) GetHTTPServers 

func (client *NginxClient) GetHTTPServers(upstream string) ([]UpstreamServer, error)

GetHTTPServers returns the servers of the upstream from NGINX.

func (*NginxClient) GetKeyValPairs 

func (client *NginxClient) GetKeyValPairs(zone string) (KeyValPairs, error)

GetKeyValPairs fetches key/value pairs for a given HTTP zone.

func (*NginxClient) GetLocationZones added in v0.7.0 

func (client *NginxClient) GetLocationZones() (*LocationZones, error)

GetLocationZones returns http/location_zones stats.

func (*NginxClient) GetMaxAPIVersion added in v1.3.0 

func (client *NginxClient) GetMaxAPIVersion() (int, error)

GetMaxAPIVersion returns the maximum API version supported by the server and the client.

func (*NginxClient) GetNginxInfo added in v0.7.0 

func (client *NginxClient) GetNginxInfo() (*NginxInfo, error)

GetNginxInfo returns Nginx stats.

func (*NginxClient) GetProcesses added in v0.7.0 

func (client *NginxClient) GetProcesses() (*Processes, error)

GetProcesses returns Processes stats.

func (*NginxClient) GetResolvers added in v0.7.0 

func (client *NginxClient) GetResolvers() (*Resolvers, error)

GetResolvers returns Resolvers stats.

func (*NginxClient) GetSSL added in v0.7.0 

func (client *NginxClient) GetSSL() (*SSL, error)

GetSSL returns SSL stats.

func (*NginxClient) GetServerZones added in v0.7.0 

func (client *NginxClient) GetServerZones() (*ServerZones, error)

GetServerZones returns http/server_zones stats.

func (*NginxClient) GetSlabs added in v0.7.0 

func (client *NginxClient) GetSlabs() (*Slabs, error)

GetSlabs returns Slabs stats.

func (*NginxClient) GetStats 

func (client *NginxClient) GetStats() (*Stats, error)

GetStats gets process, slab, connection, request, ssl, zone, stream zone, upstream and stream upstream related stats from the NGINX Plus API.

func (*NginxClient) GetStreamConnectionsLimit added in v0.10.0 

func (client *NginxClient) GetStreamConnectionsLimit() (*StreamLimitConnections, error)

GetStreamConnectionsLimit returns stream/limit_conns stats.

func (*NginxClient) GetStreamKeyValPairs 

func (client *NginxClient) GetStreamKeyValPairs(zone string) (KeyValPairs, error)

GetStreamKeyValPairs fetches key/value pairs for a given Stream zone.

func (*NginxClient) GetStreamServerZones added in v0.7.0 

func (client *NginxClient) GetStreamServerZones() (*StreamServerZones, error)

GetStreamServerZones returns stream/server_zones stats.

func (*NginxClient) GetStreamServers 

func (client *NginxClient) GetStreamServers(upstream string) ([]StreamUpstreamServer, error)

GetStreamServers returns the stream servers of the upstream from NGINX.

func (*NginxClient) GetStreamUpstreams added in v0.7.0 

func (client *NginxClient) GetStreamUpstreams() (*StreamUpstreams, error)

GetStreamUpstreams returns stream/upstreams stats.

func (*NginxClient) GetStreamZoneSync added in v0.7.0 

func (client *NginxClient) GetStreamZoneSync() (*StreamZoneSync, error)

GetStreamZoneSync returns stream/zone_sync stats.

func (*NginxClient) GetUpstreams added in v0.7.0 

func (client *NginxClient) GetUpstreams() (*Upstreams, error)

GetUpstreams returns http/upstreams stats.

func (*NginxClient) GetWorkers added in v0.11.0 

func (client *NginxClient) GetWorkers() ([]*Workers, error)

GetWorkers returns workers stats.

func (*NginxClient) ModifyKeyValPair 

func (client *NginxClient) ModifyKeyValPair(zone string, key string, val string) error

ModifyKeyValPair modifies the value of an existing key in a given HTTP zone.

func (*NginxClient) ModifyStreamKeyValPair 

func (client *NginxClient) ModifyStreamKeyValPair(zone string, key string, val string) error

ModifyStreamKeyValPair modifies the value of an existing key in a given Stream zone.

func (*NginxClient) UpdateHTTPServer added in v0.6.0 

func (client *NginxClient) UpdateHTTPServer(upstream string, server UpstreamServer) error

UpdateHTTPServer updates the server of the upstream.

func (*NginxClient) UpdateHTTPServers 

func (client *NginxClient) UpdateHTTPServers(upstream string, servers []UpstreamServer) (added []UpstreamServer, deleted []UpstreamServer, updated []UpstreamServer, err error)

UpdateHTTPServers updates the servers of the upstream. Servers that are in the slice, but don't exist in NGINX will be added to NGINX. Servers that aren't in the slice, but exist in NGINX, will be removed from NGINX. Servers that are in the slice and exist in NGINX, but have different parameters, will be updated.

func (*NginxClient) UpdateStreamServer added in v0.6.0 

func (client *NginxClient) UpdateStreamServer(upstream string, server StreamUpstreamServer) error

UpdateStreamServer updates the stream server of the upstream.

func (*NginxClient) UpdateStreamServers 

func (client *NginxClient) UpdateStreamServers(upstream string, servers []StreamUpstreamServer) (added []StreamUpstreamServer, deleted []StreamUpstreamServer, updated []StreamUpstreamServer, err error)

UpdateStreamServers updates the servers of the upstream. Servers that are in the slice, but don't exist in NGINX will be added to NGINX. Servers that aren't in the slice, but exist in NGINX, will be removed from NGINX. Servers that are in the slice and exist in NGINX, but have different parameters, will be updated.

func (*NginxClient) Version added in v0.8.0 

func (client *NginxClient) Version() int

Version returns client's current N+ API version.

type NginxInfo 

type NginxInfo struct {
	Version         string
	Build           string
	Address         string
	LoadTimestamp   string `json:"load_timestamp"`
	Timestamp       string
	Generation      uint64
	ProcessID       uint64 `json:"pid"`
	ParentProcessID uint64 `json:"ppid"`
}

NginxInfo contains general information about NGINX Plus.

type Option added in v1.0.0 

type Option func(*NginxClient)

func WithAPIVersion added in v1.0.0 

func WithAPIVersion(apiVersion int) Option

WithAPIVersion sets the API version to use for accessing the API.

func WithCheckAPI added in v1.0.0 

func WithCheckAPI() Option

WithCheckAPI sets the flag to check the API version of the server.

func WithHTTPClient added in v1.0.0 

func WithHTTPClient(httpClient *http.Client) Option

WithHTTPClient sets the HTTP client to use for accessing the API.

func WithTimeout added in v1.3.0 

func WithTimeout(duration time.Duration) Option

WithTimeout sets the timeout per request for the client.

type Pages added in v0.7.0 

type Pages struct {
	Used uint64
	Free uint64
}

Pages represents the slab memory usage stats.

type Peer 

type Peer struct {
	Server       string
	Service      string
	Name         string
	Selected     string
	Downstart    string
	State        string
	Responses    Responses
	SSL          SSL
	HealthChecks HealthChecks `json:"health_checks"`
	Requests     uint64
	ID           int
	MaxConns     int `json:"max_conns"`
	Sent         uint64
	Received     uint64
	Fails        uint64
	Unavail      uint64
	Active       uint64
	Downtime     uint64
	Weight       int
	HeaderTime   uint64 `json:"header_time"`
	ResponseTime uint64 `json:"response_time"`
	Backup       bool
}

Peer represents peer (upstream server) related stats.

type Processes added in v0.7.0 

type Processes struct {
	Respawned int64
}

Processes represents processes related stats.

type Queue 

type Queue struct {
	Size      int
	MaxSize   int `json:"max_size"`
	Overflows uint64
}

Queue represents queue related stats for an upstream.

type Resolver added in v0.5.0 

type Resolver struct {
	Requests  ResolverRequests  `json:"requests"`
	Responses ResolverResponses `json:"responses"`
}

Resolver represents resolvers related stats.

type ResolverRequests added in v0.5.0 

type ResolverRequests struct {
	Name int64
	Srv  int64
	Addr int64
}

ResolverRequests represents resolver requests.

type ResolverResponses added in v0.5.0 

type ResolverResponses struct {
	Noerror  int64
	Formerr  int64
	Servfail int64
	Nxdomain int64
	Notimp   int64
	Refused  int64
	Timedout int64
	Unknown  int64
}

ResolverResponses represents resolver responses.

type Resolvers added in v0.5.0 

type Resolvers map[string]Resolver

Resolvers represents resolvers related stats.

type Responses 

type Responses struct {
	Codes        HTTPCodes
	Responses1xx uint64 `json:"1xx"`
	Responses2xx uint64 `json:"2xx"`
	Responses3xx uint64 `json:"3xx"`
	Responses4xx uint64 `json:"4xx"`
	Responses5xx uint64 `json:"5xx"`
	Total        uint64
}

Responses represents HTTP response related stats.

type SSL 

type SSL struct {
	Handshakes       uint64
	HandshakesFailed uint64         `json:"handshakes_failed"`
	SessionReuses    uint64         `json:"session_reuses"`
	NoCommonProtocol uint64         `json:"no_common_protocol"`
	NoCommonCipher   uint64         `json:"no_common_cipher"`
	HandshakeTimeout uint64         `json:"handshake_timeout"`
	PeerRejectedCert uint64         `json:"peer_rejected_cert"`
	VerifyFailures   VerifyFailures `json:"verify_failures"`
}

SSL represents SSL related stats.

type ServerZone 

type ServerZone struct {
	Processing uint64
	Requests   uint64
	Responses  Responses
	Discarded  uint64
	Received   uint64
	Sent       uint64
	SSL        SSL
}

ServerZone represents server zone related stats.

type ServerZones 

type ServerZones map[string]ServerZone

ServerZones is map of server zone stats by zone name.

type Sessions 

type Sessions struct {
	Sessions2xx uint64 `json:"2xx"`
	Sessions4xx uint64 `json:"4xx"`
	Sessions5xx uint64 `json:"5xx"`
	Total       uint64
}

Sessions represents stream session related stats.

type Slab added in v0.7.0 

type Slab struct {
	Slots Slots
	Pages Pages
}

Slab represents slab related stats.

type Slabs added in v0.7.0 

type Slabs map[string]Slab

Slabs is map of slab stats by zone name.

type Slot added in v0.7.0 

type Slot struct {
	Used  uint64
	Free  uint64
	Reqs  uint64
	Fails uint64
}

Slot represents slot related stats.

type Slots added in v0.7.0 

type Slots map[string]Slot

Slots is a map of slots by slot size.

type Stats 

type Stats struct {
	Upstreams              Upstreams
	ServerZones            ServerZones
	StreamServerZones      StreamServerZones
	StreamUpstreams        StreamUpstreams
	Slabs                  Slabs
	Caches                 Caches
	HTTPLimitConnections   HTTPLimitConnections
	StreamLimitConnections StreamLimitConnections
	HTTPLimitRequests      HTTPLimitRequests
	Resolvers              Resolvers
	LocationZones          LocationZones
	StreamZoneSync         *StreamZoneSync
	Workers                []*Workers
	NginxInfo              NginxInfo
	SSL                    SSL
	Connections            Connections
	HTTPRequests           HTTPRequests
	Processes              Processes
}

Stats represents NGINX Plus stats fetched from the NGINX Plus API. https://nginx.org/en/docs/http/ngx_http_api_module.html

type StreamLimitConnections added in v0.10.0 

type StreamLimitConnections map[string]LimitConnection

StreamLimitConnections represents limit connections related stats.

type StreamPeer 

type StreamPeer struct {
	Server        string
	Service       string
	Name          string
	Selected      string
	Downstart     string
	State         string
	SSL           SSL
	HealthChecks  HealthChecks `json:"health_checks"`
	Connections   uint64
	Received      uint64
	ID            int
	ConnectTime   int    `json:"connect_time"`
	FirstByteTime int    `json:"first_byte_time"`
	ResponseTime  uint64 `json:"response_time"`
	Sent          uint64
	MaxConns      int `json:"max_conns"`
	Fails         uint64
	Unavail       uint64
	Active        uint64
	Downtime      uint64
	Weight        int
	Backup        bool
}

StreamPeer represents peer (stream upstream server) related stats.

type StreamServerZone 

type StreamServerZone struct {
	Processing  uint64
	Connections uint64
	Sessions    Sessions
	Discarded   uint64
	Received    uint64
	Sent        uint64
	SSL         SSL
}

StreamServerZone represents stream server zone related stats.

type StreamServerZones 

type StreamServerZones map[string]StreamServerZone

StreamServerZones is map of stream server zone stats by zone name.

type StreamUpstream 

type StreamUpstream struct {
	Zone    string
	Peers   []StreamPeer
	Zombies int
}

StreamUpstream represents stream upstream related stats.

type StreamUpstreamServer 

type StreamUpstreamServer struct {
	MaxConns    *int   `json:"max_conns,omitempty"`
	MaxFails    *int   `json:"max_fails,omitempty"`
	Backup      *bool  `json:"backup,omitempty"`
	Down        *bool  `json:"down,omitempty"`
	Weight      *int   `json:"weight,omitempty"`
	Server      string `json:"server"`
	FailTimeout string `json:"fail_timeout,omitempty"`
	SlowStart   string `json:"slow_start,omitempty"`
	Service     string `json:"service,omitempty"`
	ID          int    `json:"id,omitempty"`
}

StreamUpstreamServer lets you configure Stream upstreams.

type StreamUpstreams 

type StreamUpstreams map[string]StreamUpstream

StreamUpstreams is a map of stream upstream stats by upstream name.

type StreamZoneSync 

type StreamZoneSync struct {
	Zones  map[string]SyncZone
	Status StreamZoneSyncStatus
}

StreamZoneSync represents the sync information per each shared memory zone and the sync information per node in a cluster.

type StreamZoneSyncStatus 

type StreamZoneSyncStatus struct {
	BytesIn     uint64 `json:"bytes_in"`
	MsgsIn      uint64 `json:"msgs_in"`
	MsgsOut     uint64 `json:"msgs_out"`
	BytesOut    uint64 `json:"bytes_out"`
	NodesOnline uint64 `json:"nodes_online"`
}

StreamZoneSyncStatus represents the status of a shared memory zone.

type SyncZone 

type SyncZone struct {
	RecordsPending uint64 `json:"records_pending"`
	RecordsTotal   uint64 `json:"records_total"`
}

SyncZone represents the synchronization status of a shared memory zone.

type Upstream 

type Upstream struct {
	Zone      string
	Peers     []Peer
	Queue     Queue
	Keepalive int
	Zombies   int
}

Upstream represents upstream related stats.

type UpstreamServer 

type UpstreamServer struct {
	MaxConns    *int   `json:"max_conns,omitempty"`
	MaxFails    *int   `json:"max_fails,omitempty"`
	Backup      *bool  `json:"backup,omitempty"`
	Down        *bool  `json:"down,omitempty"`
	Weight      *int   `json:"weight,omitempty"`
	Server      string `json:"server"`
	FailTimeout string `json:"fail_timeout,omitempty"`
	SlowStart   string `json:"slow_start,omitempty"`
	Route       string `json:"route,omitempty"`
	Service     string `json:"service,omitempty"`
	ID          int    `json:"id,omitempty"`
	Drain       bool   `json:"drain,omitempty"`
}

UpstreamServer lets you configure HTTP upstreams.

type Upstreams 

type Upstreams map[string]Upstream

Upstreams is a map of upstream stats by upstream name.

type VerifyFailures added in v1.2.0 

type VerifyFailures struct {
	NoCert           uint64 `json:"no_cert"`
	ExpiredCert      uint64 `json:"expired_cert"`
	RevokedCert      uint64 `json:"revoked_cert"`
	HostnameMismatch uint64 `json:"hostname_mismatch"`
	Other            uint64 `json:"other"`
}

type Workers added in v0.11.0 

type Workers struct {
	ID          int
	ProcessID   uint64      `json:"pid"`
	HTTP        WorkersHTTP `json:"http"`
	Connections Connections
}

Workers represents worker connections related stats.

type WorkersHTTP added in v0.11.0 

type WorkersHTTP struct {
	HTTPRequests HTTPRequests `json:"requests"`
}

WorkersHTTP represents HTTP worker connections.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.