winrm

package module
v0.0.0-...-57b3353 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 4, 2026 License: Apache-2.0 Imports: 47 Imported by: 318

README

WinRM for Go

Note: if you're looking for the winrm command-line tool, this has been splitted from this project and is available at winrm-cli

This is a Go library to execute remote commands on Windows machines through the use of WinRM/WinRS.

The library supports domain users through Kerberos, including WinRM message encryption over HTTP.

Go Tests Lint

Contact

Getting Started

WinRM is available on Windows Server 2008 and up. This project natively supports basic authentication for local accounts, see the steps in the next section on how to prepare the remote Windows machine for this scenario. The authentication model is pluggable, see below for an example on using Negotiate/NTLM authentication (e.g. for connecting to vanilla Azure VMs) or Kerberos authentication (using domain accounts).

Note: This library only supports Golang 1.7+

Preparing the remote Windows machine for Basic authentication

This project supports only basic authentication for local accounts (domain users are not supported). The remote windows system must be prepared for winrm:

For a PowerShell script to do what is described below in one go, check Richard Downer's blog

On the remote host, a PowerShell prompt, using the Run as Administrator option and paste in the following lines:

	winrm quickconfig
	y
	winrm set winrm/config/service/Auth '@{Basic="true"}'
	winrm set winrm/config/service '@{AllowUnencrypted="true"}'
	winrm set winrm/config/winrs '@{MaxMemoryPerShellMB="1024"}'

N.B.: The Windows Firewall needs to be running to run this command. See Microsoft Knowledge Base article #2004640.

N.B.: Do not disable Negotiate authentication as the winrm command itself uses this for internal authentication, and you risk getting a system where winrm doesn't work anymore.

N.B.: The MaxMemoryPerShellMB option has no effects on some Windows 2008R2 systems because of a WinRM bug. Make sure to install the hotfix described Microsoft Knowledge Base article #2842230 if you need to run commands that use more than 150MB of memory.

For more information on WinRM, please refer to the online documentation at Microsoft's DevCenter.

Preparing the remote Windows machine for kerberos authentication

This project supports domain users via kerberos authentication. The remote windows system must be prepared for winrm:

On the remote host, a PowerShell prompt, using the Run as Administrator option and paste in the following lines:

            winrm quickconfig
            y
            winrm set winrm/config/winrs '@{MaxMemoryPerShellMB="1024"}'

Kerberos can protect the SOAP message body when MessageEncryption is enabled, so AllowUnencrypted=true is not required. HTTPS remains useful because it also protects HTTP headers and provides certificate-based server identity.

All other N.B points of "Preparing the remote Windows machine for Basic authentication" also apply.

Preparing the remote Windows machine for CredSSP authentication

CredSSP requires both WinRM and CredSSP to be enabled on the target host.

On the remote host, run PowerShell as Administrator and execute:

            winrm quickconfig
            Enable-WSManCredSSP -Role Server -Force
            winrm set winrm/config/service/Auth '@{CredSSP="true"}'

CredSSP wraps the WinRM payload in its own TLS-encrypted channel, so there is no need to enable AllowUnencrypted for this transport.

To allow the client machine to delegate credentials to this host, configure the client policy or run:

            Enable-WSManCredSSP -Role Client -DelegateComputer "<server-or-pattern>" -Force

All N.B points of "Preparing the remote Windows machine for Basic authentication" also apply.

Building the winrm go and executable

You can build winrm from source:

git clone https://github.com/masterzen/winrm
cd winrm
make

Note: this winrm code doesn't depend anymore on Gokogiri which means it is now in pure Go.

Note: you need go 1.5+. Please check your installation with

go version

Command-line usage

For command-line usage check the winrm-cli project

Library Usage

Warning the API might be subject to change.

