kafkamirrormaker

Documentation

Index

• func OffsetSyncsTopicLocationTypeChoices() []string
• func ReplicationPolicyClassTypeChoices() []string
• type Handler
• type KafkaMirrorMakerHandler
  • func NewHandler(doer doer) KafkaMirrorMakerHandler
  • func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerCreateReplicationFlow(ctx context.Context, project string, serviceName string, ...) error
  • func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerDeleteReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, ...) error
  • func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, ...) (*ServiceKafkaMirrorMakerGetReplicationFlowOut, error)
  • func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows(ctx context.Context, project string, serviceName string) ([]ReplicationFlowOut, error)
  • func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerPatchReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, ...) (*ServiceKafkaMirrorMakerPatchReplicationFlowOut, error)
• type OffsetSyncsTopicLocationType
• type ReplicationFlowOut
• type ReplicationPolicyClassType
• type ServiceKafkaMirrorMakerCreateReplicationFlowIn
• type ServiceKafkaMirrorMakerGetReplicationFlowOut
• type ServiceKafkaMirrorMakerPatchReplicationFlowIn
• type ServiceKafkaMirrorMakerPatchReplicationFlowOut

Functions

func OffsetSyncsTopicLocationTypeChoices

func OffsetSyncsTopicLocationTypeChoices() []string

func ReplicationPolicyClassTypeChoices

func ReplicationPolicyClassTypeChoices() []string

Types

type Handler

type Handler interface {
	// ServiceKafkaMirrorMakerCreateReplicationFlow create a replication flow
	// POST /project/{project}/service/{service_name}/mirrormaker/replication-flows
	// https://api.aiven.io/doc/#tag/Service:_Kafka_MirrorMaker/operation/ServiceKafkaMirrorMakerCreateReplicationFlow
	ServiceKafkaMirrorMakerCreateReplicationFlow(ctx context.Context, project string, serviceName string, in *ServiceKafkaMirrorMakerCreateReplicationFlowIn) error

	// ServiceKafkaMirrorMakerDeleteReplicationFlow delete a replication flow
	// DELETE /project/{project}/service/{service_name}/mirrormaker/replication-flows/{source_cluster}/{target_cluster}
	// https://api.aiven.io/doc/#tag/Service:_Kafka_MirrorMaker/operation/ServiceKafkaMirrorMakerDeleteReplicationFlow
	ServiceKafkaMirrorMakerDeleteReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string) error

	// ServiceKafkaMirrorMakerGetReplicationFlow get a replication flow
	// GET /project/{project}/service/{service_name}/mirrormaker/replication-flows/{source_cluster}/{target_cluster}
	// https://api.aiven.io/doc/#tag/Service:_Kafka_MirrorMaker/operation/ServiceKafkaMirrorMakerGetReplicationFlow
	ServiceKafkaMirrorMakerGetReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string) (*ServiceKafkaMirrorMakerGetReplicationFlowOut, error)

	// ServiceKafkaMirrorMakerGetReplicationFlows get replication flows
	// GET /project/{project}/service/{service_name}/mirrormaker/replication-flows
	// https://api.aiven.io/doc/#tag/Service:_Kafka_MirrorMaker/operation/ServiceKafkaMirrorMakerGetReplicationFlows
	ServiceKafkaMirrorMakerGetReplicationFlows(ctx context.Context, project string, serviceName string) ([]ReplicationFlowOut, error)

	// ServiceKafkaMirrorMakerPatchReplicationFlow update a replication flow
	// PUT /project/{project}/service/{service_name}/mirrormaker/replication-flows/{source_cluster}/{target_cluster}
	// https://api.aiven.io/doc/#tag/Service:_Kafka_MirrorMaker/operation/ServiceKafkaMirrorMakerPatchReplicationFlow
	ServiceKafkaMirrorMakerPatchReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string, in *ServiceKafkaMirrorMakerPatchReplicationFlowIn) (*ServiceKafkaMirrorMakerPatchReplicationFlowOut, error)
}

type KafkaMirrorMakerHandler

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

func NewHandler

func NewHandler(doer doer) KafkaMirrorMakerHandler

