bosh

Documentation

Index

• Constants
• Variables
• type Bosh
  • func New(config Config) (*Bosh, error)
  • func NewWithDirector(dir boshdir.Director) *Bosh
  • func (b *Bosh) GetVMProgress(start time.Time, deploymentName string, isErrand bool) VMProgress
  • func (b *Bosh) VMProgress(deploymentName string) chan VMProgress
• type Config
• type FileReporter
  • func (f *FileReporter) TrackDownload(int64, io.Writer) io.Writer
  • func (f *FileReporter) TrackUpload(_ int64, r io.ReadCloser) ui.ReadSeekCloser
• type Logger
  • func (l *Logger) Debug(tag, msg string, args ...interface{})
  • func (l *Logger) DebugWithDetails(tag, msg string, args ...interface{})
  • func (l *Logger) Error(tag, msg string, args ...interface{})
  • func (l *Logger) ErrorWithDetails(tag, msg string, args ...interface{})
  • func (l *Logger) Flush() error
  • func (l *Logger) FlushTimeout(time.Duration) error
  • func (l *Logger) HandlePanic(tag string)
  • func (l *Logger) Info(tag, msg string, args ...interface{})
  • func (l *Logger) ToggleForcedDebug()
  • func (l *Logger) Warn(tag, msg string, args ...interface{})
• type ReadCloserProxy
  • func (p *ReadCloserProxy) Close() error
  • func (p *ReadCloserProxy) Read(bs []byte) (int, error)
  • func (p ReadCloserProxy) Seek(offset int64, whence int) (int64, error)
• type TaskReporter
  • func (t *TaskReporter) TaskFinished(int, string)
  • func (t *TaskReporter) TaskOutputChunk(int, []byte)
  • func (t *TaskReporter) TaskStarted(int)
• type VMProgress

Constants

const (
	UploadingReleases = "uploading-releases"
	Deploying         = "deploying"
	RunningErrand     = "running-errand"
)

Variables

var VMProgressInterval = 1 * time.Second

Types

type Bosh

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

func New

func New(config Config) (*Bosh, error)

func NewWithDirector

func NewWithDirector(dir boshdir.Director) *Bosh

func (*Bosh) GetVMProgress

func (b *Bosh) GetVMProgress(start time.Time, deploymentName string, isErrand bool) VMProgress

func (*Bosh) VMProgress

func (b *Bosh) VMProgress(deploymentName string) chan VMProgress

type Config

type Config struct {
	AdminUsername   string
	AdminPassword   string
	CACertificate   string
	DirectorAddress string

	GatewayHost       string
	GatewayPrivateKey string
	GatewayUsername   string
}

type FileReporter

type FileReporter struct{}

func (*FileReporter) TrackDownload

func (f *FileReporter) TrackDownload(int64, io.Writer) io.Writer

func (*FileReporter) TrackUpload

func (f *FileReporter) TrackUpload(_ int64, r io.ReadCloser) ui.ReadSeekCloser

type Logger

type Logger struct{}

func (*Logger) Debug

func (l *Logger) Debug(tag, msg string, args ...interface{})

func (*Logger) DebugWithDetails

func (l *Logger) DebugWithDetails(tag, msg string, args ...interface{})

func (*Logger) Error

func (l *Logger) Error(tag, msg string, args ...interface{})

func (*Logger) ErrorWithDetails

func (l *Logger) ErrorWithDetails(tag, msg string, args ...interface{})

func (*Logger) Flush

func (l *Logger) Flush() error

func (*Logger) FlushTimeout

func (l *Logger) FlushTimeout(time.Duration) error

func (*Logger) HandlePanic

func (l *Logger) HandlePanic(tag string)

func (*Logger) Info

func (l *Logger) Info(tag, msg string, args ...interface{})

func (*Logger) ToggleForcedDebug

func (l *Logger) ToggleForcedDebug()

func (*Logger) Warn

func (l *Logger) Warn(tag, msg string, args ...interface{})

type ReadCloserProxy

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

func (*ReadCloserProxy) Close

func (p *ReadCloserProxy) Close() error

func (*ReadCloserProxy) Read

func (p *ReadCloserProxy) Read(bs []byte) (int, error)

func (ReadCloserProxy) Seek

func (p ReadCloserProxy) Seek(offset int64, whence int) (int64, error)

type TaskReporter

type TaskReporter struct{}

func (*TaskReporter) TaskFinished

func (t *TaskReporter) TaskFinished(int, string)

func (*TaskReporter) TaskOutputChunk

func (t *TaskReporter) TaskOutputChunk(int, []byte)

func (*TaskReporter) TaskStarted

func (t *TaskReporter) TaskStarted(int)

type VMProgress

type VMProgress struct {
	State    string
	Releases int
	Total    int
	Done     int
	Duration time.Duration
}