Integration Studio

Connector Reference

All 15+ built-in connector types with auth configuration, every available operation, and payload schemas.

Connector Anatomy

A connector has two parts: config (credentials, base URL, auth method) stored once and encrypted, and operations (actions and triggers) that use that config at runtime. Operations are available as workflow action nodes.

rest_api — Generic REST

Connect to any REST API that isn't covered by a named connector.

FieldTypeRequiredDefaultDescription
baseUrlstringrequiredBase URL prepended to all operation paths.
authTypeenumrequirednone · bearer · api_key · basic · oauth2_client_credentials · oauth2_authorization_code · custom_header
tokenstringoptionalFor authType=bearer: the Bearer token value.
apiKeystringoptionalFor authType=api_key: the API key value.
apiKeyHeaderstringoptionalX-API-KeyHeader name for the API key.
usernamestringoptionalFor authType=basic: username.
passwordstringoptionalFor authType=basic: password.
headersobjectoptionalDefault headers added to every request from this connector.
tlsVerifybooleanoptionaltrueVerify TLS certificate. Set to false for self-signed certs in dev only.
timeoutintegeroptional30000Request timeout in ms.

Operations

  • request — Make a single HTTP request: { method, path, headers, queryParams, body }
  • paginate — Make paginated requests and collect all pages: { method, path, pageParam, pageSize, dataPath }

slack

FieldTypeRequiredDefaultDescription
tokenstringrequiredSlack Bot User OAuth Token (xoxb-...). Bot must be in the target channels.

Operations

OperationKey InputsKey Outputs
postMessagechannel, text, blocks?, attachments?messageId, timestamp, channel
updateMessagechannel, timestamp, text, blocks?messageId
deleteMessagechannel, timestampok
addReactionchannel, timestamp, nameok
uploadFilechannels, filename, content, comment?fileId, permalink
getUseremail or userIduserId, name, email, status
listChannelstypes?, cursor?, limit?channels[], nextCursor
createChannelname, isPrivate?channelId, name
inviteToChannelchannel, users[]ok
sendDMuserId, text, blocks?messageId

jira

FieldTypeRequiredDefaultDescription
baseUrlstringrequiredYour Jira Cloud URL: https://yourcompany.atlassian.net
emailstringrequiredAtlassian account email for the API token user.
apiTokenstringrequiredAtlassian API token (manage at id.atlassian.com).

Operations

  • createIssue{ project, summary, issueType, priority?, description?, assignee?, labels?, customFields? }{ issueId, issueKey, url }
  • updateIssue{ issueKey, fields }
  • transitionIssue{ issueKey, transitionId, comment? }
  • addComment{ issueKey, body }{ commentId }
  • getIssue{ issueKey, expand? } → full issue object
  • searchIssues{ jql, fields?, maxResults? } → issues array
  • createSprint{ boardId, name, startDate, endDate }
  • getUser{ email or accountId }
  • listProjects — → projects array
  • uploadAttachment{ issueKey, filename, content }

github

FieldTypeRequiredDefaultDescription
tokenstringrequiredGitHub Personal Access Token or GitHub App installation token.
orgstringoptionalDefault organisation/owner. Can be overridden per operation.

Operations

  • createIssue{ owner, repo, title, body?, labels?, assignees? }
  • updateIssue{ owner, repo, number, state?, title?, body? }
  • createPR{ owner, repo, title, head, base, body? }
  • mergePR{ owner, repo, number, mergeMethod? }
  • createDeployment{ owner, repo, ref, environment, payload? }
  • updateDeploymentStatus{ owner, repo, deploymentId, state, logUrl? }
  • triggerWorkflow{ owner, repo, workflowId, ref, inputs? }
  • createComment{ owner, repo, issueNumber, body }
  • searchCode{ query, page? }
  • listRepos{ org?, type?, sort? }

pagerduty

FieldTypeRequiredDefaultDescription
apiKeystringrequiredPagerDuty REST API key (v2).
eventsApiKeystringoptionalPagerDuty Events API v2 integration key (for event triggering).

Operations

  • triggerAlert{ routingKey, summary, source, severity, payload? }{ dedupKey }
  • resolveAlert{ routingKey, dedupKey }
  • acknowledgeAlert{ routingKey, dedupKey }
  • createIncident{ title, serviceId, urgency?, body?, escalationPolicy? }
  • updateIncident{ incidentId, status?, title?, assignments? }
  • getOnCall{ scheduleId } → current on-call user
  • listSchedules — → schedules array
  • listServices — → services array
  • snoozeIncident{ incidentId, duration }

