Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BoshMetricsServer ¶
type BoshMetricsServer struct {
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer(m chan *definitions.Event, t tokenChecker, opts ...ServerOpt) *BoshMetricsServer
NewServer returns a BoshMetricsServer. It serves bosh metrics via a grpc connections from clients.
func (*BoshMetricsServer) BoshMetrics ¶
func (s *BoshMetricsServer) BoshMetrics(r *definitions.EgressRequest, srv definitions.Egress_BoshMetricsServer) error
BoshMetrics is the grpc handler that serves EgressRequests. It verifies auth tokens from the `authorization` metadata. It returns an error if the auth token is missing or invalid.
func (*BoshMetricsServer) Start ¶
func (s *BoshMetricsServer) Start() func()
Start spins up a new go routine that distributes metrics to each subscription. It returns a shutdown function which blocks until all subscriptions are drained.
Source Files
Click to show internal directories.
Click to hide internal directories.