Public/Pause-GLClusterProcessing.ps1
|
<#
.SYNOPSIS Pause message processing on node .DESCRIPTION Pause message processing on node If the message journal is enabled, incoming messages will be spooled on disk, if it is disabled, you might lose messages from inputs which cannot buffer themselves, like AMQP or Kafka-based inputs. For more information about this cmdlet - please search for /cluster/{nodeId}/processing/pause in the docs available at http(s)://your-graylog.fqdn/api/api-docs .EXAMPLE Pause-GLClusterProcessing -Nodeid <String> .NOTES Auto generated #> function Pause-GLClusterProcessing { [CmdletBinding(SupportsShouldProcess,ConfirmImpact = 'Medium')] param( # The id of the node where processing will be paused. [Parameter(Mandatory = $True,ValueFromPipelineByPropertyName = $true)] [string]$Nodeid, # Base url for the API, normally https://<grayloghost>:<port>/api [string]$APIUrl = $Global:GLApiUrl, # Graylog credentials as username:password or use Convert-GLTokenToCredential for token usage [pscredential]$Credential = $Global:GLCredential ) begin { if ([string]::IsNullOrEmpty($APIUrl)) { Write-Error -ErrorAction Stop -Exception "APIUrl not set" -Message "APIUrl was null or empty, refer to the documentation" } if ($Null -eq $Credential) { Write-Error -ErrorAction Stop -Exception "Credential not set" -Message "Credential not set - refer to the documentation for help" } } process { if ($PSCmdlet.ShouldProcess($Nodeid,"Pause message processing on node")) { $BodyHash = @{} $QueryArray | ForEach-Object { $val = $_ -split '=' $BodyHash[$val[0]] = $val[1] } $Body = $BodyHash | ConvertTo-Json try { Invoke-RestMethod -Method POST -Headers $Headers -ContentType 'application/json' -Uri "$APIUrl$APIPath" -Credential $Credential -Body $Body -ErrorAction Stop } catch { Write-Error -Exception $Error[0].Exception -Message $Error[0].Message -ErrorAction $ErrorActionPreference } } } end {} } |