func (*KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerCreateReplicationFlow

func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerCreateReplicationFlow(ctx context.Context, project string, serviceName string, in *ServiceKafkaMirrorMakerCreateReplicationFlowIn) error

func (*KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerDeleteReplicationFlow

func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerDeleteReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string) error

func (*KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow

func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string) (*ServiceKafkaMirrorMakerGetReplicationFlowOut, error)

func (*KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows

func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows(ctx context.Context, project string, serviceName string) ([]ReplicationFlowOut, error)

func (*KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerPatchReplicationFlow

func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerPatchReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string, in *ServiceKafkaMirrorMakerPatchReplicationFlowIn) (*ServiceKafkaMirrorMakerPatchReplicationFlowOut, error)

type OffsetSyncsTopicLocationType

type OffsetSyncsTopicLocationType string

const (
	OffsetSyncsTopicLocationTypeSource OffsetSyncsTopicLocationType = "source"
	OffsetSyncsTopicLocationTypeTarget OffsetSyncsTopicLocationType = "target"
)

type ReplicationFlowOut

type ReplicationFlowOut struct {
	ConfigPropertiesExclude         string                       `json:"config_properties_exclude,omitempty"`
	EmitBackwardHeartbeatsEnabled   *bool                        `json:"emit_backward_heartbeats_enabled,omitempty"`
	EmitHeartbeatsEnabled           *bool                        `json:"emit_heartbeats_enabled,omitempty"`
	Enabled                         bool                         `json:"enabled"`
	OffsetLagMax                    *int                         `json:"offset_lag_max,omitempty"`
	OffsetSyncsTopicLocation        OffsetSyncsTopicLocationType `json:"offset_syncs_topic_location,omitempty"`
	ReplicationPolicyClass          ReplicationPolicyClassType   `json:"replication_policy_class,omitempty"`
	SourceCluster                   string                       `json:"source_cluster"`
	SyncGroupOffsetsEnabled         *bool                        `json:"sync_group_offsets_enabled,omitempty"`
	SyncGroupOffsetsIntervalSeconds *int                         `json:"sync_group_offsets_interval_seconds,omitempty"`
	TargetCluster                   string                       `json:"target_cluster"`
	Topics                          []string                     `json:"topics,omitempty"`
	TopicsBlacklist                 string                       `json:"topics.blacklist,omitempty"`
}

type ReplicationPolicyClassType

type ReplicationPolicyClassType string

const (
	ReplicationPolicyClassTypeDefault  ReplicationPolicyClassType = "org.apache.kafka.connect.mirror.DefaultReplicationPolicy"
	ReplicationPolicyClassTypeIdentity ReplicationPolicyClassType = "org.apache.kafka.connect.mirror.IdentityReplicationPolicy"
)

type ServiceKafkaMirrorMakerCreateReplicationFlowIn

type ServiceKafkaMirrorMakerCreateReplicationFlowIn struct {
	ConfigPropertiesExclude         string                       `json:"config_properties_exclude,omitempty"`
	EmitBackwardHeartbeatsEnabled   *bool                        `json:"emit_backward_heartbeats_enabled,omitempty"`
	EmitHeartbeatsEnabled           *bool                        `json:"emit_heartbeats_enabled,omitempty"`
	Enabled                         bool                         `json:"enabled"`
	OffsetLagMax                    *int                         `json:"offset_lag_max,omitempty"`
	OffsetSyncsTopicLocation        OffsetSyncsTopicLocationType `json:"offset_syncs_topic_location,omitempty"`
	ReplicationPolicyClass          ReplicationPolicyClassType   `json:"replication_policy_class,omitempty"`
	SourceCluster                   string                       `json:"source_cluster"`
	SyncGroupOffsetsEnabled         *bool                        `json:"sync_group_offsets_enabled,omitempty"`
	SyncGroupOffsetsIntervalSeconds *int                         `json:"sync_group_offsets_interval_seconds,omitempty"`
	TargetCluster                   string                       `json:"target_cluster"`
	Topics                          *[]string                    `json:"topics,omitempty"`
	TopicsBlacklist                 string                       `json:"topics.blacklist,omitempty"`
}

type ServiceKafkaMirrorMakerGetReplicationFlowOut

type ServiceKafkaMirrorMakerGetReplicationFlowOut struct {
	ConfigPropertiesExclude         string                       `json:"config_properties_exclude,omitempty"`
	EmitBackwardHeartbeatsEnabled   *bool                        `json:"emit_backward_heartbeats_enabled,omitempty"`
	EmitHeartbeatsEnabled           *bool                        `json:"emit_heartbeats_enabled,omitempty"`
	Enabled                         bool                         `json:"enabled"`
	OffsetLagMax                    *int                         `json:"offset_lag_max,omitempty"`
	OffsetSyncsTopicLocation        OffsetSyncsTopicLocationType `json:"offset_syncs_topic_location,omitempty"`
	ReplicationPolicyClass          ReplicationPolicyClassType   `json:"replication_policy_class,omitempty"`
	SourceCluster                   string                       `json:"source_cluster"`
	SyncGroupOffsetsEnabled         *bool                        `json:"sync_group_offsets_enabled,omitempty"`
	SyncGroupOffsetsIntervalSeconds *int                         `json:"sync_group_offsets_interval_seconds,omitempty"`
	TargetCluster                   string                       `json:"target_cluster"`
	Topics                          []string                     `json:"topics,omitempty"`
	TopicsBlacklist                 string                       `json:"topics.blacklist,omitempty"`
}

type ServiceKafkaMirrorMakerPatchReplicationFlowIn

type ServiceKafkaMirrorMakerPatchReplicationFlowIn struct {
	ConfigPropertiesExclude         string                       `json:"config_properties_exclude,omitempty"`
	EmitBackwardHeartbeatsEnabled   *bool                        `json:"emit_backward_heartbeats_enabled,omitempty"`
	EmitHeartbeatsEnabled           *bool                        `json:"emit_heartbeats_enabled,omitempty"`
	Enabled                         *bool                        `json:"enabled,omitempty"`
	OffsetLagMax                    *int                         `json:"offset_lag_max,omitempty"`
	OffsetSyncsTopicLocation        OffsetSyncsTopicLocationType `json:"offset_syncs_topic_location,omitempty"`
	ReplicationPolicyClass          ReplicationPolicyClassType   `json:"replication_policy_class,omitempty"`
	SyncGroupOffsetsEnabled         *bool                        `json:"sync_group_offsets_enabled,omitempty"`
	SyncGroupOffsetsIntervalSeconds *int                         `json:"sync_group_offsets_interval_seconds,omitempty"`
	Topics                          *[]string                    `json:"topics,omitempty"`
	TopicsBlacklist                 string                       `json:"topics.blacklist,omitempty"`
}

type ServiceKafkaMirrorMakerPatchReplicationFlowOut

type ServiceKafkaMirrorMakerPatchReplicationFlowOut struct {
	ConfigPropertiesExclude         string                       `json:"config_properties_exclude,omitempty"`
	EmitBackwardHeartbeatsEnabled   *bool                        `json:"emit_backward_heartbeats_enabled,omitempty"`
	EmitHeartbeatsEnabled           *bool                        `json:"emit_heartbeats_enabled,omitempty"`
	Enabled                         bool                         `json:"enabled"`
	OffsetLagMax                    *int                         `json:"offset_lag_max,omitempty"`
	OffsetSyncsTopicLocation        OffsetSyncsTopicLocationType `json:"offset_syncs_topic_location,omitempty"`
	ReplicationPolicyClass          ReplicationPolicyClassType   `json:"replication_policy_class,omitempty"`
	SourceCluster                   string                       `json:"source_cluster"`
	SyncGroupOffsetsEnabled         *bool                        `json:"sync_group_offsets_enabled,omitempty"`
	SyncGroupOffsetsIntervalSeconds *int                         `json:"sync_group_offsets_interval_seconds,omitempty"`
	TargetCluster                   string                       `json:"target_cluster"`
	Topics                          []string                     `json:"topics,omitempty"`
	TopicsBlacklist                 string                       `json:"topics.blacklist,omitempty"`
}