The highest tagged major version is
Documentation
¶
Index ¶
- func NewAgentClient(endpoint string, directorID string, getTaskDelay time.Duration, ...) agentclient.AgentClient
- type AgentClientFactory
- type AgentRequestMessage
- type AgentState
- type BlobRef
- type BlobResponse
- type ListResponse
- type Response
- type SSHResponse
- type SimpleTaskResponse
- type StateResponse
- type SyncDNSResponse
- type TaskResponse
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 AgentClientFactory ¶
type AgentClientFactory interface {
NewAgentClient(directorID, mbusURL string) agentclient.AgentClient
}
func NewAgentClientFactory ¶
func NewAgentClientFactory( getTaskDelay time.Duration, logger boshlog.Logger, ) AgentClientFactory
type AgentRequestMessage ¶
type AgentState ¶
type AgentState struct {
JobState string `json:"job_state"`
NetworkSpecs map[string]agentclient.NetworkSpec `json:"networks"`
}
type BlobResponse ¶
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 SSHResponse ¶ added in v0.0.24
func (*SSHResponse) ServerError ¶ added in v0.0.24
func (r *SSHResponse) ServerError() error
func (*SSHResponse) Unmarshal ¶ added in v0.0.24
func (r *SSHResponse) Unmarshal(message []byte) 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
¶
Directories
Click to show internal directories.
Click to hide internal directories.