For the fast version (this doesn't allow to send input to the command) and it's using HTTP as the transport:

package main

import (
	"github.com/masterzen/winrm"
	"os"
)

endpoint := winrm.NewEndpoint(host, 5986, false, false, nil, nil, nil, 0)
client, err := winrm.NewClient(endpoint, "Administrator", "secret")
if err != nil {
	panic(err)
}
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
client.RunWithContext(ctx, "ipconfig /all", os.Stdout, os.Stderr)

or

package main
import (
  "github.com/masterzen/winrm"
  "fmt"
  "os"
)

endpoint := winrm.NewEndpoint("localhost", 5985, false, false, nil, nil, nil, 0)
client, err := winrm.NewClient(endpoint,"Administrator", "secret")
if err != nil {
	panic(err)
}

ctx, cancel := context.WithCancel(context.Background())
defer cancel()
_, err := client.RunWithContextWithInput(ctx, "ipconfig", os.Stdout, os.Stderr, os.Stdin)
if err != nil {
	panic(err)
}

Authentication and encryption transports

Beyond the default unencrypted Basic-authentication transport shown above, this library supports three additional, related-but-distinct TransportDecorator options for authenticating and/or encrypting WinRM traffic:

  • NTLM, with an opt-in message-encryption mode that seals the WinRM SOAP body (MS-NLMP), useful for workgroup or Azure-VM style hosts without a domain controller.
  • Kerberos, for domain accounts, with its own opt-in message-encryption mode that encrypts each SOAP message using the negotiated Kerberos security context.
  • CredSSP, which delegates the client's credentials to the remote host over a TLS tunnel -- needed for double-hop scenarios where the remote command itself must authenticate onward using the caller's credentials -- and always encrypts traffic as part of that tunnel.

All three are opt-in and layer on top of the same TransportDecorator (or, for message encryption, NewEncryption/NewEncryptionWithSettings) mechanism; none change the default transport's behavior for existing callers.

NTLM

By passing a TransportDecorator in the Parameters struct it is possible to use different Transports (e.g. NTLM)

package main
import (
  "github.com/masterzen/winrm"
  "fmt"
  "os"
)

endpoint := winrm.NewEndpoint("localhost", 5985, false, false, nil, nil, nil, 0)

params := DefaultParameters
params.TransportDecorator = func() Transporter { return &ClientNTLM{} }

client, err := NewClientWithParameters(endpoint, "test", "test", params)
if err != nil {
	panic(err)
}

_, err := client.RunWithInput("ipconfig", os.Stdout, os.Stderr, os.Stdin)
if err != nil {
	panic(err)
}

NTLM message encryption

For confidentiality without a domain controller, wrap the transport in winrm.NewEncryption("ntlm") instead of &ClientNTLM{}. This runs the same NTLM handshake but additionally seals each SOAP message using the negotiated NTLM session key (MS-NLMP §3.4):

package main
import (
  "github.com/masterzen/winrm"
  "os"
)

endpoint := winrm.NewEndpoint("localhost", 5985, false, false, nil, nil, nil, 0)

encryption, err := winrm.NewEncryption("ntlm")
if err != nil {
	panic(err)
}

params := DefaultParameters
params.TransportDecorator = func() Transporter { return encryption }

client, err := NewClientWithParameters(endpoint, "test", "test", params)
if err != nil {
	panic(err)
}

_, err = client.RunWithInput("ipconfig", os.Stdout, os.Stderr, os.Stdin)
if err != nil {
	panic(err)
}

Like the unencrypted ClientNTLM transport above, this is opt-in and does not change the default transport's behavior. By default it accepts whatever key strength (128, 56, or 40-bit) the server negotiates, matching this library's historical NTLM-encryption behavior; set NewEncryptionWithSettings("ntlm", &Settings{NTLMKeyExchangeOptions: winrm.NTLMKeyExchangeOptions{MinimumKeyBits: 128}}) to reject weaker keys.

Kerberos

Passing a TransportDecorator also permits Kerberos authentication:

package main

import (
	"context"
	"os"

	"github.com/masterzen/winrm"
)

func main() {
	endpoint := winrm.NewEndpoint("srv-win", 5985, false, false, nil, nil, nil, 0)

	params := *winrm.DefaultParameters
	params.TransportDecorator = func() winrm.Transporter {
		return &winrm.ClientKerberos{
			Username:          "test",
			Password:          "s3cr3t",
			Hostname:          "srv-win",
			Realm:             "DOMAIN.LAN",
			Port:              5985,
			Proto:             "http",
			KrbConf:           "/etc/krb5.conf",
			SPN:               "HTTP/srv-win",
			MessageEncryption: true,
		}
	}

	client, err := winrm.NewClientWithParameters(endpoint, "test", "s3cr3t", &params)
	if err != nil {
		panic(err)
	}

	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	_, err = client.RunWithContextWithInput(ctx, "ipconfig", os.Stdout, os.Stderr, os.Stdin)
	if err != nil {
		panic(err)
	}
}

MessageEncryption is opt-in to preserve compatibility with existing callers. When enabled, the client establishes a mutually authenticated Kerberos context, encrypts each SOAP request using the negotiated Kerberos enctype, and requires encrypted responses. Password and credential-cache authentication are both supported. Set KrbCCache instead of Password to use a cache.

The protocol-selected encryption constructors, NewEncryption and NewEncryptionWithSettings, accept "ntlm" and "kerberos". For Kerberos, NewEncryptionWithSettings applies the same settings shown above and delegates authentication and message protection to ClientKerberos. CredSSP is intentionally not one of the accepted protocol strings here -- it has its own dedicated transport, ClientCredSSP (see below), which always encrypts its traffic as part of its TLS tunnel rather than through this generic protocol switch.

Kerberos message encryption supports AES128/AES256 SHA-1 and SHA-2 enctypes, and legacy RC4-HMAC. AES is strongly preferred. The export-strength RC4 enctype is not supported.

The SPN should normally be HTTP/fully-qualified-hostname; using an IP address usually fails because it does not identify the host's registered service principal. A ClientKerberos serializes requests because GSS message sequence numbers are stateful.

Kerberos configuration

Kerberos requires a MIT/Heimdal-style krb5.conf file. The Go Kerberos library reads this file to determine the default realm and how to locate the realm's KDC. ClientKerberos.KrbConf must point to the file; the library does not create one or discover its location automatically.

A minimal Active Directory configuration is:

[libdefaults]
    default_realm = EXAMPLE.COM
    dns_lookup_kdc = false
    dns_lookup_realm = false

[realms]
    EXAMPLE.COM = {
        kdc = dc01.example.com
        admin_server = dc01.example.com
    }

[domain_realm]
    .example.com = EXAMPLE.COM
    example.com = EXAMPLE.COM

Replace the realm, domain, and domain-controller names with values from the Active Directory environment. A domain controller provides the KDC service, normally on TCP and UDP port 88. Instead of listing a KDC explicitly, DNS SRV discovery can be enabled with dns_lookup_kdc = true, provided the client can resolve the domain's _kerberos._tcp records.

Kerberos also requires synchronized clocks; a substantial time difference between the client and KDC will cause authentication to fail. Use the server's fully qualified hostname and its registered SPN, normally HTTP/server.example.com, rather than an IP address.

Kerberos over HTTP with message encryption

For an HTTP endpoint, enable MessageEncryption when constructing the Kerberos transport. The endpoint and SPN must use the server hostname, not its IP address:

endpoint := winrm.NewEndpoint("srv-win.example.com", 5985, false, false, nil, nil, nil, 0)

params := *winrm.DefaultParameters
params.TransportDecorator = func() winrm.Transporter {
	return &winrm.ClientKerberos{
		Username:          "alice",
		Password:          "password",
		Hostname:          "srv-win.example.com",
		Realm:             "EXAMPLE.COM",
		Port:              5985,
		Proto:             "http",
		KrbConf:           "/etc/krb5.conf",
		SPN:               "HTTP/srv-win.example.com",
		MessageEncryption: true,
	}
}

The client first performs the normal Negotiate exchange. After the Kerberos security context is established, each SOAP message is encrypted using the negotiated GSS context. The initial 401 responses are expected; encrypted requests do not need to repeat the Authorization header.

Before troubleshooting WinRM, verify that:

  • the client can reach the configured KDC on TCP/UDP port 88;
  • the client and domain controller clocks are synchronized;
  • the configured SPN exists for the target hostname;
  • the hostname resolves to the intended Windows host; and
  • the account has permission to use WinRM on that host.

Message encryption is intended for HTTP. HTTPS already encrypts the transport, although message encryption can still be requested explicitly. Kerberos and NTLM use the WinRM SPNEGO encrypted-message content type; CredSSP encrypts its traffic through its own TLS tunnel instead (see below), not through the NewEncryption/NewEncryptionWithSettings constructors. AES enctypes are preferred; RC4-HMAC is retained only for legacy interoperability.

CredSSP

By passing a TransportDecorator it is also possible to use CredSSP authentication:

package main

import (
  "context"
  "os"

  "github.com/masterzen/winrm"
)

endpoint := winrm.NewEndpoint("srv-win", 5985, false, true, nil, nil, nil, 0)

params := winrm.DefaultParameters
params.TransportDecorator = func() winrm.Transporter { return &winrm.ClientCredSSP{} }

client, err := winrm.NewClientWithParameters(endpoint, "DOMAIN\\user", "s3cr3t", params)
if err != nil {
  panic(err)
}

ctx, cancel := context.WithCancel(context.Background())
defer cancel()
_, err = client.RunWithContext(ctx, "whoami", os.Stdout, os.Stderr)
if err != nil {
  panic(err)
}

N.B.: CredSSP binds authentication state and its TLS tunnel to a single connection, so all requests on a CredSSP client are serialized. Because a long-polling output Receive holds that lock until it returns, concurrent stdin sends are stalled behind each poll. Real-time interactive stdin is therefore not supported over CredSSP; non-interactive RunCmd/RunPS (no stdin) are unaffected. If the server drops the pinned connection, the client transparently re-runs the handshake once on the next request.

Running opt-in integration tests

All real-Windows integration tests (CredSSP included) live in integrationTest/ as env-var-driven subtests of a single go test entry point. See that package's README for the full environment variable contract and SETUP.md for how to get a Windows host to point it at.

go test ./integrationTest/... -v

Every subtest skips itself (never fails) if its environment variables are unset.

By passing a Dial in the Parameters struct it is possible to use different dialer (e.g. tunnel through SSH)

package main
     
 import (
    "github.com/masterzen/winrm"
    "golang.org/x/crypto/ssh"
    "os"
 )
 
 func main() {
 
    sshClient, err := ssh.Dial("tcp","localhost:22", &ssh.ClientConfig{
        User:"ubuntu",
        Auth: []ssh.AuthMethod{ssh.Password("ubuntu")},
        HostKeyCallback: ssh.InsecureIgnoreHostKey(),
    })
 
    endpoint := winrm.NewEndpoint("other-host", 5985, false, false, nil, nil, nil, 0)
 
    params := winrm.DefaultParameters
    params.Dial = sshClient.Dial
 
    client, err := winrm.NewClientWithParameters(endpoint, "test", "test", params)
    if err != nil {
        panic(err)
    }
 
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()
    _, err = client.RunWithContextWithInput(ctx, "ipconfig", os.Stdout, os.Stderr, os.Stdin)
    if err != nil {
        panic(err)
    }
 }

For a more complex example, it is possible to call the various functions directly:

package main

import (
  "github.com/masterzen/winrm"
  "fmt"
  "bytes"
  "os"
)

stdin := bytes.NewBufferString("ipconfig /all")
endpoint := winrm.NewEndpoint("localhost", 5985, false, false,nil, nil, nil, 0)
client , err := winrm.NewClient(endpoint, "Administrator", "secret")
if err != nil {
	panic(err)
}
shell, err := client.CreateShell()
if err != nil {
  panic(err)
}
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
var cmd *winrm.Command
cmd, err = shell.ExecuteWithContext(ctx, "cmd.exe")
if err != nil {
  panic(err)
}

go io.Copy(cmd.Stdin, stdin)
go io.Copy(os.Stdout, cmd.Stdout)
go io.Copy(os.Stderr, cmd.Stderr)

cmd.Wait()
shell.Close()

For using HTTPS authentication with x 509 cert without checking the CA

package main

import (
    "github.com/masterzen/winrm"
    "log"
    "os"
)

func main() {
    clientCert, err := os.ReadFile("/home/example/winrm_client_cert.pem")
    if err != nil {
        log.Fatalf("failed to read client certificate: %q", err)
    }

    clientKey, err := os.ReadFile("/home/example/winrm_client_key.pem")
    if err != nil {
        log.Fatalf("failed to read client key: %q", err)
    }

    winrm.DefaultParameters.TransportDecorator = func() winrm.Transporter {
        // winrm https module
        return &winrm.ClientAuthRequest{}
    }

    endpoint := winrm.NewEndpoint(
        "192.168.100.2", // host to connect to
        5986,            // winrm port
        true,            // use TLS
        true,            // Allow insecure connection
        nil,             // CA certificate
        clientCert,      // Client Certificate
        clientKey,       // Client Key
        0,               // Timeout
    )
    client, err := winrm.NewClient(endpoint, "Administrator", "")
    if err != nil {
        log.Fatalf("failed to create client: %q", err)
    }
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()
    _, err = client.RunWithContext(ctx, "whoami", os.Stdout, os.Stderr)
    if err != nil {
        log.Fatalf("failed to run command: %q", err)
    }
}

Note: canceling the context.Context passed as first argument to the various functions of the API will not cancel the HTTP requests themselves, it will rather cause a running command to be aborted on the remote machine via a call to command.Stop().

Developing on WinRM

If you wish to work on winrm itself, you'll first need Go installed (version 1.5+ is required). Make sure you have Go properly installed, including setting up your GOPATH.

For some additional dependencies, Go needs Mercurial and Bazaar to be installed. Winrm itself doesn't require these, but a dependency of a dependency does.

Next, clone this repository into $GOPATH/src/github.com/masterzen/winrm and then just type make.

You can run tests by typing make test.

If you make any changes to the code, run make format in order to automatically format the code according to Go standards.

When new dependencies are added to winrm you can use make updatedeps to get the latest and subsequently use make to compile.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultParameters = NewParameters("PT60S", "en-US", 153600)

DefaultParameters return constant config of type Parameters

Functions

func NewClientWithDial

func NewClientWithDial(dial func(network, addr string) (net.Conn, error)) *clientRequest

NewClientWithDial NewClientWithDial

func NewClientWithProxyFunc

func NewClientWithProxyFunc(proxyfunc func(req *http.Request) (*url.URL, error)) *clientRequest

NewClientWithProxyFunc NewClientWithProxyFunc

func NewDeleteShellRequest

func NewDeleteShellRequest(uri, shellID string, params *Parameters) *soap.SoapMessage

NewDeleteShellRequest ...

func NewExecuteCommandRequest

func NewExecuteCommandRequest(uri, shellID, command string, arguments []string, params *Parameters) *soap.SoapMessage

NewExecuteCommandRequest exec command on specific shellID

func NewGetOutputRequest

func NewGetOutputRequest(uri, shellID, commandID, streams string, params *Parameters) *soap.SoapMessage

NewGetOutputRequest NewGetOutputRequest

func NewOpenShellRequest

func NewOpenShellRequest(uri string, params *Parameters) *soap.SoapMessage

NewOpenShellRequest makes a new soap request

func NewSendInputRequest

func NewSendInputRequest(uri, shellID, commandID string, input []byte, eof bool, params *Parameters) *soap.SoapMessage

NewSendInputRequest NewSendInputRequest

func NewSignalRequest

func NewSignalRequest(uri string, shellID string, commandID string, params *Parameters) *soap.SoapMessage

NewSignalRequest NewSignalRequest

func ParseExecuteCommandResponse

func ParseExecuteCommandResponse(response string) (string, error)

func ParseOpenShellResponse

func ParseOpenShellResponse(response string) (string, error)

func ParseSlurpOutputErrResponse

func ParseSlurpOutputErrResponse(response string, stdout, stderr io.Writer) (bool, int, error)

ParseSlurpOutputErrResponse ParseSlurpOutputErrResponse

func ParseSlurpOutputResponse

func ParseSlurpOutputResponse(response string, stream io.Writer, streamType string) (bool, int, error)

ParseSlurpOutputResponse ParseSlurpOutputResponse

func Powershell

func Powershell(psCmd string) string

Powershell wraps a PowerShell script and prepares it for execution by the winrm client

Types

type Client

type Client struct {
	Parameters
	// contains filtered or unexported fields
}

Client struct

func NewClient

func NewClient(endpoint *Endpoint, user, password string) (*Client, error)

NewClient will create a new remote client on url, connecting with user and password This function doesn't connect (connection happens only when CreateShell is called)

func NewClientWithParameters

func NewClientWithParameters(endpoint *Endpoint, user, password string, params *Parameters) (*Client, error)

NewClientWithParameters will create a new remote client on url, connecting with user and password This function doesn't connect (connection happens only when CreateShell is called)

func (*Client) CreateShell

func (c *Client) CreateShell() (*Shell, error)

CreateShell will create a WinRM Shell, which is the prealable for running commands.

func (*Client) NewShell

func (c *Client) NewShell(id string) *Shell

NewShell will create a new WinRM Shell for the given shellID

func (*Client) Run deprecated

func (c *Client) Run(command string, stdout io.Writer, stderr io.Writer) (int, error)

Run will run command on the the remote host, writing the process stdout and stderr to the given writers. Note with this method it isn't possible to inject stdin.

Deprecated: use RunWithContext()

func (*Client) RunCmdWithContext

func (c *Client) RunCmdWithContext(ctx context.Context, command string) (string, string, int, error)

RunCmdWithContext will run command on the the remote host, returning the process stdout and stderr as strings If the context is canceled, the remote command is canceled.

func (*Client) RunPSWithContext

func (c *Client) RunPSWithContext(ctx context.Context, command string) (string, string, int, error)

RunPSWithContext will basically wrap your code to execute commands in powershell.exe. runs commands in cmd.exe

func (*Client) RunPSWithContextWithString

func (c *Client) RunPSWithContextWithString(ctx context.Context, command string, stdin string) (string, string, int, error)

RunPSWithContextWithString will basically wrap your code to execute commands in powershell.exe. Default RunWithString runs commands in cmd.exe

func (*Client) RunPSWithString deprecated

func (c *Client) RunPSWithString(command string, stdin string) (string, string, int, error)

RunPSWithString will basically wrap your code to execute commands in powershell.exe. Default RunWithString runs commands in cmd.exe

Deprecated: use RunPSWithContextWithString()

func (*Client) RunWithContext

func (c *Client) RunWithContext(ctx context.Context, command string, stdout io.Writer, stderr io.Writer) (int, error)

RunWithContext will run command on the the remote host, writing the process stdout and stderr to the given writers. Note with this method it isn't possible to inject stdin. If the context is canceled, the remote command is canceled.

func (*Client) RunWithContextWithInput

func (c *Client) RunWithContextWithInput(ctx context.Context, command string, stdout, stderr io.Writer, stdin io.Reader) (int, error)

RunWithContextWithInput will run command on the the remote host, writing the process stdout and stderr to the given writers, and injecting the process stdin with the stdin reader. If the context is canceled, the command on the remote machine is canceled. Warning stdin (not stdout/stderr) are bufferized, which means reading only one byte in stdin will send a winrm http packet to the remote host. If stdin is a pipe, it might be better for performance reasons to buffer it. If stdin is nil, this is equivalent to c.RunWithContext()

func (*Client) RunWithContextWithString

func (c *Client) RunWithContextWithString(ctx context.Context, command string, stdin string) (string, string, int, error)

RunWithContextWithString will run command on the the remote host, returning the process stdout and stderr as strings, and using the input stdin string as the process input If the context is canceled, the remote command is canceled.

func (*Client) RunWithInput deprecated

func (c *Client) RunWithInput(command string, stdout, stderr io.Writer, stdin io.Reader) (int, error)

RunWithInput will run command on the the remote host, writing the process stdout and stderr to the given writers, and injecting the process stdin with the stdin reader. Warning stdin (not stdout/stderr) are bufferized, which means reading only one byte in stdin will send a winrm http packet to the remote host. If stdin is a pipe, it might be better for performance reasons to buffer it. If stdin is nil, this is equivalent to c.Run()

Deprecated: use RunWithContextWithInput()

func (*Client) RunWithString deprecated

func (c *Client) RunWithString(command string, stdin string) (string, string, int, error)

RunWithString will run command on the the remote host, returning the process stdout and stderr as strings, and using the input stdin string as the process input

Deprecated: use RunWithContextWithString()

type ClientAuthRequest

type ClientAuthRequest struct {
	// contains filtered or unexported fields
}

ClientAuthRequest ClientAuthRequest

func NewClientAuthRequestWithDial

func NewClientAuthRequestWithDial(dial func(network, addr string) (net.Conn, error)) *ClientAuthRequest

NewClientAuthRequestWithDial NewClientAuthRequestWithDial

func (ClientAuthRequest) Post

func (c ClientAuthRequest) Post(client *Client, request *soap.SoapMessage) (string, error)

Post Post

func (*ClientAuthRequest) Transport

func (c *ClientAuthRequest) Transport(endpoint *Endpoint) error

Transport Transport

type ClientCredSSP

type ClientCredSSP struct {

	// MinimumVersion, when set, requires the server to negotiate at least this
	// CredSSP version. CredSSP versions 2-4 use the pre-CVE-2018-0886 public-key
	// binding, so a server claiming an old version silently downgrades the
	// binding scheme. Set MinimumVersion to 5 to refuse that downgrade. Zero
	// means only the protocol floor (version 2) is enforced.
	MinimumVersion int

	// NTLMKeyExchangeOptions controls the minimum accepted NTLM key strength
	// for the pubKeyAuth exchange's inner NTLM security session. The zero
	// value accepts whatever the server negotiates, matching the historical
	// bodgit/ntlmssp default.
	NTLMKeyExchangeOptions NTLMKeyExchangeOptions
	// contains filtered or unexported fields
}

ClientCredSSP provides a transport via CredSSP.

func NewClientCredSSP

func NewClientCredSSP() *ClientCredSSP

NewClientCredSSP creates a CredSSP client.

func NewClientCredSSPWithDial

func NewClientCredSSPWithDial(dial func(network, addr string) (net.Conn, error)) *ClientCredSSP

NewClientCredSSPWithDial creates a CredSSP client with custom dialer.

func NewClientCredSSPWithProxyFunc

func NewClientCredSSPWithProxyFunc(proxyfunc func(req *http.Request) (*url.URL, error)) *ClientCredSSP

NewClientCredSSPWithProxyFunc creates a CredSSP client with custom proxy.

func (*ClientCredSSP) Post

func (c *ClientCredSSP) Post(client *Client, request *soap.SoapMessage) (string, error)

Post makes post to the winrm soap service over CredSSP.

func (*ClientCredSSP) Transport

func (c *ClientCredSSP) Transport(endpoint *Endpoint) error

Transport creates the wrapped CredSSP transport.

type ClientKerberos

type ClientKerberos struct {
	Username          string
	Password          string
	Realm             string
	Hostname          string
	Port              int
	Proto             string
	SPN               string
	KrbConf           string
	KrbCCache         string
	MessageEncryption bool
	// contains filtered or unexported fields
}

func NewClientKerberos

func NewClientKerberos(settings *Settings) *ClientKerberos

func (*ClientKerberos) Post

func (c *ClientKerberos) Post(clt *Client, request *soap.SoapMessage) (string, error)

func (*ClientKerberos) Transport

func (c *ClientKerberos) Transport(endpoint *Endpoint) error

type ClientNTLM

type ClientNTLM struct {
	// contains filtered or unexported fields
}

ClientNTLM provides a transport via NTLMv2

func NewClientNTLMWithDial

func NewClientNTLMWithDial(dial func(network, addr string) (net.Conn, error)) *ClientNTLM

NewClientNTLMWithDial NewClientNTLMWithDial

func NewClientNTLMWithProxyFunc

func NewClientNTLMWithProxyFunc(proxyfunc func(req *http.Request) (*url.URL, error)) *ClientNTLM

NewClientNTLMWithProxyFunc NewClientNTLMWithProxyFunc

func (ClientNTLM) Post

func (c ClientNTLM) Post(client *Client, request *soap.SoapMessage) (string, error)

Post make post to the winrm soap service (forwarded to clientRequest implementation)

func (*ClientNTLM) Transport

func (c *ClientNTLM) Transport(endpoint *Endpoint) error

Transport creates the wrapped NTLM transport

type Command

type Command struct {
	Stdin  *commandWriter
	Stdout *commandReader
	Stderr *commandReader
	// contains filtered or unexported fields
}

Command represents a given command running on a Shell. This structure allows to get access to the various stdout, stderr and stdin pipes.

func (*Command) Close

func (c *Command) Close() error

Close will terminate the running command

func (*Command) Error

func (c *Command) Error() error

Error returns command execution error if any

func (*Command) ExitCode

func (c *Command) ExitCode() int

ExitCode returns command exit code when it is finished. Before that the result is always 0.

func (*Command) Wait

func (c *Command) Wait()

Wait function will block the current goroutine until the remote command terminates.

type Encryption

type Encryption struct {
	// contains filtered or unexported fields
}

Encryption is a WinRM message-encryption transport selected by protocol (MS-WSMV §2.2.9.1). NTLM negotiates an azureNTLMSecuritySession (MS-NLMP §3.4, ntlm_security_session.go) directly over HTTP and wraps/unwraps message bodies through the shared messageProtector-based MIME framing in message_encryption.go. Kerberos delegates entirely to ClientKerberos, which owns the Kerberos security context. CredSSP has its own dedicated transport, ClientCredSSP (credssp.go): its ongoing message encryption is genuine TLS application data (not an NTLM-style Wrap/Unwrap), driven through a credsspMessageProtector built from the TLS tunnel established by performCredSSPAuth -- it never goes through this type. NTLM-style sealing is used only for CredSSP's pubKeyAuth handshake step, a separate code path in credssp.go.

func NewEncryption

func NewEncryption(protocol string) (*Encryption, error)

NewEncryption creates a WinRM message-encryption transport for protocol. Supported protocols are "ntlm" and "kerberos". CredSSP has its own dedicated transport, ClientCredSSP (credssp.go), and is not constructed through this function. For Kerberos, use NewEncryptionWithSettings when possible so the authentication configuration is installed before the transport is initialized.

func NewEncryptionWithSettings

func NewEncryptionWithSettings(protocol string, settings *Settings) (*Encryption, error)

NewEncryptionWithSettings creates a protocol-selected WinRM message- encryption transport and applies the supplied authentication settings.

func (*Encryption) ParseEncryptedResponse

func (e *Encryption) ParseEncryptedResponse(response *http.Response) ([]byte, error)

func (*Encryption) Post

func (e *Encryption) Post(client *Client, message *soap.SoapMessage) (string, error)

func (*Encryption) PrepareEncryptedRequest

func (e *Encryption) PrepareEncryptedRequest(_ *Client, endpoint string, message []byte) (string, error)

func (*Encryption) PrepareRequest

func (e *Encryption) PrepareRequest(client *Client, endpoint string) error

PrepareRequest negotiates NTLM message encryption: it runs the NTLM negotiate/challenge/authenticate exchange over endpoint (each leg sent as an Authorization: Negotiate header, MS-NLMP §3.3.1), derives an azureNTLMSecuritySession from the resulting exported session key (MS-NLMP §3.4), and installs it as e.messageEncryption's protector.

func (*Encryption) Transport

func (e *Encryption) Transport(endpoint *Endpoint) error

type Endpoint

type Endpoint struct {
	// host name or ip address
	Host string
	// port to determine if it's http or https default
	// winrm ports (http:5985, https:5986).Versions
	// of winrm can be customized to listen on other ports
	Port int
	// set the flag true for https connections
	HTTPS bool
	// set the flag true for skipping ssl verifications
	Insecure bool
	// if set, used to verify the hostname on the returned certificate
	TLSServerName string
	// pointer pem certs, and key
	CACert []byte // cert auth to intdetify the server cert
	Key    []byte // public key for client auth connections
	Cert   []byte // cert for client auth connections
	// duration timeout for the underling tcp conn(http/https base protocol)
	// if the time exceeds the connection is cloded/timeouts
	Timeout time.Duration
}

Endpoint struct holds configurations for the server endpoint

func NewEndpoint

func NewEndpoint(host string, port int, https bool, insecure bool, Cacert, cert, key []byte, timeout time.Duration) *Endpoint

NewEndpoint returns new pointer to struct Endpoint, with a default 60s response header timeout

type ExecuteCommandError

type ExecuteCommandError struct {
	Inner error
	Body  string
}

func (*ExecuteCommandError) Error

func (e *ExecuteCommandError) Error() string

func (*ExecuteCommandError) Is

func (e *ExecuteCommandError) Is(err error) bool

func (*ExecuteCommandError) Unwrap

func (e *ExecuteCommandError) Unwrap() error

type NTLMKeyExchangeOptions

type NTLMKeyExchangeOptions struct {
	MinimumKeyBits int
}

NTLMKeyExchangeOptions controls the minimum accepted NTLM key strength. The zero value accepts any strength the server negotiates. This matches bodgit/ntlmssp's historical behavior, so existing callers keep working. Set MinimumKeyBits to reject weaker keys instead.

type Parameters

type Parameters struct {
	Timeout            string
	Locale             string
	EnvelopeSize       int
	TransportDecorator func() Transporter
	Dial               func(network, addr string) (net.Conn, error)
}

Parameters struct defines metadata information and http transport config

func NewParameters

func NewParameters(timeout, locale string, envelopeSize int) *Parameters

NewParameters return new struct of type Parameters this struct makes the configuration for the request, size message, etc.

type Settings

type Settings struct {
	WinRMUsername          string
	WinRMPassword          string
	WinRMHost              string
	WinRMPort              int
	WinRMProto             string
	WinRMInsecure          bool
	WinRMMessageEncryption bool
	KrbRealm               string
	KrbConfig              string
	// KrbSpn is normally HTTP/<fully-qualified-hostname>. It must use the
	// hostname registered in Active Directory, not an IP address; Kerberos
	// service-ticket lookup is based on the SPN and IP literals generally do
	// not have a matching HTTP principal.
	KrbSpn               string
	KrbCCache            string
	WinRMUseNTLM         bool
	WinRMPassCredentials bool
	// NTLMKeyExchangeOptions controls the minimum NTLM key strength
	// NewEncryptionWithSettings("ntlm", ...) will accept. The zero value
	// accepts whatever the server negotiates, matching bodgit/ntlmssp's
	// historical default, so existing callers are unaffected.
	NTLMKeyExchangeOptions NTLMKeyExchangeOptions
}

Settings holds all the information necessary to configure the provider.

type Shell

type Shell struct {
	// contains filtered or unexported fields
}

Shell is the local view of a WinRM Shell of a given Client

func (*Shell) Close

func (s *Shell) Close() error

Close will terminate this shell. No commands can be issued once the shell is closed.

func (*Shell) Execute deprecated

func (s *Shell) Execute(command string, arguments ...string) (*Command, error)

Execute command on the given Shell, returning either an error or a Command

Deprecated: user ExecuteWithContext

func (*Shell) ExecuteWithContext

func (s *Shell) ExecuteWithContext(ctx context.Context, command string, arguments ...string) (*Command, error)

ExecuteWithContext command on the given Shell, returning either an error or a Command

type Transporter

type Transporter interface {
	// init request baset on the transport configurations
	Post(*Client, *soap.SoapMessage) (string, error)
	Transport(*Endpoint) error
}

Transporter does different transporters and init a Post request based on them

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL