status

package
v0.0.0-...-a13ee55 Latest Latest
Warning

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

 Go to latest Published: May 31, 2015 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package status defines the data types of cluster-wide and per-node status responses.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ProcessNodeEvents 

func ProcessNodeEvents(l NodeEventListener, sub *util.Subscription)

ProcessNodeEvents reads node events from the supplied channel and passes them to the correct methods of the supplied NodeEventListener. This method will run until the Subscription's events channel is closed.

Types

type CallErrorEvent 

type CallErrorEvent struct {
	NodeID proto.NodeID
	Method proto.Method
}

CallErrorEvent is published when a call to a node returns an error.

type CallSuccessEvent 

type CallSuccessEvent struct {
	NodeID proto.NodeID
	Method proto.Method
}

CallSuccessEvent is published when a call to a node completes without error.

type Cluster 

type Cluster struct{}

A Cluster that contains nodes.

type Node 

type Node struct{}

Node represents an individual node within the cluster.

type NodeEventFeed 

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

NodeEventFeed is a helper structure which publishes node-specific events to a util.Feed. If the target feed is nil, event methods become no-ops.

func NewNodeEventFeed 

func NewNodeEventFeed(id proto.NodeID, feed *util.Feed) NodeEventFeed

NewNodeEventFeed creates a new NodeEventFeed which publishes events for a specific node to the supplied feed.

func (NodeEventFeed) CallComplete 

func (nef NodeEventFeed) CallComplete(args proto.Request, reply proto.Response)

CallComplete is called by a node whenever it completes a request. This will publish an appropriate event to the feed based on the results of the call.

type NodeEventListener 

type NodeEventListener interface {
	OnCallSuccess(event *CallSuccessEvent)
	OnCallError(event *CallErrorEvent)
}

NodeEventListener is an interface that can be implemented by objects which listen for events published by nodes.

type NodeList 

type NodeList struct {
	Nodes []NodeSummary `json:"nodes"`
}

NodeList contains a slice of summaries for each Node.

type NodeStatusMonitor 

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

NodeStatusMonitor monitors the status of a server node. Status information is collected from event feeds provided by lower level components.

This structure contains collections of other StatusMonitor types which monitor interesting subsets of data on the node. NodeStatusMonitor is responsible for passing event feed data to these subset structures for accumulation.

func NewNodeStatusMonitor 

func NewNodeStatusMonitor() *NodeStatusMonitor

NewNodeStatusMonitor initializes a new NodeStatusMonitor instance.

func (*NodeStatusMonitor) GetStoreMonitor 

func (nsm *NodeStatusMonitor) GetStoreMonitor(id proto.StoreID) *StoreStatusMonitor

GetStoreMonitor is a helper method which retrieves the StoreStatusMonitor for the given StoreID, creating it if it does not already exist.

func (*NodeStatusMonitor) OnAddRange 

func (nsm *NodeStatusMonitor) OnAddRange(event *storage.AddRangeEvent)

OnAddRange receives AddRangeEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnBeginScanRanges 

func (nsm *NodeStatusMonitor) OnBeginScanRanges(event *storage.BeginScanRangesEvent)

OnBeginScanRanges receives BeginScanRangesEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnCallError 

func (nsm *NodeStatusMonitor) OnCallError(event *CallErrorEvent)

OnCallError receives CallErrorEvents from a node event subscription. This method is part of the implementation of NodeEventListener.

func (*NodeStatusMonitor) OnCallSuccess 

func (nsm *NodeStatusMonitor) OnCallSuccess(event *CallSuccessEvent)

OnCallSuccess receives CallSuccessEvents from a node event subscription. This method is part of the implementation of NodeEventListener.

func (*NodeStatusMonitor) OnEndScanRanges 

func (nsm *NodeStatusMonitor) OnEndScanRanges(event *storage.EndScanRangesEvent)

OnEndScanRanges receives EndScanRangesEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnMergeRange 

func (nsm *NodeStatusMonitor) OnMergeRange(event *storage.MergeRangeEvent)

OnMergeRange receives MergeRangeEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnRemoveRange 

func (nsm *NodeStatusMonitor) OnRemoveRange(event *storage.RemoveRangeEvent)

OnRemoveRange receives RemoveRangeEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnSplitRange 

func (nsm *NodeStatusMonitor) OnSplitRange(event *storage.SplitRangeEvent)

OnSplitRange receives SplitRangeEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnStartStore 

func (nsm *NodeStatusMonitor) OnStartStore(event *storage.StartStoreEvent)

OnStartStore receives StartStoreEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) OnUpdateRange 

func (nsm *NodeStatusMonitor) OnUpdateRange(event *storage.UpdateRangeEvent)

OnUpdateRange receives UpdateRangeEvents retrieved from an storage event subscription. This method is part of the implementation of store.StoreEventListener.

func (*NodeStatusMonitor) SetNodeID 

func (nsm *NodeStatusMonitor) SetNodeID(id proto.NodeID)

SetNodeID sets the NodeID for the node being monitored.

func (*NodeStatusMonitor) StartMonitorFeed 

func (nsm *NodeStatusMonitor) StartMonitorFeed(feed *util.Feed)

StartMonitorFeed starts a goroutine which processes events published to the supplied Subscription. The goroutine will continue running until the Subscription's Events feed is closed.

func (*NodeStatusMonitor) VisitStoreMonitors 

func (nsm *NodeStatusMonitor) VisitStoreMonitors(visitor func(*StoreStatusMonitor))

VisitStoreMonitors calls the supplied visitor function with every StoreStatusMonitor currently in this monitor's collection. A lock is taken on each StoreStatusMonitor before it is passed to the visitor function.

type NodeStatusRecorder 

type NodeStatusRecorder struct {
	*NodeStatusMonitor
	// contains filtered or unexported fields
}

NodeStatusRecorder is used to periodically persist the status of a node as a set of time series data.

func NewNodeStatusRecorder 

func NewNodeStatusRecorder(monitor *NodeStatusMonitor, clock *hlc.Clock) *NodeStatusRecorder

NewNodeStatusRecorder instantiates a recorder for the supplied monitor.

func (*NodeStatusRecorder) GetTimeSeriesData 

func (nsr *NodeStatusRecorder) GetTimeSeriesData() []proto.TimeSeriesData

GetTimeSeriesData returns a slice of interesting TimeSeriesData from the encapsulated NodeStatusMonitor.

type NodeSummary 

type NodeSummary struct {
	ID   string `json:"id"`
	Addr string `json:"addr"`
}

A NodeSummary contains a summary for a particular node.

type StoreStatusMonitor 

type StoreStatusMonitor struct {
	ID proto.StoreID
	// contains filtered or unexported fields
}

StoreStatusMonitor monitors the status of a single store on the server. Status information is collected from event feeds provided by lower level components.

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.