google-cloud-debugger - Class Google::Cloud::Debugger::Transmitter (v0.42.2)
Stay organized with collections
Save and categorize content based on your preferences.
Reference documentation and code samples for the google-cloud-debugger class Google::Cloud::Debugger::Transmitter.
Transmitter
Responsible for submit evaluated breakpoints back to Stackdriver
Debugger service asynchronously. It maintains a thread pool.
The transmitter is controlled by the debugger agent it belongs to.
Debugger agent submits evaluated breakpoint asynchronously, and the
transmitter submits the breakpoints to Stackdriver Debugger service.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-28 UTC."],[],[],null,["# google-cloud-debugger - Class Google::Cloud::Debugger::Transmitter (v0.42.2)\n\nReference documentation and code samples for the google-cloud-debugger class Google::Cloud::Debugger::Transmitter.\n\nTransmitter\n-----------\n\nResponsible for submit evaluated breakpoints back to Stackdriver\nDebugger service asynchronously. It maintains a thread pool.\n\nThe transmitter is controlled by the debugger agent it belongs to.\nDebugger agent submits evaluated breakpoint asynchronously, and the\ntransmitter submits the breakpoints to Stackdriver Debugger service. \n\nInherits\n--------\n\n- Object\n\nMethods\n-------\n\n### #agent\n\n def agent() -\u003e Google::Cloud::Debugger::Agent\n\nThe debugger agent this transmiter belongs to \n**Returns**\n\n- ([Google::Cloud::Debugger::Agent](./Google-Cloud-Debugger-Agent))\n\n### #agent=\n\n def agent=(value) -\u003e Google::Cloud::Debugger::Agent\n\nThe debugger agent this transmiter belongs to \n**Parameter**\n\n- **value** ([Google::Cloud::Debugger::Agent](./Google-Cloud-Debugger-Agent)) \n**Returns**\n\n- ([Google::Cloud::Debugger::Agent](./Google-Cloud-Debugger-Agent))\n\n### #max_queue\n\n def max_queue()\n\n**Aliases**\n\n- [#max_queue_size](./Google-Cloud-Debugger-Transmitter#Google__Cloud__Debugger__Transmitter_max_queue_size_instance_) \nMaximum backlog size for this transmitter's queue\n\n### #max_queue=\n\n def max_queue=(value)\n\n**Aliases**\n\n- [#max_queue_size=](./Google-Cloud-Debugger-Transmitter#Google__Cloud__Debugger__Transmitter_max_queue_size=_instance_) \nMaximum backlog size for this transmitter's queue\n\n### #max_queue_size\n\n def max_queue_size()\n\n**Alias Of** : [#max_queue](./Google-Cloud-Debugger-Transmitter#Google__Cloud__Debugger__Transmitter_max_queue_instance_) \nMaximum backlog size for this transmitter's queue\n\n### #max_queue_size=\n\n def max_queue_size=(value)\n\n**Alias Of** : [#max_queue=](./Google-Cloud-Debugger-Transmitter#Google__Cloud__Debugger__Transmitter_max_queue=_instance_) \nMaximum backlog size for this transmitter's queue\n\n### #on_error\n\n def on_error(&block) { |error| ... }\n\nRegister to be notified of errors when raised.\n\n\nIf an unhandled error has occurred the transmitter will attempt to\nrecover from the error and resume submitting breakpoints.\n\n\u003cbr /\u003e\n\nMultiple error handlers can be added. \n**Yields**\n\n- (callback) --- The block to be called when an error is raised. \n**Yield Parameter**\n\n- **error** (Exception) --- The error raised.\n\n### #start\n\n def start() -\u003e Transmitter\n\nStarts the transmitter and its thread pool. \n**Returns**\n\n- ([Transmitter](./Google-Cloud-Debugger-Transmitter)) --- returns self so calls can be chained.\n\n### #started?\n\n def started?() -\u003e boolean\n\nWhether the transmitter has been started. \n**Returns**\n\n- (boolean) --- `true` when started, `false` otherwise.\n\n### #stop\n\n def stop(timeout = nil) -\u003e Transmitter\n\nStops the transmitter and its thread pool. Once stopped, cannot be\nstarted again. \n**Returns**\n\n- ([Transmitter](./Google-Cloud-Debugger-Transmitter)) --- returns self so calls can be chained.\n\n### #stopped?\n\n def stopped?() -\u003e boolean\n\nWhether the transmitter has been stopped. \n**Returns**\n\n- (boolean) --- `true` when stopped, `false` otherwise.\n\n### #submit\n\n def submit(breakpoint)\n\nEnqueue an evaluated breakpoint to be submitted by the transmitter. \n**Raises**\n\n- ([TransmitterError](./Google-Cloud-Debugger-TransmitterError)) --- if there are no resources available to make queue the API call on the thread pool.\n\n### #threads\n\n def threads()\n\nMaximum threads used in the thread pool\n\n### #threads=\n\n def threads=(value)\n\nMaximum threads used in the thread pool"]]
