Help us shape the future of Go! Take the 2026 Go Developer Survey

http

package
v2.905.0 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2026 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAgentClient 

func NewAgentClient(
	endpoint string,
	directorID string,
	getTaskDelay time.Duration,
	toleratedErrorCount int,
	httpClient *httpclient.HTTPClient,
	logger boshlog.Logger,
) agentclient.AgentClient

Types

type AgentClient 

type AgentClient struct {
	AgentRequest agentRequest
	// contains filtered or unexported fields
}

func (*AgentClient) AddPersistentDisk 

func (c *AgentClient) AddPersistentDisk(diskCID string, diskHints interface{}) error

func (*AgentClient) Apply 

func (c *AgentClient) Apply(spec applyspec.ApplySpec) error

func (*AgentClient) BundleLogs 

func (c *AgentClient) BundleLogs(owningUser string, logType string, filters []string) (agentclient.BundleLogsResult, error)

func (*AgentClient) CleanUpSSH 

func (c *AgentClient) CleanUpSSH(user string) (agentclient.SSHResult, error)

func (*AgentClient) CompilePackage 

func (c *AgentClient) CompilePackage(packageSource agentclient.BlobRef, compiledPackageDependencies []agentclient.BlobRef) (compiledPackageRef agentclient.BlobRef, err error)

func (*AgentClient) DeleteARPEntries 

func (c *AgentClient) DeleteARPEntries(ips []string) error

func (*AgentClient) Drain 

func (c *AgentClient) Drain(drainType string) (int64, error)

func (*AgentClient) GetState 

func (c *AgentClient) GetState() (agentclient.AgentState, error)

func (*AgentClient) ListDisk 

func (c *AgentClient) ListDisk() ([]string, error)

func (*AgentClient) MigrateDisk 

func (c *AgentClient) MigrateDisk() error

func (*AgentClient) MountDisk 

func (c *AgentClient) MountDisk(diskCID string) error

func (*AgentClient) Ping 

func (c *AgentClient) Ping() (string, error)

func (*AgentClient) RemoveFile 

func (c *AgentClient) RemoveFile(path string) error

func (*AgentClient) RemovePersistentDisk 

func (c *AgentClient) RemovePersistentDisk(diskCID string) error

func (*AgentClient) RunScript 

func (c *AgentClient) RunScript(scriptName string, options map[string]interface{}) error

func (*AgentClient) SendAsyncTaskMessage 

func (c *AgentClient) SendAsyncTaskMessage(method string, arguments []interface{}) (value interface{}, err error)

func (*AgentClient) SetUpSSH 

func (c *AgentClient) SetUpSSH(user string, publicKey string) (agentclient.SSHResult, error)

func (*AgentClient) Start 

func (c *AgentClient) Start() error

func (*AgentClient) Stop 

func (c *AgentClient) Stop() error

func (*AgentClient) SyncDNS 

func (c *AgentClient) SyncDNS(blobID, sha1 string, version uint64) (string, error)

func (*AgentClient) UnmountDisk 

func (c *AgentClient) UnmountDisk(diskCID string) error

type AgentClientFactory 

type AgentClientFactory interface {
	NewAgentClient(directorID, mbusURL, caCert string) (agentclient.AgentClient, error)
}

func NewAgentClientFactory 

func NewAgentClientFactory(
	getTaskDelay time.Duration,
	logger boshlog.Logger,
) AgentClientFactory

type AgentRequestMessage 

type AgentRequestMessage struct {
	Method    string        `json:"method"`
	Arguments []interface{} `json:"arguments"`
	ReplyTo   string        `json:"reply_to"`
}

type AgentState 

type AgentState struct {
	JobState     string                             `json:"job_state"`
	NetworkSpecs map[string]agentclient.NetworkSpec `json:"networks"`
}

type BlobRef 

type BlobRef struct {
	Name        string `json:"name"`
	Version     string `json:"version"`
	SHA1        string `json:"sha1"`
	BlobstoreID string `json:"blobstore_id"`
}

type BlobResponse 

type BlobResponse struct {
	Value     map[string]string
	Exception *exception
}

func (*BlobResponse) ServerError 

func (r *BlobResponse) ServerError() error

func (*BlobResponse) Unmarshal 

func (r *BlobResponse) Unmarshal(message []byte) error

type BundleLogsResponse 

type BundleLogsResponse struct {
	Value     BundleLogsState
	Exception *exception
}

func (*BundleLogsResponse) ServerError 

func (r *BundleLogsResponse) ServerError() error

func (*BundleLogsResponse) Unmarshal 

func (r *BundleLogsResponse) Unmarshal(message []byte) error

type BundleLogsState 

type BundleLogsState struct {
	LogsTarPath  string `json:"logs_tar_path"`
	SHA512Digest string `json:"sha512"`
}

type ListResponse 

type ListResponse struct {
	Value     []string
	Exception *exception
}

func (*ListResponse) ServerError 

func (r *ListResponse) ServerError() error

func (*ListResponse) Unmarshal 

func (r *ListResponse) Unmarshal(message []byte) error

type Response 

type Response interface {
	Unmarshal([]byte) error
	ServerError() error
}

type SSHResponse 

type SSHResponse struct {
	Value     SSHState
	Exception *exception
}

func (*SSHResponse) ServerError 

func (r *SSHResponse) ServerError() error

func (*SSHResponse) Unmarshal 

func (r *SSHResponse) Unmarshal(message []byte) error

type SSHState 

type SSHState struct {
	Command       string `json:"command"`
	Status        string `json:"status"`
	Ip            string `json:"ip"`
	HostPublicKey string `json:"host_public_key"`
}

type SimpleTaskResponse 

type SimpleTaskResponse struct {
	Value     string
	Exception *exception
}

func (*SimpleTaskResponse) ServerError 

func (r *SimpleTaskResponse) ServerError() error

func (*SimpleTaskResponse) Unmarshal 

func (r *SimpleTaskResponse) Unmarshal(message []byte) error

type StateResponse 

type StateResponse struct {
	Value     AgentState
	Exception *exception
}

func (*StateResponse) ServerError 

func (r *StateResponse) ServerError() error

func (*StateResponse) Unmarshal 

func (r *StateResponse) Unmarshal(message []byte) error

type SyncDNSResponse 

type SyncDNSResponse struct {
	Value     string
	Exception *exception
}

func (*SyncDNSResponse) ServerError 

func (r *SyncDNSResponse) ServerError() error

func (*SyncDNSResponse) Unmarshal 

func (r *SyncDNSResponse) Unmarshal(message []byte) error

type TaskResponse 

type TaskResponse struct {
	Value     interface{}
	Exception *exception
}

func (*TaskResponse) ServerError 

func (r *TaskResponse) ServerError() error

func (*TaskResponse) TaskID 

func (r *TaskResponse) TaskID() (string, error)

func (*TaskResponse) TaskState 

func (r *TaskResponse) TaskState() (string, error)

TaskState returns the state of the task reported by agent.

Agent response to get_task can be in different format based on task state. If task state is running agent responds with value as {value: { agent_task_id: "task-id", state: "running" }} Otherwise the value is a string like "stopped".

func (*TaskResponse) Unmarshal 

func (r *TaskResponse) Unmarshal(message []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.