client

Documentation

Index

• type Client
• type CompiledPackage
• type DiskManager
• type HTTPClient
  • func NewHTTPClient(url *url.URL, requester HTTPRequester, logger boshlog.Logger) HTTPClient
  • func NewHTTPClientWithURI(uri string, requester HTTPRequester, logger boshlog.Logger) (HTTPClient, error)
  • func NewInsecureHTTPClientWithURI(uri string, logger boshlog.Logger) (HTTPClient, error)
  • func (ac HTTPClient) Apply(desiredSpec boshas.V1ApplySpec) (string, error)
  • func (ac HTTPClient) CancelTask(taskID string) (string, error)
  • func (ac HTTPClient) CompilePackage(blobID, sha1, name, version string, deps boshcomp.Dependencies) (CompiledPackage, error)
  • func (ac HTTPClient) Drain(drainType boshaction.DrainType, newSpecs ...boshas.V1ApplySpec) (int, error)
  • func (ac HTTPClient) FetchLogs(logType string, filters []string) (map[string]interface{}, error)
  • func (ac HTTPClient) GetState(filters ...string) (boshaction.GetStateV1ApplySpec, error)
  • func (ac HTTPClient) GetTask(taskID string) (interface{}, error)
  • func (ac HTTPClient) Ping() (string, error)
  • func (ac HTTPClient) Prepare(desiredSpec boshas.V1ApplySpec) (string, error)
  • func (ac HTTPClient) RunErrand() (boshaction.ErrandResult, error)
  • func (ac HTTPClient) SSH(cmd string, params boshaction.SSHParams) (map[string]interface{}, error)
• type HTTPRequester
• type JobManager
• type NetworkManager
• type PackageCompiler
• type StateManager
• type TaskManager
• type VMAdministrator

Types

type Client

type Client interface {
	TaskManager
	VMAdministrator
	StateManager
	JobManager
	PackageCompiler
	DiskManager
	NetworkManager
}

type CompiledPackage

type CompiledPackage struct {
	BlobID string `json:"blobstore_id"`
	SHA1   string `json:"sha1"`
}

CompiledPackage keeps information about compiled package asset todo move into agent

type DiskManager

type DiskManager interface {
}

type HTTPClient

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

func NewHTTPClient

func NewHTTPClient(url *url.URL, requester HTTPRequester, logger boshlog.Logger) HTTPClient

func NewHTTPClientWithURI

func NewHTTPClientWithURI(uri string, requester HTTPRequester, logger boshlog.Logger) (HTTPClient, error)

func NewInsecureHTTPClientWithURI

func NewInsecureHTTPClientWithURI(uri string, logger boshlog.Logger) (HTTPClient, error)

func (HTTPClient) Apply

func (ac HTTPClient) Apply(desiredSpec boshas.V1ApplySpec) (string, error)

func (HTTPClient) CancelTask

func (ac HTTPClient) CancelTask(taskID string) (string, error)

func (HTTPClient) CompilePackage

func (ac HTTPClient) CompilePackage(blobID, sha1, name, version string, deps boshcomp.Dependencies) (CompiledPackage, error)

func (HTTPClient) Drain

func (ac HTTPClient) Drain(drainType boshaction.DrainType, newSpecs ...boshas.V1ApplySpec) (int, error)

func (HTTPClient) FetchLogs

func (ac HTTPClient) FetchLogs(logType string, filters []string) (map[string]interface{}, error)

func (HTTPClient) GetState

func (ac HTTPClient) GetState(filters ...string) (boshaction.GetStateV1ApplySpec, error)

func (HTTPClient) GetTask

func (ac HTTPClient) GetTask(taskID string) (interface{}, error)

func (HTTPClient) Ping

func (ac HTTPClient) Ping() (string, error)

func (HTTPClient) Prepare

func (ac HTTPClient) Prepare(desiredSpec boshas.V1ApplySpec) (string, error)

func (HTTPClient) RunErrand

func (ac HTTPClient) RunErrand() (boshaction.ErrandResult, error)

func (HTTPClient) SSH

func (ac HTTPClient) SSH(cmd string, params boshaction.SSHParams) (map[string]interface{}, error)

type HTTPRequester

type HTTPRequester interface {
	Do(*http.Request) (*http.Response, error)
}

type JobManager

type JobManager interface {
	Drain(boshaction.DrainType, ...boshas.V1ApplySpec) (int, error)
	RunErrand() (boshaction.ErrandResult, error)
}

type NetworkManager

type NetworkManager interface {
}

type PackageCompiler

type PackageCompiler interface {
	CompilePackage(
		blobID string,
		sha1 string,
		name string,
		version string,
		deps boshcomp.Dependencies,
	) (CompiledPackage, error)
}

type StateManager

type StateManager interface {
	Prepare(boshas.V1ApplySpec) (string, error)
	Apply(boshas.V1ApplySpec) (string, error)
	GetState(filters ...string) (boshaction.GetStateV1ApplySpec, error)
}

type TaskManager

type TaskManager interface {
	Ping() (string, error)
	GetTask(string) (interface{}, error)
	CancelTask(string) (string, error)
}

type VMAdministrator

type VMAdministrator interface {
	SSH(cmd string, params boshaction.SSHParams) (map[string]interface{}, error)
	FetchLogs(logType string, filters []string) (map[string]interface{}, error)
}

VMAdministrator provides administrative API for the agent todo eliminate remaining param names