Versions in this module Expand all Collapse all v3 v3.1.2 Jul 27, 2022 Changes in this version + type BaseClient interface + AddRootCertificate func(pemFilePath string) + CreateConnector func(req CreateConnectorRequest) (ConnectorResponse, error) + DeleteConnector func(req ConnectorRequest) (EmptyResponse, error) + GetAll func() (GetAllConnectorsResponse, error) + GetAllTasks func(req ConnectorRequest) (GetAllTasksResponse, error) + GetConnector func(req ConnectorRequest) (ConnectorResponse, error) + GetConnectorConfig func(req ConnectorRequest) (GetConnectorConfigResponse, error) + GetConnectorStatus func(req ConnectorRequest) (GetConnectorStatusResponse, error) + GetTaskStatus func(req TaskRequest) (TaskStatusResponse, error) + PauseConnector func(req ConnectorRequest) (EmptyResponse, error) + RestartConnector func(req ConnectorRequest) (EmptyResponse, error) + RestartTask func(req TaskRequest) (EmptyResponse, error) + ResumeConnector func(req ConnectorRequest) (EmptyResponse, error) + SetBasicAuth func(username string, password string) + SetClientCertificates func(certs ...tls.Certificate) + SetDebug func() + SetHeader func(name string, value string) + SetInsecureSSL func() + UpdateConnector func(req CreateConnectorRequest) (ConnectorResponse, error) + type ConnectorRequest struct + Name string + type ConnectorResponse struct + Config map[string]interface{} + Name string + Tasks []TaskID + type CreateConnectorRequest struct + Config map[string]interface{} + type EmptyResponse struct + Code int + type ErrorResponse struct + ErrorCode int + Message string + func (err ErrorResponse) Error() string + type GetAllConnectorsResponse struct + Connectors []string + type GetAllTasksResponse struct + Code int + Tasks []TaskDetails + type GetConnectorConfigResponse struct + Config map[string]interface{} + type GetConnectorStatusResponse struct + ConnectorStatus map[string]string + Name string + TasksStatus []TaskStatus + type HighLevelClient interface + AddRootCertificate func(pemFilePath string) + CreateConnector func(req CreateConnectorRequest, sync bool) (ConnectorResponse, error) + DeleteConnector func(req ConnectorRequest, sync bool) (EmptyResponse, error) + DeployConnector func(req CreateConnectorRequest) (err error) + DeployMultipleConnector func(connectors []CreateConnectorRequest) (err error) + GetAll func() (GetAllConnectorsResponse, error) + GetAllTasks func(req ConnectorRequest) (GetAllTasksResponse, error) + GetConnector func(req ConnectorRequest) (ConnectorResponse, error) + GetConnectorConfig func(req ConnectorRequest) (GetConnectorConfigResponse, error) + GetConnectorStatus func(req ConnectorRequest) (GetConnectorStatusResponse, error) + GetTaskStatus func(req TaskRequest) (TaskStatusResponse, error) + IsUpToDate func(connector string, config map[string]interface{}) (bool, error) + PauseConnector func(req ConnectorRequest, sync bool) (EmptyResponse, error) + RestartConnector func(req ConnectorRequest) (EmptyResponse, error) + RestartTask func(req TaskRequest) (EmptyResponse, error) + ResumeConnector func(req ConnectorRequest, sync bool) (EmptyResponse, error) + SetBasicAuth func(username string, password string) + SetClientCertificates func(certs ...tls.Certificate) + SetDebug func() + SetHeader func(name string, value string) + SetInsecureSSL func() + SetParallelism func(value int) + UpdateConnector func(req CreateConnectorRequest, sync bool) (ConnectorResponse, error) + func NewClient(url string) HighLevelClient + type MockBaseClient struct + func (_m *MockBaseClient) AddRootCertificate(pemFilePath string) + func (_m *MockBaseClient) CreateConnector(req CreateConnectorRequest) (ConnectorResponse, error) + func (_m *MockBaseClient) DeleteConnector(req ConnectorRequest) (EmptyResponse, error) + func (_m *MockBaseClient) GetAll() (GetAllConnectorsResponse, error) + func (_m *MockBaseClient) GetAllTasks(req ConnectorRequest) (GetAllTasksResponse, error) + func (_m *MockBaseClient) GetConnector(req ConnectorRequest) (ConnectorResponse, error) + func (_m *MockBaseClient) GetConnectorConfig(req ConnectorRequest) (GetConnectorConfigResponse, error) + func (_m *MockBaseClient) GetConnectorStatus(req ConnectorRequest) (GetConnectorStatusResponse, error) + func (_m *MockBaseClient) GetTaskStatus(req TaskRequest) (TaskStatusResponse, error) + func (_m *MockBaseClient) PauseConnector(req ConnectorRequest) (EmptyResponse, error) + func (_m *MockBaseClient) RestartConnector(req ConnectorRequest) (EmptyResponse, error) + func (_m *MockBaseClient) RestartTask(req TaskRequest) (EmptyResponse, error) + func (_m *MockBaseClient) ResumeConnector(req ConnectorRequest) (EmptyResponse, error) + func (_m *MockBaseClient) SetBasicAuth(username string, password string) + func (_m *MockBaseClient) SetClientCertificates(certs ...tls.Certificate) + func (_m *MockBaseClient) SetDebug() + func (_m *MockBaseClient) SetHeader(name string, value string) + func (_m *MockBaseClient) SetInsecureSSL() + func (_m *MockBaseClient) UpdateConnector(req CreateConnectorRequest) (ConnectorResponse, error) + type MockHighLevelClient struct + func (_m *MockHighLevelClient) CreateConnector(req CreateConnectorRequest, sync bool) (ConnectorResponse, error) + func (_m *MockHighLevelClient) DeleteConnector(req ConnectorRequest, sync bool) (EmptyResponse, error) + func (_m *MockHighLevelClient) DeployConnector(req CreateConnectorRequest) error + func (_m *MockHighLevelClient) DeployMultipleConnector(connectors []CreateConnectorRequest) error + func (_m *MockHighLevelClient) GetAll() (GetAllConnectorsResponse, error) + func (_m *MockHighLevelClient) GetAllTasks(req ConnectorRequest) (GetAllTasksResponse, error) + func (_m *MockHighLevelClient) GetConnector(req ConnectorRequest) (ConnectorResponse, error) + func (_m *MockHighLevelClient) GetConnectorConfig(req ConnectorRequest) (GetConnectorConfigResponse, error) + func (_m *MockHighLevelClient) GetConnectorStatus(req ConnectorRequest) (GetConnectorStatusResponse, error) + func (_m *MockHighLevelClient) GetTaskStatus(req TaskRequest) (TaskStatusResponse, error) + func (_m *MockHighLevelClient) IsUpToDate(connector string, config map[string]interface{}) (bool, error) + func (_m *MockHighLevelClient) PauseConnector(req ConnectorRequest, sync bool) (EmptyResponse, error) + func (_m *MockHighLevelClient) RestartConnector(req ConnectorRequest) (EmptyResponse, error) + func (_m *MockHighLevelClient) RestartTask(req TaskRequest) (EmptyResponse, error) + func (_m *MockHighLevelClient) ResumeConnector(req ConnectorRequest, sync bool) (EmptyResponse, error) + func (_m *MockHighLevelClient) SetBasicAuth(username string, password string) + func (_m *MockHighLevelClient) SetClientCertificates(certs ...tls.Certificate) + func (_m *MockHighLevelClient) SetDebug() + func (_m *MockHighLevelClient) SetInsecureSSL() + func (_m *MockHighLevelClient) SetParallelism(value int) + func (_m *MockHighLevelClient) UpdateConnector(req CreateConnectorRequest, sync bool) (ConnectorResponse, error) + type TaskDetails struct + Config map[string]interface{} + ID TaskID + type TaskID struct + Connector string + TaskID int + type TaskRequest struct + Connector string + TaskID int + type TaskStatus struct + ID int + State string + Trace string + WorkerID string + type TaskStatusResponse struct + Code int + Status TaskStatus