http

Documentation

Index

• func NewAgentClient(endpoint string, directorID string, getTaskDelay time.Duration, ...) biagentclient.AgentClient
• type AgentClientFactory
  • func NewAgentClientFactory(getTaskDelay time.Duration, logger boshlog.Logger) AgentClientFactory
• type AgentRequestMessage
• type AgentState
• type BlobRef
• type BlobResponse
  • func (r *BlobResponse) ServerError() error
  • func (r *BlobResponse) Unmarshal(message []byte) error
• type ListResponse
  • func (r *ListResponse) ServerError() error
  • func (r *ListResponse) Unmarshal(message []byte) error
• type Response
• type SimpleTaskResponse
  • func (r *SimpleTaskResponse) ServerError() error
  • func (r *SimpleTaskResponse) Unmarshal(message []byte) error
• type StateResponse
  • func (r *StateResponse) ServerError() error
  • func (r *StateResponse) Unmarshal(message []byte) error
• type TaskResponse
  • func (r *TaskResponse) ServerError() error
  • func (r *TaskResponse) TaskID() (string, error)
  • func (r *TaskResponse) TaskState() (string, error)
  • func (r *TaskResponse) Unmarshal(message []byte) error

Functions

func NewAgentClient

func NewAgentClient(
	endpoint string,
	directorID string,
	getTaskDelay time.Duration,
	httpClient bihttpclient.HTTPClient,
	logger boshlog.Logger,
) biagentclient.AgentClient

Types

type AgentClientFactory

type AgentClientFactory interface {
	NewAgentClient(directorID, mbusURL string) biagentclient.AgentClient
}

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"`
}

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 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 { 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