utils

Documentation

Index

• Constants
• func GenerateKeyPair() (publicKey []byte, privateAuthMethod ssh.AuthMethod, err error)
• func TarballDirectory(dirname, rootdir, tarname string) (string, error)
• type BlobClient
  • func NewBlobstore(uri string) BlobClient
  • func (b BlobClient) Create(filepath string) (string, error)
  • func (b BlobClient) Get(uuid string, destinationPath string) error
• type CompileTemplate
  • func (c CompileTemplate) Arguments() []interface{}
• type MarshalableBlobRef
• type NatCommand
  • func (n NatCommand) Marshal() (string, error)
• type NatsClient
  • func NewNatsClient(compressor boshfileutil.Compressor, blobstoreClient BlobClient, natsIP string) *NatsClient
  • func (n *NatsClient) CheckErrandResultStatus(taskID string) func() (action.ErrandResult, error)
  • func (n *NatsClient) Cleanup()
  • func (n *NatsClient) CleanupSSH(username string, senderID string) (action.SSHResult, error)
  • func (n *NatsClient) CompilePackage(packageName string) (*MarshalableBlobRef, error)
  • func (n *NatsClient) CompilePackageWithDeps(packageName string, deps map[string]MarshalableBlobRef) (*MarshalableBlobRef, error)
  • func (n *NatsClient) FetchLogs(destinationDir string)
  • func (n *NatsClient) GetNextAlert(timeout time.Duration) (*boshalert.Alert, error)
  • func (n *NatsClient) GetState() action.GetStateV1ApplySpec
  • func (n *NatsClient) GetTask(id string) (*http.TaskResponse, error)
  • func (n *NatsClient) PrepareJob(jobName string)
  • func (n *NatsClient) RunDrain() error
  • func (n *NatsClient) RunErrand() (map[string]map[string]string, error)
  • func (n *NatsClient) RunScript(scriptName string) error
  • func (n *NatsClient) RunStart() (map[string]string, error)
  • func (n *NatsClient) RunStop() error
  • func (n *NatsClient) SendMessage(message string) (map[string]map[string]string, error)
  • func (n *NatsClient) SendRawMessage(message string) ([]byte, error)
  • func (n *NatsClient) SendRawMessageWithTimeout(message string, timeout time.Duration) ([]byte, error)
  • func (n *NatsClient) Setup() error
  • func (n *NatsClient) SetupSSH(username string, senderID string) (action.SSHResult, *ssh.ClientConfig, error)
  • func (n *NatsClient) WaitForTask(id string, timeout time.Duration) (*http.TaskResponse, error)
• type PrepareTemplateConfig
• type TarWalker
  • func (t *TarWalker) Walk(path string, fi os.FileInfo, _ error) error

Constants

const (
	DefaultTimeout  = time.Minute
	DefaultInterval = time.Second
)

const DefaultNatsTimeout = time.Second * 15

const DefaultTaskTimeout = time.Second * 30

Functions

func GenerateKeyPair

func GenerateKeyPair() (publicKey []byte, privateAuthMethod ssh.AuthMethod, err error)

func TarballDirectory

func TarballDirectory(dirname, rootdir, tarname string) (string, error)

TarballDirectory - rootdir is equivalent to tar -C 'rootdir'

Types

type BlobClient

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

func NewBlobstore

func NewBlobstore(uri string) BlobClient

func (BlobClient) Create

func (b BlobClient) Create(filepath string) (string, error)

func (BlobClient) Get

func (b BlobClient) Get(uuid string, destinationPath string) error

type CompileTemplate

type CompileTemplate struct {
	BlobstoreID  string
	SHA1         string
	Name         string
	Version      string
	Dependencies map[string]MarshalableBlobRef
}

func (CompileTemplate) Arguments

func (c CompileTemplate) Arguments() []interface{}

type MarshalableBlobRef

type MarshalableBlobRef struct {
	Name        string
	Version     string
	BlobstoreID string `json:"blobstore_id"`
	SHA1        string
}

type NatCommand

type NatCommand struct {
	Protocol  int           `json:"protocol"`
	Method    string        `json:"method"`
	Arguments []interface{} `json:"arguments"`
	ReplyTo   string        `json:"reply_to"`
}

func (NatCommand) Marshal

func (n NatCommand) Marshal() (string, error)

type NatsClient

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

func NewNatsClient

func NewNatsClient(
	compressor boshfileutil.Compressor,
	blobstoreClient BlobClient,
	natsIP string,
) *NatsClient

func (*NatsClient) CheckErrandResultStatus

func (n *NatsClient) CheckErrandResultStatus(taskID string) func() (action.ErrandResult, error)

func (*NatsClient) Cleanup

func (n *NatsClient) Cleanup()

func (*NatsClient) CleanupSSH

func (n *NatsClient) CleanupSSH(username string, senderID string) (action.SSHResult, error)

func (*NatsClient) CompilePackage

func (n *NatsClient) CompilePackage(packageName string) (*MarshalableBlobRef, error)

func (*NatsClient) CompilePackageWithDeps

func (n *NatsClient) CompilePackageWithDeps(packageName string, deps map[string]MarshalableBlobRef) (*MarshalableBlobRef, error)

func (*NatsClient) FetchLogs

func (n *NatsClient) FetchLogs(destinationDir string)

func (*NatsClient) GetNextAlert

func (n *NatsClient) GetNextAlert(timeout time.Duration) (*boshalert.Alert, error)

func (*NatsClient) GetState

func (n *NatsClient) GetState() action.GetStateV1ApplySpec

func (*NatsClient) GetTask

func (n *NatsClient) GetTask(id string) (*http.TaskResponse, error)

func (*NatsClient) PrepareJob

func (n *NatsClient) PrepareJob(jobName string)

func (*NatsClient) RunDrain

func (n *NatsClient) RunDrain() error

func (*NatsClient) RunErrand

func (n *NatsClient) RunErrand() (map[string]map[string]string, error)

func (*NatsClient) RunScript

func (n *NatsClient) RunScript(scriptName string) error

func (*NatsClient) RunStart

func (n *NatsClient) RunStart() (map[string]string, error)

func (*NatsClient) RunStop

func (n *NatsClient) RunStop() error

func (*NatsClient) SendMessage

func (n *NatsClient) SendMessage(message string) (map[string]map[string]string, error)

func (*NatsClient) SendRawMessage

func (n *NatsClient) SendRawMessage(message string) ([]byte, error)

func (*NatsClient) SendRawMessageWithTimeout

func (n *NatsClient) SendRawMessageWithTimeout(message string, timeout time.Duration) ([]byte, error)

func (*NatsClient) Setup

func (n *NatsClient) Setup() error

func (*NatsClient) SetupSSH

func (n *NatsClient) SetupSSH(username string, senderID string) (action.SSHResult, *ssh.ClientConfig, error)

func (*NatsClient) WaitForTask

func (n *NatsClient) WaitForTask(id string, timeout time.Duration) (*http.TaskResponse, error)

type PrepareTemplateConfig

type PrepareTemplateConfig struct {
	JobName                             string
	TemplateBlobstoreID                 string
	RenderedTemplatesArchiveBlobstoreID string
	RenderedTemplatesArchiveSHA1        string
	ReplyTo                             string
}

type TarWalker

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

func (*TarWalker) Walk

func (t *TarWalker) Walk(path string, fi os.FileInfo, _ error) error