DeltaStream GraphQL API
DeltaStream GraphQL API
API Endpoints
Copy https://api.deltastream.io/query
Headers
Copy Authorization: Bearer <YOUR_TOKEN_HERE>
Queries
apiTokens
Response
Returns [
APIToken!]!
Arguments
Example
Query
Copy query ApiTokens ($organizationId: UUID ! ) {
apiTokens(organizationId: $organizationId) {
name
lastUsed
createdAt
}
}
Variables
Copy {
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"apiTokens" : [{ "name" : 4 , "lastUsed" : 1592577642 , "createdAt" : 1592577642 }]
}
}
availabilityZones
Response
Returns [AvailabilityZone!]!
Example
Query
Copy query AvailabilityZones {
availabilityZones {
name
longName
}
}
Response
Copy {
"data" : {
"availabilityZones" : [
{
"name" : "abc123" ,
"longName" : "xyz789"
}
]
}
}
changelogs
Response
Returns [Relation!]!
Arguments
Example
Query
Copy query Changelogs (
$organizationId: UUID ! ,
$databaseName: ID ! ,
$schemaName: ID !
) {
changelogs(
organizationId: $organizationId,
databaseName: $databaseName,
schemaName: $schemaName
) {
name
schema {
name
database {
... DatabaseFragment
}
relations {
... RelationFragment
}
relation {
... RelationFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
columns {
name
dataType
}
primaryKey
metadata {
value {
... MapEntryFragment
}
}
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"databaseName" : 4 ,
"schemaName" : "4"
}
Response
Copy {
"data" : {
"changelogs" : [
{
"name" : "4" ,
"schema" : Schema ,
"columns" : [Column] ,
"primaryKey" : [ "abc123" ] ,
"metadata" : Map ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
]
}
}
connector
Response
Returns a Connector!
Arguments
Example
Query
Copy query Connector (
$name: String ! ,
$organizationId: UUID !
) {
connector(
name: $name,
organizationId: $organizationId
) {
name
type
sourceRelation {
name
schema {
... SchemaFragment
}
columns {
... ColumnFragment
}
primaryKey
metadata {
... MapFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
sinkStore {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
sender
destinations
template
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"name" : "abc123" ,
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"connector" : {
"name" : "4" ,
"type" : "Notification" ,
"sourceRelation" : Relation ,
"sinkStore" : Store ,
"sender" : "xyz789" ,
"destinations" : [ "xyz789" ] ,
"template" : "xyz789" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
}
}
connectors
Response
Returns [Connector!]!
Arguments
Example
Query
Copy query Connectors ($organizationId: UUID ! ) {
connectors(organizationId: $organizationId) {
name
type
sourceRelation {
name
schema {
... SchemaFragment
}
columns {
... ColumnFragment
}
primaryKey
metadata {
... MapFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
sinkStore {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
sender
destinations
template
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"connectors" : [
{
"name" : 4 ,
"type" : "Notification" ,
"sourceRelation" : Relation ,
"sinkStore" : Store ,
"sender" : "abc123" ,
"destinations" : [ "abc123" ] ,
"template" : "xyz789" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
]
}
}
descriptorSource
Response
Returns a DescriptorSource!
Arguments
Example
Query
Copy query DescriptorSource (
$name: String ! ,
$orgID: UUID !
) {
descriptorSource(
name: $name,
orgID: $orgID
) {
name
tags
type
org {
connectors {
... ConnectorFragment
}
invitations {
... InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
... RoleFragment
}
members {
... MemberFragment
}
member {
... MemberFragment
}
database {
... DatabaseFragment
}
databases {
... DatabaseFragment
}
defaultDatabase {
... DatabaseFragment
}
schemaRegistries {
... SchemaRegistryFragment
}
query {
... QueryFragment
}
queries {
... QueryFragment
}
topicDescriptor {
... TopicDescriptorFragment
}
topicDescriptors {
... TopicDescriptorFragment
}
sandbox {
... SandboxFragment
}
role {
... RoleFragment
}
roles {
... RoleFragment
}
defaultRole {
... RoleFragment
}
store {
... StoreFragment
}
stores {
... StoreFragment
}
defaultStore {
... StoreFragment
}
}
descriptors {
id
name
source {
... DescriptorSourceFragment
}
}
url
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"name" : "abc123" ,
"orgID" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"descriptorSource" : {
"name" : "abc123" ,
"tags" : [ "abc123" ] ,
"type" : "PB_DESCRIPTOR" ,
"org" : Organization ,
"descriptors" : [Descriptor] ,
"url" : "abc123" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
}
}
descriptorSources
Response
Returns [DescriptorSource!]!
Arguments
Example
Query
Copy query DescriptorSources ($orgID: UUID ! ) {
descriptorSources(orgID: $orgID) {
name
tags
type
org {
connectors {
... ConnectorFragment
}
invitations {
... InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
... RoleFragment
}
members {
... MemberFragment
}
member {
... MemberFragment
}
database {
... DatabaseFragment
}
databases {
... DatabaseFragment
}
defaultDatabase {
... DatabaseFragment
}
schemaRegistries {
... SchemaRegistryFragment
}
query {
... QueryFragment
}
queries {
... QueryFragment
}
topicDescriptor {
... TopicDescriptorFragment
}
topicDescriptors {
... TopicDescriptorFragment
}
sandbox {
... SandboxFragment
}
role {
... RoleFragment
}
roles {
... RoleFragment
}
defaultRole {
... RoleFragment
}
store {
... StoreFragment
}
stores {
... StoreFragment
}
defaultStore {
... StoreFragment
}
}
descriptors {
id
name
source {
... DescriptorSourceFragment
}
}
url
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"orgID" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"descriptorSources" : [
{
"name" : "xyz789" ,
"tags" : [ "abc123" ] ,
"type" : "PB_DESCRIPTOR" ,
"org" : Organization ,
"descriptors" : [Descriptor] ,
"url" : "abc123" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
]
}
}
functionSource
Response
Returns a FunctionSource!
Arguments
Example
Query
Copy query FunctionSource (
$name: String ! ,
$orgID: UUID !
) {
functionSource(
name: $name,
orgID: $orgID
) {
name
description
url
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"name" : "xyz789" ,
"orgID" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"functionSource" : {
"name" : "xyz789" ,
"description" : "xyz789" ,
"url" : "abc123" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
}
}
functionSources
Response
Returns [FunctionSource!]!
Arguments
Example
Query
Copy query FunctionSources ($orgID: UUID ! ) {
functionSources(orgID: $orgID) {
name
description
url
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"orgID" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"functionSources" : [
{
"name" : "xyz789" ,
"description" : "abc123" ,
"url" : "xyz789" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
]
}
}
functions
Response
Returns [Function!]!
Arguments
Example
Query
Copy query Functions ($orgID: UUID ! ) {
functions(orgID: $orgID) {
org {
connectors {
... ConnectorFragment
}
invitations {
... InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
... RoleFragment
}
members {
... MemberFragment
}
member {
... MemberFragment
}
database {
... DatabaseFragment
}
databases {
... DatabaseFragment
}
defaultDatabase {
... DatabaseFragment
}
schemaRegistries {
... SchemaRegistryFragment
}
query {
... QueryFragment
}
queries {
... QueryFragment
}
topicDescriptor {
... TopicDescriptorFragment
}
topicDescriptors {
... TopicDescriptorFragment
}
sandbox {
... SandboxFragment
}
role {
... RoleFragment
}
roles {
... RoleFragment
}
defaultRole {
... RoleFragment
}
store {
... StoreFragment
}
stores {
... StoreFragment
}
defaultStore {
... StoreFragment
}
}
name
type
inputs {
name
type
}
outputType
source {
name
description
url
createdAt
updatedAt
owner {
... RoleFragment
}
}
className
signature
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"orgID" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"functions" : [
{
"org" : Organization ,
"name" : "abc123" ,
"type" : "UDF" ,
"inputs" : [Parameter] ,
"outputType" : "abc123" ,
"source" : FunctionSource ,
"className" : "xyz789" ,
"signature" : "xyz789" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
]
}
}
invitations
Response
Returns [Invitation!]!
Arguments
Example
Query
Copy query Invitations (
$organizationId: UUID ! ,
$state: InvitationState !
) {
invitations(
organizationId: $organizationId,
state: $state
) {
organization {
connectors {
... ConnectorFragment
}
invitations {
... InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
... RoleFragment
}
members {
... MemberFragment
}
member {
... MemberFragment
}
database {
... DatabaseFragment
}
databases {
... DatabaseFragment
}
defaultDatabase {
... DatabaseFragment
}
schemaRegistries {
... SchemaRegistryFragment
}
query {
... QueryFragment
}
queries {
... QueryFragment
}
topicDescriptor {
... TopicDescriptorFragment
}
topicDescriptors {
... TopicDescriptorFragment
}
sandbox {
... SandboxFragment
}
role {
... RoleFragment
}
roles {
... RoleFragment
}
defaultRole {
... RoleFragment
}
store {
... StoreFragment
}
stores {
... StoreFragment
}
defaultStore {
... StoreFragment
}
}
id
invitedUserEmail
invitedBy {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
userRole {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
defaultRole {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
additionalRoles {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
invitationState
}
}
Variables
Copy {
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"state" : "PENDING"
}
Response
Copy {
"data" : {
"invitations" : [
{
"organization" : Organization ,
"id" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"invitedUserEmail" : "xyz789" ,
"invitedBy" : Role ,
"userRole" : Role ,
"defaultRole" : Role ,
"additionalRoles" : [Role] ,
"invitationState" : "PENDING"
}
]
}
}
materializedViews
Response
Returns [Relation!]!
Arguments
Example
Query
Copy query MaterializedViews (
$organizationId: UUID ! ,
$databaseName: ID ! ,
$schemaName: ID !
) {
materializedViews(
organizationId: $organizationId,
databaseName: $databaseName,
schemaName: $schemaName
) {
name
schema {
name
database {
... DatabaseFragment
}
relations {
... RelationFragment
}
relation {
... RelationFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
columns {
name
dataType
}
primaryKey
metadata {
value {
... MapEntryFragment
}
}
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"databaseName" : "4" ,
"schemaName" : "4"
}
Response
Copy {
"data" : {
"materializedViews" : [
{
"name" : "4" ,
"schema" : Schema ,
"columns" : [Column] ,
"primaryKey" : [ "xyz789" ] ,
"metadata" : Map ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role
}
]
}
}
me
Example
Query
Copy query Me {
me {
id
givenName
familyName
email
profileImage
licenseAccepted
licenseId
locale
defaultOrganization {
connectors {
... ConnectorFragment
}
invitations {
... InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
... RoleFragment
}
members {
... MemberFragment
}
member {
... MemberFragment
}
database {
... DatabaseFragment
}
databases {
... DatabaseFragment
}
defaultDatabase {
... DatabaseFragment
}
schemaRegistries {
... SchemaRegistryFragment
}
query {
... QueryFragment
}
queries {
... QueryFragment
}
topicDescriptor {
... TopicDescriptorFragment
}
topicDescriptors {
... TopicDescriptorFragment
}
sandbox {
... SandboxFragment
}
role {
... RoleFragment
}
roles {
... RoleFragment
}
defaultRole {
... RoleFragment
}
store {
... StoreFragment
}
stores {
... StoreFragment
}
defaultStore {
... StoreFragment
}
}
organizations {
connectors {
... ConnectorFragment
}
invitations {
... InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
... RoleFragment
}
members {
... MemberFragment
}
member {
... MemberFragment
}
database {
... DatabaseFragment
}
databases {
... DatabaseFragment
}
defaultDatabase {
... DatabaseFragment
}
schemaRegistries {
... SchemaRegistryFragment
}
query {
... QueryFragment
}
queries {
... QueryFragment
}
topicDescriptor {
... TopicDescriptorFragment
}
topicDescriptors {
... TopicDescriptorFragment
}
sandbox {
... SandboxFragment
}
role {
... RoleFragment
}
roles {
... RoleFragment
}
defaultRole {
... RoleFragment
}
store {
... StoreFragment
}
stores {
... StoreFragment
}
defaultStore {
... StoreFragment
}
}
createdAt
updatedAt
}
}
Response
Copy {
"data" : {
"me" : {
"id" : "xyz789" ,
"givenName" : "xyz789" ,
"familyName" : "xyz789" ,
"email" : "xyz789" ,
"profileImage" : "xyz789" ,
"licenseAccepted" : true ,
"licenseId" : "abc123" ,
"locale" : "xyz789" ,
"defaultOrganization" : Organization ,
"organizations" : [Organization] ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642
}
}
}
myInvitations
Response
Returns [UserInvitation!]!
Example
Query
Copy query MyInvitations {
myInvitations {
organizationID
organizationName
id
invitationState
}
}
Response
Copy {
"data" : {
"myInvitations" : [
{
"organizationID" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"organizationName" : "xyz789" ,
"id" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"invitationState" : "PENDING"
}
]
}
}
organization
Response
Returns an Organization
Arguments
Example
Query
Copy query Organization ($id: UUID ! ) {
organization(id: $id) {
connectors {
name
type
sourceRelation {
... RelationFragment
}
sinkStore {
... StoreFragment
}
sender
destinations
template
createdAt
updatedAt
owner {
... RoleFragment
}
}
invitations {
organization {
... OrganizationFragment
}
id
invitedUserEmail
invitedBy {
... RoleFragment
}
userRole {
... RoleFragment
}
defaultRole {
... RoleFragment
}
additionalRoles {
... RoleFragment
}
invitationState
}
id
name
description
profileImage
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
members {
user {
... UserFragment
}
roles {
... RoleGrantFragment
}
defaultRole {
... RoleFragment
}
createdAt
updatedAt
}
member {
user {
... UserFragment
}
roles {
... RoleGrantFragment
}
defaultRole {
... RoleFragment
}
createdAt
updatedAt
}
database {
name
org {
... OrganizationFragment
}
schema {
... SchemaFragment
}
schemas {
... SchemaFragment
}
defaultSchema {
... SchemaFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
databases {
name
org {
... OrganizationFragment
}
schema {
... SchemaFragment
}
schemas {
... SchemaFragment
}
defaultSchema {
... SchemaFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
defaultDatabase {
name
org {
... OrganizationFragment
}
schema {
... SchemaFragment
}
schemas {
... SchemaFragment
}
defaultSchema {
... SchemaFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
schemaRegistries {
name
uris
type
createdAt
updatedAt
owner {
... RoleFragment
}
}
query {
id
organization {
... OrganizationFragment
}
sources {
... RelationFragment
}
sinks {
... RelationFragment
}
dsql
intendedState
actualState
errorMessages
createdAt
updatedAt
owner {
... RoleFragment
}
}
queries {
id
organization {
... OrganizationFragment
}
sources {
... RelationFragment
}
sinks {
... RelationFragment
}
dsql
intendedState
actualState
errorMessages
createdAt
updatedAt
owner {
... RoleFragment
}
}
topicDescriptor {
id
keyDescriptor {
... DescriptorFragment
}
valueDescriptor {
... DescriptorFragment
}
topicName
storeName
org {
... OrganizationFragment
}
}
topicDescriptors {
id
keyDescriptor {
... DescriptorFragment
}
valueDescriptor {
... DescriptorFragment
}
topicName
storeName
org {
... OrganizationFragment
}
}
sandbox {
id
status
functionSources {
... FunctionSourceFragment
}
errorMessages
availabilityZone
createdAt
updatedAt
owner {
... RoleFragment
}
}
role {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
roles {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
defaultRole {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
store {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
stores {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
defaultStore {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
}
}
Variables
Copy {
"id" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"organization" : {
"connectors" : [Connector] ,
"invitations" : [Invitation] ,
"id" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"name" : "xyz789" ,
"description" : "abc123" ,
"profileImage" : "abc123" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role ,
"members" : [Member] ,
"member" : Member ,
"database" : Database ,
"databases" : [Database] ,
"defaultDatabase" : Database ,
"schemaRegistries" : [SchemaRegistry] ,
"query" : Query ,
"queries" : [Query] ,
"topicDescriptor" : TopicDescriptor ,
"topicDescriptors" : [TopicDescriptor] ,
"sandbox" : Sandbox ,
"role" : Role ,
"roles" : [Role] ,
"defaultRole" : Role ,
"store" : Store ,
"stores" : [Store] ,
"defaultStore" : Store
}
}
}
organizationMember
Response
Returns a Member
Arguments
Example
Query
Copy query OrganizationMember ($organizationId: UUID ! ) {
organizationMember(organizationId: $organizationId) {
user {
id
givenName
familyName
email
profileImage
licenseAccepted
licenseId
locale
defaultOrganization {
... OrganizationFragment
}
organizations {
... OrganizationFragment
}
createdAt
updatedAt
}
roles {
name
isEnabled
isInherited
role {
... RoleFragment
}
createdAt
updatedAt
}
defaultRole {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
createdAt
updatedAt
}
}
Variables
Copy {
"organizationId" : "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data" : {
"organizationMember" : {
"user" : User ,
"roles" : [RoleGrant] ,
"defaultRole" : Role ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642
}
}
}
organizations
Response
Returns [Organization!]!
Example
Query
Copy query Organizations {
organizations {
connectors {
name
type
sourceRelation {
... RelationFragment
}
sinkStore {
... StoreFragment
}
sender
destinations
template
createdAt
updatedAt
owner {
... RoleFragment
}
}
invitations {
organization {
... OrganizationFragment
}
id
invitedUserEmail
invitedBy {
... RoleFragment
}
userRole {
... RoleFragment
}
defaultRole {
... RoleFragment
}
additionalRoles {
... RoleFragment
}
invitationState
}
id
name
description
profileImage
createdAt
updatedAt
owner {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
members {
user {
... UserFragment
}
roles {
... RoleGrantFragment
}
defaultRole {
... RoleFragment
}
createdAt
updatedAt
}
member {
user {
... UserFragment
}
roles {
... RoleGrantFragment
}
defaultRole {
... RoleFragment
}
createdAt
updatedAt
}
database {
name
org {
... OrganizationFragment
}
schema {
... SchemaFragment
}
schemas {
... SchemaFragment
}
defaultSchema {
... SchemaFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
databases {
name
org {
... OrganizationFragment
}
schema {
... SchemaFragment
}
schemas {
... SchemaFragment
}
defaultSchema {
... SchemaFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
defaultDatabase {
name
org {
... OrganizationFragment
}
schema {
... SchemaFragment
}
schemas {
... SchemaFragment
}
defaultSchema {
... SchemaFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
schemaRegistries {
name
uris
type
createdAt
updatedAt
owner {
... RoleFragment
}
}
query {
id
organization {
... OrganizationFragment
}
sources {
... RelationFragment
}
sinks {
... RelationFragment
}
dsql
intendedState
actualState
errorMessages
createdAt
updatedAt
owner {
... RoleFragment
}
}
queries {
id
organization {
... OrganizationFragment
}
sources {
... RelationFragment
}
sinks {
... RelationFragment
}
dsql
intendedState
actualState
errorMessages
createdAt
updatedAt
owner {
... RoleFragment
}
}
topicDescriptor {
id
keyDescriptor {
... DescriptorFragment
}
valueDescriptor {
... DescriptorFragment
}
topicName
storeName
org {
... OrganizationFragment
}
}
topicDescriptors {
id
keyDescriptor {
... DescriptorFragment
}
valueDescriptor {
... DescriptorFragment
}
topicName
storeName
org {
... OrganizationFragment
}
}
sandbox {
id
status
functionSources {
... FunctionSourceFragment
}
errorMessages
availabilityZone
createdAt
updatedAt
owner {
... RoleFragment
}
}
role {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
roles {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
defaultRole {
organization {
... OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
... RoleGrantFragment
}
grantedPrivileges {
... PrivilegeGrantFragment
}
}
store {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
stores {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
defaultStore {
name
type
uris
availabilityZone
organization {
... OrganizationFragment
}
metadata {
... MapFragment
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
... TopicFragment
}
topic {
... TopicFragment
}
schemaRegistry {
... SchemaRegistryFragment
}
createdAt
updatedAt
owner {
... RoleFragment
}
}
}
}
Response
Copy {
"data" : {
"organizations" : [
{
"connectors" : [Connector] ,
"invitations" : [Invitation] ,
"id" : "2c5d69e6-5348-4431-8496-252418e42515" ,
"name" : "xyz789" ,
"description" : "abc123" ,
"profileImage" : "abc123" ,
"createdAt" : 1592577642 ,
"updatedAt" : 1592577642 ,
"owner" : Role ,
"members" : [Member] ,
"member" : Member ,
"database" : Database ,
"databases" : [Database] ,
"defaultDatabase" : Database ,
"schemaRegistries" : [SchemaRegistry] ,
"query" : Query ,
"queries" : [Query] ,
"topicDescriptor" : TopicDescriptor ,
"topicDescriptors" : [TopicDescriptor] ,
"sandbox" : Sandbox ,
"role" : Role ,
"roles" : [Role] ,
"defaultRole" : Role ,
"store" : Store ,
"stores" : [Store] ,
"defaultStore" : Store
}
]
}
}
queries
Response
Returns [Query]!
Arguments
Example
Query
Copy query Queries($organizationId: UUID!) {
queries(organizationId: $organizationId) {
id
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
sources {
name
schema {
...SchemaFragment
}
columns {
...ColumnFragment
}
primaryKey
metadata {
...MapFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
sinks {
name
schema {
...SchemaFragment
}
columns {
...ColumnFragment
}
primaryKey
metadata {
...MapFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
dsql
intendedState
actualState
errorMessages
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"queries": [
{
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organization": Organization,
"sources": [Relation],
"sinks": [Relation],
"dsql": "xyz789",
"intendedState": "NEW",
"actualState": "NEW",
"errorMessages": ["xyz789"],
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
]
}
}
query
Response
Returns a Query!
Arguments
Example
Query
Copy query Query(
$id: UUID!,
$organizationId: UUID!
) {
query(
id: $id,
organizationId: $organizationId
) {
id
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
sources {
name
schema {
...SchemaFragment
}
columns {
...ColumnFragment
}
primaryKey
metadata {
...MapFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
sinks {
name
schema {
...SchemaFragment
}
columns {
...ColumnFragment
}
primaryKey
metadata {
...MapFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
dsql
intendedState
actualState
errorMessages
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"query": {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organization": Organization,
"sources": [Relation],
"sinks": [Relation],
"dsql": "abc123",
"intendedState": "NEW",
"actualState": "NEW",
"errorMessages": ["xyz789"],
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
}
}
relation
Response
Returns a Relation!
Arguments
Example
Query
Copy query Relation(
$name: ID!,
$organizationId: UUID!,
$databaseName: ID!,
$schemaName: ID!
) {
relation(
name: $name,
organizationId: $organizationId,
databaseName: $databaseName,
schemaName: $schemaName
) {
name
schema {
name
database {
...DatabaseFragment
}
relations {
...RelationFragment
}
relation {
...RelationFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
columns {
name
dataType
}
primaryKey
metadata {
value {
...MapEntryFragment
}
}
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"name": "4",
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515",
"databaseName": "4",
"schemaName": "4"
}
Response
Copy {
"data": {
"relation": {
"name": "4",
"schema": Schema,
"columns": [Column],
"primaryKey": ["abc123"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
}
}
relations
Response
Returns [Relation!]!
Arguments
Example
Query
Copy query Relations(
$organizationId: UUID!,
$databaseName: ID!,
$schemaName: ID!
) {
relations(
organizationId: $organizationId,
databaseName: $databaseName,
schemaName: $schemaName
) {
name
schema {
name
database {
...DatabaseFragment
}
relations {
...RelationFragment
}
relation {
...RelationFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
columns {
name
dataType
}
primaryKey
metadata {
value {
...MapEntryFragment
}
}
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515",
"databaseName": 4,
"schemaName": "4"
}
Response
Copy {
"data": {
"relations": [
{
"name": 4,
"schema": Schema,
"columns": [Column],
"primaryKey": ["xyz789"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
]
}
}
role
Arguments
Example
Query
Copy query Role(
$organizationId: UUID!,
$name: String
) {
role(
organizationId: $organizationId,
name: $name
) {
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
name
isEnabled
isInherited
role {
...RoleFragment
}
createdAt
updatedAt
}
grantedPrivileges {
privilegeTarget
privilegeType
targetID
}
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515",
"name": "xyz789"
}
Response
Copy {
"data": {
"role": {
"organization": Organization,
"name": "xyz789",
"enabled": true,
"inherit": false,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"grantedRoles": [RoleGrant],
"grantedPrivileges": [PrivilegeGrant]
}
}
}
roles
Response
Returns [Role!]!
Arguments
Example
Query
Copy query Roles($organizationId: UUID!) {
roles(organizationId: $organizationId) {
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
name
isEnabled
isInherited
role {
...RoleFragment
}
createdAt
updatedAt
}
grantedPrivileges {
privilegeTarget
privilegeType
targetID
}
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"roles": [
{
"organization": Organization,
"name": "abc123",
"enabled": false,
"inherit": true,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"grantedRoles": [RoleGrant],
"grantedPrivileges": [PrivilegeGrant]
}
]
}
}
schemaRegistries
Response
Returns [SchemaRegistry!]!
Arguments
Example
Query
Copy query SchemaRegistries($organizationId: ID!) {
schemaRegistries(organizationId: $organizationId) {
name
uris
type
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {"organizationId": 4}
Response
Copy {
"data": {
"schemaRegistries": [
{
"name": "abc123",
"uris": ["abc123"],
"type": "ConfluentCloud",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
]
}
}
statement
Response
Returns a Statement!
Arguments
Example
Query
Copy query Statement(
$id: UUID!,
$organizationId: UUID!
) {
statement(
id: $id,
organizationId: $organizationId
) {
id
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
dsql
user {
id
givenName
familyName
email
profileImage
licenseAccepted
licenseId
locale
defaultOrganization {
...OrganizationFragment
}
organizations {
...OrganizationFragment
}
createdAt
updatedAt
}
errorMessage
createdAt
updatedAt
}
}
Variables
Copy {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"statement": {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organization": Organization,
"dsql": "abc123",
"user": User,
"errorMessage": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642
}
}
}
statements
Response
Returns [Statement!]!
Arguments
Example
Query
Copy query Statements($organizationId: UUID!) {
statements(organizationId: $organizationId) {
id
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
dsql
user {
id
givenName
familyName
email
profileImage
licenseAccepted
licenseId
locale
defaultOrganization {
...OrganizationFragment
}
organizations {
...OrganizationFragment
}
createdAt
updatedAt
}
errorMessage
createdAt
updatedAt
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"statements": [
{
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organization": Organization,
"dsql": "abc123",
"user": User,
"errorMessage": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642
}
]
}
}
store
Response
Returns a Store!
Arguments
Example
Query
Copy query Store(
$name: String!,
$organizationId: UUID!
) {
store(
name: $name,
organizationId: $organizationId
) {
name
type
uris
availabilityZone
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
metadata {
value {
...MapEntryFragment
}
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
name
store {
...StoreFragment
}
}
topic {
name
store {
...StoreFragment
}
}
schemaRegistry {
name
uris
type
createdAt
updatedAt
owner {
...RoleFragment
}
}
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"name": "abc123",
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"store": {
"name": "4",
"type": "Kafka",
"uris": ["xyz789"],
"availabilityZone": "xyz789",
"organization": Organization,
"metadata": Map,
"additionalEgressURIs": ["abc123"],
"enableSslEncryption": true,
"serverHostnameVerification": true,
"caCert": "xyz789",
"tlsProtocols": ["TLS1_2"],
"cipherSuites": ["TLS_RSA_WITH_3DES_EDE_CBC_SHA"],
"topics": [Topic],
"topic": Topic,
"schemaRegistry": SchemaRegistry,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
}
}
stores
Response
Returns [Store!]!
Arguments
Example
Query
Copy query Stores($organizationId: UUID!) {
stores(organizationId: $organizationId) {
name
type
uris
availabilityZone
organization {
connectors {
...ConnectorFragment
}
invitations {
...InvitationFragment
}
id
name
description
profileImage
createdAt
updatedAt
owner {
...RoleFragment
}
members {
...MemberFragment
}
member {
...MemberFragment
}
database {
...DatabaseFragment
}
databases {
...DatabaseFragment
}
defaultDatabase {
...DatabaseFragment
}
schemaRegistries {
...SchemaRegistryFragment
}
query {
...QueryFragment
}
queries {
...QueryFragment
}
topicDescriptor {
...TopicDescriptorFragment
}
topicDescriptors {
...TopicDescriptorFragment
}
sandbox {
...SandboxFragment
}
role {
...RoleFragment
}
roles {
...RoleFragment
}
defaultRole {
...RoleFragment
}
store {
...StoreFragment
}
stores {
...StoreFragment
}
defaultStore {
...StoreFragment
}
}
metadata {
value {
...MapEntryFragment
}
}
additionalEgressURIs
enableSslEncryption
serverHostnameVerification
caCert
tlsProtocols
cipherSuites
topics {
name
store {
...StoreFragment
}
}
topic {
name
store {
...StoreFragment
}
}
schemaRegistry {
name
uris
type
createdAt
updatedAt
owner {
...RoleFragment
}
}
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515"
}
Response
Copy {
"data": {
"stores": [
{
"name": "4",
"type": "Kafka",
"uris": ["xyz789"],
"availabilityZone": "abc123",
"organization": Organization,
"metadata": Map,
"additionalEgressURIs": ["xyz789"],
"enableSslEncryption": true,
"serverHostnameVerification": false,
"caCert": "abc123",
"tlsProtocols": ["TLS1_2"],
"cipherSuites": ["TLS_RSA_WITH_3DES_EDE_CBC_SHA"],
"topics": [Topic],
"topic": Topic,
"schemaRegistry": SchemaRegistry,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
]
}
}
streams
Response
Returns [Relation!]!
Arguments
Example
Query
Copy query Streams(
$organizationId: UUID!,
$databaseName: ID!,
$schemaName: ID!
) {
streams(
organizationId: $organizationId,
databaseName: $databaseName,
schemaName: $schemaName
) {
name
schema {
name
database {
...DatabaseFragment
}
relations {
...RelationFragment
}
relation {
...RelationFragment
}
createdAt
updatedAt
owner {
...RoleFragment
}
}
columns {
name
dataType
}
primaryKey
metadata {
value {
...MapEntryFragment
}
}
createdAt
updatedAt
owner {
organization {
...OrganizationFragment
}
name
enabled
inherit
createdAt
updatedAt
grantedRoles {
...RoleGrantFragment
}
grantedPrivileges {
...PrivilegeGrantFragment
}
}
}
}
Variables
Copy {
"organizationId": "2c5d69e6-5348-4431-8496-252418e42515",
"databaseName": 4,
"schemaName": "4"
}
Response
Copy {
"data": {
"streams": [
{
"name": 4,
"schema": Schema,
"columns": [Column],
"primaryKey": ["abc123"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
]
}
}
version
Response
Returns a Version!
Example
Query
Copy query Version {
version {
major
minor
patch
}
}
Response
Copy {"data": {"version": {"major": 123, "minor": 987, "patch": 987}}}
Types
APIToken
Fields
Example
Copy {
"name": "4",
"lastUsed": 1592577642,
"createdAt": 1592577642
}
AvailabilityZone
Fields
Example
Copy {
"name": "abc123",
"longName": "xyz789"
}
Boolean
Description
The Boolean
scalar type represents true
or false
.
Changelog
Fields
Example
Copy {
"name": "4",
"schema": Schema,
"topic": Topic,
"columns": [Column],
"primaryKey": ["xyz789"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
CipherSuite
Values
Example
Copy "TLS_RSA_WITH_3DES_EDE_CBC_SHA"
Column
Fields
Example
Copy {"name": 4, "dataType": "abc123"}
Connector
Fields
Example
Copy {
"name": 4,
"type": "Notification",
"sourceRelation": Relation,
"sinkStore": Store,
"sender": "xyz789",
"destinations": ["xyz789"],
"template": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
ConnectorType
Values
Database
Fields
Example
Copy {
"name": "abc123",
"org": Organization,
"schema": Schema,
"schemas": [Schema],
"defaultSchema": Schema,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
Descriptor
Fields
Example
Copy {
"id": 4,
"name": "abc123",
"source": DescriptorSource
}
DescriptorSource
Fields
Example
Copy {
"name": "xyz789",
"tags": ["xyz789"],
"type": "PB_DESCRIPTOR",
"org": Organization,
"descriptors": [Descriptor],
"url": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
DescriptorSourceType
Values
Function
Fields
Example
Copy {
"org": Organization,
"name": "xyz789",
"type": "UDF",
"inputs": [Parameter],
"outputType": "abc123",
"source": FunctionSource,
"className": "xyz789",
"signature": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
FunctionSource
Fields
Example
Copy {
"name": "abc123",
"description": "xyz789",
"url": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
FunctionType
Values
ID
Description
The ID
scalar type represents a unique identifier, often used to refetch an object or as key for a cache. The ID type appears in a JSON response as a String; however, it is not intended to be human-readable. When expected as an input type, any string (such as "4"
) or integer (such as 4
) input value will be accepted as an ID.
Int
Description
The Int
scalar type represents non-fractional signed whole numeric values. Int can represent values between -(2^31) and 2^31 - 1.
Invitation
Fields
Example
Copy {
"organization": Organization,
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"invitedUserEmail": "abc123",
"invitedBy": Role,
"userRole": Role,
"defaultRole": Role,
"additionalRoles": [Role],
"invitationState": "PENDING"
}
InvitationState
Values
KafkaTopic
Fields
Example
Copy {
"name": "4",
"store": Store,
"numPartitions": 123,
"numReplicas": 123,
"keyDescriptor": Descriptor,
"valueDescriptor": Descriptor
}
KinesisTopic
Fields
Example
Copy {
"name": "4",
"store": Store,
"shards": 123,
"descriptor": Descriptor
}
Map
Fields
Example
Copy {"value": [MapEntry]}
MapEntry
Fields
Example
Copy {
"key": "abc123",
"value": "xyz789"
}
MaterializedView
Fields
Example
Copy {
"name": "4",
"schema": Schema,
"columns": [Column],
"primaryKey": ["xyz789"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
Member
Fields
Example
Copy {
"user": User,
"roles": [RoleGrant],
"defaultRole": Role,
"createdAt": 1592577642,
"updatedAt": 1592577642
}
Organization
Fields
Example
Copy {
"connectors": [Connector],
"invitations": [Invitation],
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"name": "xyz789",
"description": "abc123",
"profileImage": "xyz789",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role,
"members": [Member],
"member": Member,
"database": Database,
"databases": [Database],
"defaultDatabase": Database,
"schemaRegistries": [SchemaRegistry],
"query": Query,
"queries": [Query],
"topicDescriptor": TopicDescriptor,
"topicDescriptors": [TopicDescriptor],
"sandbox": Sandbox,
"role": Role,
"roles": [Role],
"defaultRole": Role,
"store": Store,
"stores": [Store],
"defaultStore": Store
}
Parameter
Fields
Example
Copy {
"name": "abc123",
"type": "xyz789"
}
PrivilegeGrant
Fields
Example
Copy {
"privilegeTarget": "Organization",
"privilegeType": "CreateRole",
"targetID": 4
}
PrivilegeTarget
Values
PrivilegeType
Values
Query
Fields
Example
Copy {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organization": Organization,
"sources": [Relation],
"sinks": [Relation],
"dsql": "xyz789",
"intendedState": "NEW",
"actualState": "NEW",
"errorMessages": ["abc123"],
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
QueryState
Values
Relation
Fields
Possible Types
Example
Copy {
"name": "4",
"schema": Schema,
"columns": [Column],
"primaryKey": ["xyz789"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
Role
Fields
Example
Copy {
"organization": Organization,
"name": "xyz789",
"enabled": true,
"inherit": false,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"grantedRoles": [RoleGrant],
"grantedPrivileges": [PrivilegeGrant]
}
RoleGrant
Fields
Example
Copy {
"name": "abc123",
"isEnabled": false,
"isInherited": false,
"role": Role,
"createdAt": 1592577642,
"updatedAt": 1592577642
}
Sandbox
Fields
Example
Copy {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"status": "STOPPING",
"functionSources": [FunctionSource],
"errorMessages": ["xyz789"],
"availabilityZone": "abc123",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
SandboxStatus
Values
Schema
Fields
Example
Copy {
"name": "abc123",
"database": Database,
"relations": [Relation],
"relation": Relation,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
SchemaRegistry
Fields
Example
Copy {
"name": "xyz789",
"uris": ["abc123"],
"type": "ConfluentCloud",
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
SchemaRegistryType
Values
Statement
Fields
Example
Copy {
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"organization": Organization,
"dsql": "abc123",
"user": User,
"errorMessage": "abc123",
"createdAt": 1592577642,
"updatedAt": 1592577642
}
Store
Fields
Example
Copy {
"name": "4",
"type": "Kafka",
"uris": ["abc123"],
"availabilityZone": "abc123",
"organization": Organization,
"metadata": Map,
"additionalEgressURIs": ["abc123"],
"enableSslEncryption": false,
"serverHostnameVerification": true,
"caCert": "xyz789",
"tlsProtocols": ["TLS1_2"],
"cipherSuites": ["TLS_RSA_WITH_3DES_EDE_CBC_SHA"],
"topics": [Topic],
"topic": Topic,
"schemaRegistry": SchemaRegistry,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
StoreType
Values
Stream
Fields
Example
Copy {
"name": 4,
"schema": Schema,
"topic": Topic,
"columns": [Column],
"primaryKey": ["abc123"],
"metadata": Map,
"createdAt": 1592577642,
"updatedAt": 1592577642,
"owner": Role
}
String
Description
The String
scalar type represents textual data, represented as UTF-8 character sequences. The String type is most often used by GraphQL to represent free-form human-readable text.
TLSProtocol
Values
Timestamp
Topic
Fields
Possible Types
Example
Copy {
"name": "4",
"store": Store
}
TopicDescriptor
Fields
Example
Copy {
"id": 4,
"keyDescriptor": Descriptor,
"valueDescriptor": Descriptor,
"topicName": "abc123",
"storeName": "xyz789",
"org": Organization
}
UUID
Example
Copy "2c5d69e6-5348-4431-8496-252418e42515"
User
Fields
Example
Copy {
"id": "xyz789",
"givenName": "xyz789",
"familyName": "xyz789",
"email": "xyz789",
"profileImage": "abc123",
"licenseAccepted": true,
"licenseId": "abc123",
"locale": "abc123",
"defaultOrganization": Organization,
"organizations": [Organization],
"createdAt": 1592577642,
"updatedAt": 1592577642
}
UserInvitation
Fields
Example
Copy {
"organizationID": "2c5d69e6-5348-4431-8496-252418e42515",
"organizationName": "xyz789",
"id": "2c5d69e6-5348-4431-8496-252418e42515",
"invitationState": "PENDING"
}
Version
Fields
Example
Copy {"major": 987, "minor": 987, "patch": 987}