Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControlHandler ¶
type ControlHandler struct {
// contains filtered or unexported fields
}
ControlHandler is responsible for receiving control messages pushed by the backend service.
func NewControlHandler ¶
func NewControlHandler(s *pubsub.Subscription, st *stats.Tracker, logDir string) *ControlHandler
NewControlHandler creates an instance of ControlHandler.
func (*ControlHandler) Process ¶
func (ch *ControlHandler) Process(ctx context.Context)
Process handles control messages sent by the DCP. This is a blocking function. TODO(b/117972265): This method should detect control messages absence, and act accordingly.
type PulseSender ¶
type PulseSender struct {
// contains filtered or unexported fields
}
PulseSender periodically sends "pulses" on the topic passed in during construction.
func NewPulseSender ¶
func NewPulseSender(ctx context.Context, t pubsubinternal.PSTopic, logsDir string, st *stats.Tracker) *PulseSender
NewPulseSender returns a new PulseSender.
Source Files
Click to show internal directories.
Click to hide internal directories.