funcAuthenticateProvisioner¶

func AuthenticateProvisioner(connio.ReadWriter, token, jobIDstring)error

AuthenticateProvisioner performs the provisioner's side of the authenticationprotocol.

funcDialTLS¶

func DialTLS(ctxcontext.Context, cert, addrstring) (*tls.Conn,error)

DialTLS establishes a TLS connection to the given addr using the given certas the root CA

funcEphemeralEcho¶

func EphemeralEcho(ctxcontext.Context,loggerslog.Logger,cacheDir, jobID, token, daemonCert, daemonAddressstring,)error

EphemeralEcho starts an Echo provisioner that connects to provisioner daemon,handles one job, then exits.

funcGenCert¶

func GenCert() (*ecdsa.PrivateKey, []byte,error)

GenCert is a helper function that generates a private key and certificate. Itis exported so that we can test a certificate generated in exactly the sameway, but with a different private key.

funcNewRemoteConnector¶

func NewRemoteConnector(ctxcontext.Context, loggerslog.Logger, execExecutor) (agpl.Connector,error)

typeExecutor¶

type Executor interface {// Execute a provisioner that connects back to the remoteConnector.  errCh// allows signaling of errors asynchronously and is closed on completion// with no error.Execute(ctxcontext.Context,provisionerTypedatabase.ProvisionerType,jobID, token, daemonCert, daemonAddressstring) (errCh <-chanerror)}

Executor is responsible for executing the remote provisioners.

TODO: this interface is where we will run Kubernetes Jobs in a futureversion; right now, only the unit tests implement this interface.