client

Documentation

Index

• type StreamcomputerClient
  • func NewStreamcomputerClient(credential *core.Credential) *StreamcomputerClient
  • func (c *StreamcomputerClient) AddOrUpdateJob(request *streamcomputer.AddOrUpdateJobRequest) (*streamcomputer.AddOrUpdateJobResponse, error)
  • func (c *StreamcomputerClient) AddOrUpdateStorage(request *streamcomputer.AddOrUpdateStorageRequest) (*streamcomputer.AddOrUpdateStorageResponse, error)
  • func (c *StreamcomputerClient) CreateNamespace(request *streamcomputer.CreateNamespaceRequest) (*streamcomputer.CreateNamespaceResponse, error)
  • func (c *StreamcomputerClient) DeleteJob(request *streamcomputer.DeleteJobRequest) (*streamcomputer.DeleteJobResponse, error)
  • func (c *StreamcomputerClient) DeleteNamespace(request *streamcomputer.DeleteNamespaceRequest) (*streamcomputer.DeleteNamespaceResponse, error)
  • func (c *StreamcomputerClient) DeleteStorage(request *streamcomputer.DeleteStorageRequest) (*streamcomputer.DeleteStorageResponse, error)
  • func (c *StreamcomputerClient) DescribeJob(request *streamcomputer.DescribeJobRequest) (*streamcomputer.DescribeJobResponse, error)
  • func (c *StreamcomputerClient) DescribeStorage(request *streamcomputer.DescribeStorageRequest) (*streamcomputer.DescribeStorageResponse, error)
  • func (c *StreamcomputerClient) GetJobList(request *streamcomputer.GetJobListRequest) (*streamcomputer.GetJobListResponse, error)
  • func (c *StreamcomputerClient) GetStorageList(request *streamcomputer.GetStorageListRequest) (*streamcomputer.GetStorageListResponse, error)
  • func (c *StreamcomputerClient) QueryNamespaceDetail(request *streamcomputer.QueryNamespaceDetailRequest) (*streamcomputer.QueryNamespaceDetailResponse, error)
  • func (c *StreamcomputerClient) QueryNamespaces(request *streamcomputer.QueryNamespacesRequest) (*streamcomputer.QueryNamespacesResponse, error)
  • func (c *StreamcomputerClient) SetConfig(config *core.Config)
  • func (c *StreamcomputerClient) SetLogger(logger core.Logger)
  • func (c *StreamcomputerClient) StartJob(request *streamcomputer.StartJobRequest) (*streamcomputer.StartJobResponse, error)
  • func (c *StreamcomputerClient) StopJob(request *streamcomputer.StopJobRequest) (*streamcomputer.StopJobResponse, error)
  • func (c *StreamcomputerClient) UpdateNamespace(request *streamcomputer.UpdateNamespaceRequest) (*streamcomputer.UpdateNamespaceResponse, error)

Types

type StreamcomputerClient

type StreamcomputerClient struct {
	core.JDCloudClient
}

func NewStreamcomputerClient

func NewStreamcomputerClient(credential *core.Credential) *StreamcomputerClient

func (*StreamcomputerClient) AddOrUpdateJob

func (c *StreamcomputerClient) AddOrUpdateJob(request *streamcomputer.AddOrUpdateJobRequest) (*streamcomputer.AddOrUpdateJobResponse, error)

添加或者更新job

func (*StreamcomputerClient) AddOrUpdateStorage

func (c *StreamcomputerClient) AddOrUpdateStorage(request *streamcomputer.AddOrUpdateStorageRequest) (*streamcomputer.AddOrUpdateStorageResponse, error)

创建或者更新storage

func (*StreamcomputerClient) CreateNamespace

func (c *StreamcomputerClient) CreateNamespace(request *streamcomputer.CreateNamespaceRequest) (*streamcomputer.CreateNamespaceResponse, error)

创建namespace

func (*StreamcomputerClient) DeleteJob

func (c *StreamcomputerClient) DeleteJob(request *streamcomputer.DeleteJobRequest) (*streamcomputer.DeleteJobResponse, error)

删除作业

func (*StreamcomputerClient) DeleteNamespace

func (c *StreamcomputerClient) DeleteNamespace(request *streamcomputer.DeleteNamespaceRequest) (*streamcomputer.DeleteNamespaceResponse, error)

删除namespace,如果旗下关联有其他资源，不允许删除

func (*StreamcomputerClient) DeleteStorage

func (c *StreamcomputerClient) DeleteStorage(request *streamcomputer.DeleteStorageRequest) (*streamcomputer.DeleteStorageResponse, error)

删除指定输入

func (*StreamcomputerClient) DescribeJob

func (c *StreamcomputerClient) DescribeJob(request *streamcomputer.DescribeJobRequest) (*streamcomputer.DescribeJobResponse, error)

查询指定作业详情

func (*StreamcomputerClient) DescribeStorage

func (c *StreamcomputerClient) DescribeStorage(request *streamcomputer.DescribeStorageRequest) (*streamcomputer.DescribeStorageResponse, error)

查询指定输入

func (*StreamcomputerClient) GetJobList

func (c *StreamcomputerClient) GetJobList(request *streamcomputer.GetJobListRequest) (*streamcomputer.GetJobListResponse, error)

查询指定应用下的所有job

func (*StreamcomputerClient) GetStorageList

func (c *StreamcomputerClient) GetStorageList(request *streamcomputer.GetStorageListRequest) (*streamcomputer.GetStorageListResponse, error)

创建或者更新storage

func (*StreamcomputerClient) QueryNamespaceDetail

func (c *StreamcomputerClient) QueryNamespaceDetail(request *streamcomputer.QueryNamespaceDetailRequest) (*streamcomputer.QueryNamespaceDetailResponse, error)

查询某个应用详情

func (*StreamcomputerClient) QueryNamespaces

func (c *StreamcomputerClient) QueryNamespaces(request *streamcomputer.QueryNamespacesRequest) (*streamcomputer.QueryNamespacesResponse, error)

查询租户下的应用列表

func (*StreamcomputerClient) SetConfig

func (c *StreamcomputerClient) SetConfig(config *core.Config)

func (*StreamcomputerClient) SetLogger

func (c *StreamcomputerClient) SetLogger(logger core.Logger)

func (*StreamcomputerClient) StartJob

func (c *StreamcomputerClient) StartJob(request *streamcomputer.StartJobRequest) (*streamcomputer.StartJobResponse, error)

运行job

func (*StreamcomputerClient) StopJob

func (c *StreamcomputerClient) StopJob(request *streamcomputer.StopJobRequest) (*streamcomputer.StopJobResponse, error)

停止作业运行job

func (*StreamcomputerClient) UpdateNamespace

func (c *StreamcomputerClient) UpdateNamespace(request *streamcomputer.UpdateNamespaceRequest) (*streamcomputer.UpdateNamespaceResponse, error)

更新namespace