connect

type Connector struct {
	Name   ConnectorName   `json:"name"`
	Config ConnectorConfig `json:"config"`
	Type   string          `json:"type"`
	Tasks  []Task          `json:"tasks"`
}

type ConnectorConfig map[string]string

type ConnectorName = string

type ConnectorPlugin struct {
	Class   string `json:"class"`
	Type    string `json:"type"`
	Version string `json:"version"`
}

type ConnectorState struct {
	State    string `json:"state"`
	WorkerID string `json:"worker_id"`
}

type ConnectorStatus struct {
	Name  string         `json:"name"`
	State ConnectorState `json:"connector"`
	Tasks []TaskState    `json:"tasks"`
	Type  string         `json:"type"`
}

type Error struct {
	Code    int    `json:"error_code"`
	Message string `json:"message"`
}

type Task struct {
	Connector string `json:"connector"`
	ID        int    `json:"task"`
}

type TaskConfig map[string]string

type TaskInfo struct {
	ID     Task       `json:"id"`
	Config TaskConfig `json:"config"`
}

type TaskState struct {
	ID       int    `json:"id"`
	State    string `json:"state"`
	WorkerID string `json:"worker_id"`
}

type TaskTopics map[string]Topics

type Topics struct {
	Topics []string `json:"topics"`
}

type Worker struct {
	Version string `json:"version"`
	Commit  string `json:"commit"`
	ID      string `json:"kafka_worker_id"`
}