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

http

package
v0.0.59 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2017 License: Apache-2.0 Imports: 14 Imported by: 129

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) Apply 

func (c *AgentClient) Apply(spec applyspec.ApplySpec) 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) 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) RunScript 

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

func (*AgentClient) SendAsyncTaskMessage 

func (c *AgentClient) SendAsyncTaskMessage(method string, arguments []interface{}) (value map[string]interface{}, err 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 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 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

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.