api

Documentation

Index

• type ConfigDeleteRequest
• type ConfigDeleteResponse
• type ConfigItem
• type ConfigListRequest
• type ConfigListResponse
• type ConfigUpdateRequest
• type DatabaseConnector
• type DatabaseConnectorConfig
• type EnableRequest
• type GetStatusRequest
• type GetStatusResponse
• type SourceConnector
• type SourceConnectorConfig
• type UpdateDatabaseConnectorRequest
• type UpdateSourceConnectorRequest

Types

type ConfigDeleteRequest

type ConfigDeleteRequest struct {
	Attr string
}

type ConfigDeleteResponse

type ConfigDeleteResponse struct {
	AttrNotFound bool
}

type ConfigItem

type ConfigItem struct {
	Attr string
	Val  string
}

type ConfigListRequest

type ConfigListRequest struct {
	Attr string
}

type ConfigListResponse

type ConfigListResponse struct {
	Configs []ConfigItem
}

type ConfigUpdateRequest

type ConfigUpdateRequest struct {
	Attr string
	Val  string
}

type DatabaseConnector

type DatabaseConnector struct {
	Name   string                  `json:"name"`
	Config DatabaseConnectorConfig `json:"config"`
}

type DatabaseConnectorConfig

type DatabaseConnectorConfig struct {
	Type            string `json:"type"`
	DBHost          string `json:"dbHost"`
	DBPort          string `json:"dbPort"`
	DBName          string `json:"dbName"`
	DBAdminUser     string `json:"dbAdminUser"`
	DBAdminPassword string `json:"dbAdminPassword"`
	DBUsers         string `json:"dbUsers"`
	DBSSLMode       string `json:"dbSSLMode"`
}

type EnableRequest

type EnableRequest struct {
	Connectors []string
}

type GetStatusRequest

type GetStatusRequest struct {
}

type GetStatusResponse

type GetStatusResponse struct {
	Sources   map[string]status.Status `json:"sources"`
	Databases map[string]status.Status `json:"databases"`
}

type SourceConnector

type SourceConnector struct {
	Name   string                `json:"name"`
	Config SourceConnectorConfig `json:"config"`
}

type SourceConnectorConfig

type SourceConnectorConfig struct {
	Brokers          string   `json:"brokers"`
	Topics           []string `json:"topics"`
	Group            string   `json:"group"`
	SchemaPassFilter []string `json:"schemaPassFilter"`
	SchemaPrefix     string   `json:"schemaPrefix"`
	Databases        []string `json:"databases"`
}

type UpdateDatabaseConnectorRequest

type UpdateDatabaseConnectorRequest DatabaseConnector

type UpdateSourceConnectorRequest

type UpdateSourceConnectorRequest SourceConnector