pskafka.psm1
|
Import-Module ThreadJob -ErrorAction Stop #handle PS2 if (-not $PSScriptRoot) { $PSScriptRoot = Split-Path $MyInvocation.MyCommand.Path -Parent } $ModuleRoot = $PSScriptRoot #Get public and private function definition files. $Public = @( Get-ChildItem -Path $PSScriptRoot\Public\*.ps1 -ErrorAction SilentlyContinue ) $Private = @( Get-ChildItem -Path $PSScriptRoot\Private\*.ps1 -ErrorAction SilentlyContinue ) $Types = @( Get-ChildItem -Path $PSScriptRoot\Types\*.ps1 -ErrorAction SilentlyContinue ) #Dot source the files Foreach ($import in @($Public + $Private + $Types)) { Try { Write-Verbose -Message "Importing $($import.fullname)" . $import.fullname } Catch { Write-Error -Message "Failed to import $($import.fullname): $_" } } foreach ($verb in @('Read', 'Stop', 'Get', 'Receive', 'Wait', 'Remove')) { $alias_name = "$verb-KafkaConsumer" $aliases += @($alias_name) New-Alias -Name $alias_name -Value "$verb-Job" -Force } Export-ModuleMember -Function ($Public | Select-Object -ExpandProperty BaseName) -Alias $aliases |