aws

FieldTypeRequiredDefaultDescription
accessKeyIdstringrequiredAWS Access Key ID.
secretAccessKeystringrequiredAWS Secret Access Key.
regionstringrequiredDefault AWS region (e.g. us-east-1).
sessionTokenstringoptionalTemporary session token for assumed roles.

Operations (EC2, S3, CloudWatch, SNS, SQS, Lambda)

  • ec2.describeInstances / ec2.startInstances / ec2.stopInstances
  • s3.putObject / s3.getObject / s3.listObjects / s3.deleteObject
  • cloudwatch.putMetricData / cloudwatch.getMetricData / cloudwatch.describeAlarms
  • sns.publish{ topicArn, message, subject?, attributes? }
  • sqs.sendMessage / sqs.receiveMessage / sqs.deleteMessage
  • lambda.invoke{ functionName, payload, invocationType? }
  • secretsManager.getSecret / secretsManager.putSecret

postgres / mysql

FieldTypeRequiredDefaultDescription
hoststringrequiredDatabase hostname or IP.
portintegeroptional5432/3306Port number.
databasestringrequiredDatabase name.
usernamestringrequiredDatabase username.
passwordstringrequiredDatabase password.
sslbooleanoptionaltrueRequire SSL connection.
sslCertstringoptionalPEM-encoded client certificate for mTLS.

Operations

  • query{ sql, parameters? }{ rows, rowCount }. Read and write SQL.
  • execute{ sql, parameters? }{ rowsAffected }. Mutations without returning rows.
  • transaction{ statements: [{ sql, parameters }] }. Runs in a transaction; rolls back on error.

okta

FieldTypeRequiredDefaultDescription
domainstringrequiredOkta domain: https://yourorg.okta.com
apiTokenstringrequiredOkta SSWS API token.

Operations

  • getUser / createUser / updateUser / deactivateUser / deleteUser
  • addUserToGroup / removeUserFromGroup / listUserGroups
  • assignAppToUser / removeAppFromUser
  • sendResetPasswordEmail{ login }
  • listUsers{ filter?, search?, limit? }

smtp

FieldTypeRequiredDefaultDescription
hoststringrequiredSMTP server hostname.
portintegeroptional587SMTP port (587 for STARTTLS, 465 for SSL, 25 for unencrypted).
securebooleanoptionaltrueUse TLS.
usernamestringoptionalSMTP auth username.
passwordstringoptionalSMTP auth password.
fromEmailstringrequiredDefault from address.
fromNamestringoptionalDefault from display name.

Operations

  • sendEmail{ to, cc?, bcc?, replyTo?, subject, text?, html?, attachments? }{ messageId, accepted }
  • sendTemplate{ to, templateId, variables, subject? } (uses Email Studio templates)

salesforce

FieldTypeRequiredDefaultDescription
instanceUrlstringrequiredYour Salesforce instance URL: https://yourorg.salesforce.com
clientIdstringrequiredConnected App consumer key.
clientSecretstringrequiredConnected App consumer secret.
refreshTokenstringrequiredOAuth 2.0 refresh token from initial authorization.

Operations

  • createRecord / updateRecord / deleteRecord / getRecord{ objectType, ... }
  • query{ soql } → records array
  • search{ sosl } → records array
  • bulkCreate / bulkUpdate — up to 10,000 records via Bulk API 2.0

graphql

FieldTypeRequiredDefaultDescription
endpointstringrequiredGraphQL API endpoint URL.
headersobjectoptionalAuth and other default headers.
wsEndpointstringoptionalWebSocket endpoint for subscription support.

Operations

  • query{ query, variables? }{ data, errors? }
  • mutate{ mutation, variables? }{ data, errors? }

webhook (outbound)

Send outbound HTTP payloads to any URL, with retry logic and optional HMAC signing.

FieldTypeRequiredDefaultDescription
urlstringrequiredTarget URL.
methodenumoptionalPOSTHTTP method.
secretstringoptionalHMAC secret. If set, adds X-Signature-256 header.
headersobjectoptionalDefault headers.
retriesintegeroptional3Number of retry attempts on failure.
timeoutMsintegeroptional10000Request timeout.

Operations

  • send{ body, headers?, method? }{ status, responseBody, durationMs }