Versions in this module Expand all Collapse all v0 v0.0.1 Apr 3, 2020 Changes in this version + type Client struct + Addr string + func New(addr string) (*Client, error) + func (c *Client) Checkpoints(jobID string) (checkpointsResp, error) + func (c *Client) Config() (configResp, error) + func (c *Client) DeleteJar(jarid string) error + func (c *Client) Jars() (jarsResp, error) + func (c *Client) Job(jobID string) (jobResp, error) + func (c *Client) JobManagerConfig() ([]kv, error) + func (c *Client) JobManagerMetrics() ([]metric, error) + func (c *Client) JobMetrics(opts JobMetricsOpts) (map[string]interface{}, error) + func (c *Client) Jobs() (jobsResp, error) + func (c *Client) JobsOverview() (overviewResp, error) + func (c *Client) PlanJar(jarid string) (planResp, error) + func (c *Client) RunJar(opts RunOpts) (runResp, error) + func (c *Client) SavePoints(jobID string, saveDir string, cancleJob bool) (savePointsResp, error) + func (c *Client) Shutdown() error + func (c *Client) StopJob(jobID string) error + func (c *Client) StopJobWithSavepoint(jobID string, saveDir string, drain bool) (stopJobResp, error) + func (c *Client) SubmitJob() error + func (c *Client) UploadJar(fpath string) (uploadResp, error) + type JobMetricsOpts struct + Agg []string + Jobs []string + Metrics []string + type RunOpts struct + AllowNonRestoredState bool + EntryClass string + JarID string + Parallelism int + ProgramArg []string + SavepointPath string
Go to main page