clusterlink

type ClusterLink struct {
	LinkName        string `json:"link_name"`
	LinkID          string `json:"link_id"`
	ClusterID       string `json:"cluster_id"`
	SourceClusterID string `json:"source_cluster_id"`
	LinkState       string `json:"link_state"`
	LinkError       string `json:"link_error,omitempty"`
}

type Config struct {
	RestEndpoint string
	ClusterID    string
	LinkName     string
	APIKey       string
	APISecret    string
	Topics       []string
}

type ConfigAlteration struct {
	Name      string `json:"name"`
	Value     string `json:"value"`
	Operation string `json:"operation"`
}

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

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type MirrorLag struct {
	Partition             int `json:"partition"`
	Lag                   int `json:"lag"`
	LastSourceFetchOffset int `json:"last_source_fetch_offset"`
}

type MirrorTopic struct {
	MirrorTopicName string      `json:"mirror_topic_name"`
	MirrorStatus    string      `json:"mirror_status"`
	MirrorLags      []MirrorLag `json:"mirror_lags"`
}

type PromoteMirrorTopicsResponse struct {
	Data []struct {
		MirrorTopicName string `json:"mirror_topic_name"`
		ErrorMessage    string `json:"error_message,omitempty"`
		ErrorCode       int    `json:"error_code,omitempty"`
	} `json:"data"`
}

type Service interface {
	GetClusterLink(ctx context.Context, config Config) (*ClusterLink, error)
	ListMirrorTopics(ctx context.Context, config Config) ([]MirrorTopic, error)
	ListConfigs(ctx context.Context, config Config) (map[string]string, error)
	ValidateTopics(topics []string, clusterLinkTopics []string) error
	PromoteMirrorTopics(ctx context.Context, config Config, topicNames []string) (*PromoteMirrorTopicsResponse, error)

	// AlterConfigs applies the given alterations to the cluster link's configs.
	//
	// IMPORTANT: this method is NOT atomic across multiple alterations. The
	// implementation iterates the slice and issues one network call per entry,
	// short-circuiting on the first error. On mid-batch failure, alterations
	// before the failing index are already persisted server-side; alterations
	// at and after the failing index are NOT applied. The returned error does
	// not identify which entries succeeded — callers that need batch
	// atomicity must implement compensation themselves, or call this method
	// with a single alteration at a time.
	AlterConfigs(ctx context.Context, config Config, alterations []ConfigAlteration) error
}