manager

type Config struct {
	ClusterURL        string        `json:"cluster_url"`
	SyncPeriod        time.Duration `json:"sync_period"`
	InitialWaitPeriod time.Duration `json:"initial_wait_period"`
	AllowPurge        bool          `json:"allow_purge"`
	AutoRestart       bool          `json:"auto_restart"`

	Version string `json:"version"`

	GlobalConnectorRestartsMax   int           `json:"global_connector_restarts_max"`
	GlobalConnectorRestartPeriod time.Duration `json:"global_connector_restart_period"`
	GlobalTaskRestartsMax        int           `json:"global_task_restarts_max"`
	GlobalTaskRestartPeriod      time.Duration `json:"global_task_restart_period"`

	RestartOverrides *RestartPolicy `json:"restart_policy"`
}

type ConnectorManager struct {
	// contains filtered or unexported fields
}

type ConnectorSource func() ([]connect.Connector, error)

type ConnectorWithState struct {
	Name           string                  `json:"name"`
	Config         connect.ConnectorConfig `json:"config,omitempty"`
	ConnectorState connect.ConnectorState  `json:"connectorState,omitempty"`
	Tasks          Tasks                   `json:"tasks,omitempty"`
}

type Logger interface {
	Infof(message string, args ...interface{})
	Warnf(message string, args ...interface{})
	Debugf(message string, args ...interface{})
	Errorf(message string, args ...interface{})
}

type Option func(c *ConnectorManager)

type Policy struct {
	ConnectorRestartsMax   int           `json:"connector_restarts_max"`
	ConnectorRestartPeriod time.Duration `json:"connector_restart_period"`
	TaskRestartsMax        int           `json:"task_restarts_max"`
	TaskRestartPeriod      time.Duration `json:"task_restart_period"`
}

type RestartPolicy struct {
	Connectors map[string]Policy `json:"connectors"`
}

type TaskPredicate func(connect.TaskState) bool

type Tasks []connect.TaskState