replication

Documentation

Index

• type Client
  • func New(c HTTPClient) *Client
  • func (c *Client) Find(ctx context.Context, req *FindRequest) (*FindResponse, error)
  • func (c *Client) Index(ctx context.Context, req *IndexRequest) (*IndexResponse, error)
  • func (c *Client) JobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)
  • func (c *Client) ReadJobLog(ctx context.Context, req *ReadJobLogRequest) (*ReadJobLogResponse, error)
  • func (c *Client) ScheduleNow(ctx context.Context, req *ScheduleNowRequest) (*ScheduleNowResponse, error)
• type FindRequest
• type FindResponse
• type HTTPClient
• type IndexRequest
• type IndexResponse
• type JobStatusRequest
• type JobStatusResponse
• type ReadJobLogRequest
• type ReadJobLogResponse
• type ScheduleNowRequest
• type ScheduleNowResponse

Types

type Client

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

func New

func New(c HTTPClient) *Client

func (*Client) Find

func (c *Client) Find(ctx context.Context, req *FindRequest) (*FindResponse, error)

Find Directory index.

func (*Client) Index

func (c *Client) Index(ctx context.Context, req *IndexRequest) (*IndexResponse, error)

Index List status of all replication jobs on this node.

func (*Client) JobStatus

func (c *Client) JobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)

JobStatus Get replication job status.

func (*Client) ReadJobLog

func (c *Client) ReadJobLog(ctx context.Context, req *ReadJobLogRequest) (*ReadJobLogResponse, error)

ReadJobLog Read replication job log.

func (*Client) ScheduleNow

func (c *Client) ScheduleNow(ctx context.Context, req *ScheduleNowRequest) (*ScheduleNowResponse, error)

ScheduleNow Schedule replication job to start as soon as possible.

type FindRequest

type FindRequest struct {
	Id   string `url:"id",json:"id"`     // Replication Job ID. The ID is composed of a Guest ID and a job number, separated by a hyphen, i.e. '<GUEST>-<JOBNUM>'.
	Node string `url:"node",json:"node"` // The cluster node name.

}

type FindResponse

type FindResponse []*map[string]interface{}

type HTTPClient

type HTTPClient interface {
	Do(context.Context, string, string, interface{}, interface{}) error
}

type IndexRequest

type IndexRequest struct {
	Node string `url:"node",json:"node"` // The cluster node name.

	// The following parameters are optional
	Guest *int `url:"guest,omitempty",json:"guest,omitempty"` // Only list replication jobs for this guest.
}

type IndexResponse

type IndexResponse []*struct {
	Id string `url:"id",json:"id"`
}

type JobStatusRequest

type JobStatusRequest struct {
	Id   string `url:"id",json:"id"`     // Replication Job ID. The ID is composed of a Guest ID and a job number, separated by a hyphen, i.e. '<GUEST>-<JOBNUM>'.
	Node string `url:"node",json:"node"` // The cluster node name.

}

type JobStatusResponse

type JobStatusResponse map[string]interface{}

type ReadJobLogRequest

type ReadJobLogRequest struct {
	Id   string `url:"id",json:"id"`     // Replication Job ID. The ID is composed of a Guest ID and a job number, separated by a hyphen, i.e. '<GUEST>-<JOBNUM>'.
	Node string `url:"node",json:"node"` // The cluster node name.

	// The following parameters are optional
	Limit *int `url:"limit,omitempty",json:"limit,omitempty"`
	Start *int `url:"start,omitempty",json:"start,omitempty"`
}

type ReadJobLogResponse

type ReadJobLogResponse []*struct {
	N int    `url:"n",json:"n"` // Line number
	T string `url:"t",json:"t"` // Line text

}

type ScheduleNowRequest

type ScheduleNowRequest struct {
	Id   string `url:"id",json:"id"`     // Replication Job ID. The ID is composed of a Guest ID and a job number, separated by a hyphen, i.e. '<GUEST>-<JOBNUM>'.
	Node string `url:"node",json:"node"` // The cluster node name.

}

type ScheduleNowResponse

type ScheduleNowResponse string