Documentation ¶
Index ¶
- func CleanupPolicyTypeChoices() []string
- func CompressionTypeChoices() []string
- func CompressionTypeValueChoices() []string
- func FormatTypeChoices() []string
- func MessageFormatVersionTypeChoices() []string
- func MessageTimestampTypeChoices() []string
- func MessageTimestampTypeValueChoices() []string
- func SourceTypeChoices() []string
- func TopicStateTypeChoices() []string
- type CleanupPolicyOut
- type CleanupPolicyType
- type CompressionType
- type CompressionTypeOut
- type CompressionTypeValue
- type ConfigIn
- type ConfigOut
- type ConsumerGroupOut
- type DeleteRetentionMsOut
- type FileDeleteDelayMsOut
- type FlushMessagesOut
- type FlushMsOut
- type FormatType
- type Handler
- type IndexIntervalBytesOut
- type KafkaTopicHandler
- func (h *KafkaTopicHandler) ServiceKafkaTopicCreate(ctx context.Context, project string, serviceName string, ...) error
- func (h *KafkaTopicHandler) ServiceKafkaTopicDelete(ctx context.Context, project string, serviceName string, topicName string) error
- func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project string, serviceName string, topicName string) (*ServiceKafkaTopicGetOut, error)
- func (h *KafkaTopicHandler) ServiceKafkaTopicList(ctx context.Context, project string, serviceName string) ([]TopicOut, error)
- func (h *KafkaTopicHandler) ServiceKafkaTopicMessageList(ctx context.Context, project string, serviceName string, topicName string, ...) ([]MessageOut, error)
- func (h *KafkaTopicHandler) ServiceKafkaTopicMessageProduce(ctx context.Context, project string, serviceName string, topicName string, ...) (*ServiceKafkaTopicMessageProduceOut, error)
- func (h *KafkaTopicHandler) ServiceKafkaTopicUpdate(ctx context.Context, project string, serviceName string, topicName string, ...) error
- type LocalRetentionBytesOut
- type LocalRetentionMsOut
- type MaxCompactionLagMsOut
- type MaxMessageBytesOut
- type MessageDownconversionEnableOut
- type MessageFormatVersionOut
- type MessageFormatVersionType
- type MessageOut
- type MessageTimestampDifferenceMaxMsOut
- type MessageTimestampType
- type MessageTimestampTypeOut
- type MessageTimestampTypeValue
- type MinCleanableDirtyRatioOut
- type MinCompactionLagMsOut
- type MinInsyncReplicasOut
- type OffsetOut
- type PartitionOut
- type PreallocateOut
- type RecordIn
- type RemoteStorageEnableOut
- type RetentionBytesOut
- type RetentionMsOut
- type SegmentBytesOut
- type SegmentIndexBytesOut
- type SegmentJitterMsOut
- type SegmentMsOut
- type ServiceKafkaTopicCreateIn
- type ServiceKafkaTopicGetOut
- type ServiceKafkaTopicMessageListIn
- type ServiceKafkaTopicMessageProduceIn
- type ServiceKafkaTopicMessageProduceOut
- type ServiceKafkaTopicUpdateIn
- type SourceType
- type SynonymOut
- type TagIn
- type TagOut
- type TopicOut
- type TopicStateType
- type UncleanLeaderElectionEnableOut
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CleanupPolicyTypeChoices ¶
func CleanupPolicyTypeChoices() []string
func CompressionTypeChoices ¶
func CompressionTypeChoices() []string
func CompressionTypeValueChoices ¶ added in v0.3.0
func CompressionTypeValueChoices() []string
func FormatTypeChoices ¶
func FormatTypeChoices() []string
func MessageFormatVersionTypeChoices ¶
func MessageFormatVersionTypeChoices() []string
func MessageTimestampTypeChoices ¶
func MessageTimestampTypeChoices() []string
func MessageTimestampTypeValueChoices ¶ added in v0.3.0
func MessageTimestampTypeValueChoices() []string
func SourceTypeChoices ¶ added in v0.3.0
func SourceTypeChoices() []string
func TopicStateTypeChoices ¶ added in v0.3.0
func TopicStateTypeChoices() []string
Types ¶
type CleanupPolicyOut ¶
type CleanupPolicyOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *string `json:"value,omitempty"` // cleanup.policy }
CleanupPolicyOut cleanup.policy value, source and synonyms
type CleanupPolicyType ¶
type CleanupPolicyType string
const ( CleanupPolicyTypeDelete CleanupPolicyType = "delete" CleanupPolicyTypeCompact CleanupPolicyType = "compact" CleanupPolicyTypeCompactdelete CleanupPolicyType = "compact,delete" )
type CompressionType ¶
type CompressionType string
const ( CompressionTypeSnappy CompressionType = "snappy" CompressionTypeGzip CompressionType = "gzip" CompressionTypeLz4 CompressionType = "lz4" CompressionTypeProducer CompressionType = "producer" CompressionTypeUncompressed CompressionType = "uncompressed" CompressionTypeZstd CompressionType = "zstd" )
type CompressionTypeOut ¶
type CompressionTypeOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value CompressionTypeValue `json:"value,omitempty"` // compression.type }
CompressionTypeOut compression.type value, source and synonyms
type CompressionTypeValue ¶ added in v0.3.0
type CompressionTypeValue string
const ( CompressionTypeValueSnappy CompressionTypeValue = "snappy" CompressionTypeValueGzip CompressionTypeValue = "gzip" CompressionTypeValueLz4 CompressionTypeValue = "lz4" CompressionTypeValueProducer CompressionTypeValue = "producer" CompressionTypeValueUncompressed CompressionTypeValue = "uncompressed" CompressionTypeValueZstd CompressionTypeValue = "zstd" )
type ConfigIn ¶
type ConfigIn struct { CleanupPolicy CleanupPolicyType `json:"cleanup_policy,omitempty"` // cleanup.policy CompressionType CompressionType `json:"compression_type,omitempty"` // compression.type DeleteRetentionMs *int `json:"delete_retention_ms,omitempty"` // delete.retention.ms FileDeleteDelayMs *int `json:"file_delete_delay_ms,omitempty"` // file.delete.delay.ms FlushMessages *int `json:"flush_messages,omitempty"` // flush.messages FlushMs *int `json:"flush_ms,omitempty"` // flush.ms IndexIntervalBytes *int `json:"index_interval_bytes,omitempty"` // index.interval.bytes LocalRetentionBytes *int `json:"local_retention_bytes,omitempty"` // local.retention.bytes LocalRetentionMs *int `json:"local_retention_ms,omitempty"` // local.retention.ms MaxCompactionLagMs *int `json:"max_compaction_lag_ms,omitempty"` // max.compaction.lag.ms MaxMessageBytes *int `json:"max_message_bytes,omitempty"` // max.message.bytes MessageDownconversionEnable *bool `json:"message_downconversion_enable,omitempty"` // message.downconversion.enable MessageFormatVersion MessageFormatVersionType `json:"message_format_version,omitempty"` // message.format.version MessageTimestampDifferenceMaxMs *int `json:"message_timestamp_difference_max_ms,omitempty"` // message.timestamp.difference.max.ms MessageTimestampType MessageTimestampType `json:"message_timestamp_type,omitempty"` // message.timestamp.type MinCleanableDirtyRatio *float64 `json:"min_cleanable_dirty_ratio,omitempty"` // min.cleanable.dirty.ratio MinCompactionLagMs *int `json:"min_compaction_lag_ms,omitempty"` // min.compaction.lag.ms MinInsyncReplicas *int `json:"min_insync_replicas,omitempty"` // min.insync.replicas Preallocate *bool `json:"preallocate,omitempty"` // preallocate RemoteStorageEnable *bool `json:"remote_storage_enable,omitempty"` // remote.storage.enable RetentionBytes *int `json:"retention_bytes,omitempty"` // retention.bytes RetentionMs *int `json:"retention_ms,omitempty"` // retention.ms SegmentBytes *int `json:"segment_bytes,omitempty"` // segment.bytes SegmentIndexBytes *int `json:"segment_index_bytes,omitempty"` // segment.index.bytes SegmentJitterMs *int `json:"segment_jitter_ms,omitempty"` // segment.jitter.ms SegmentMs *int `json:"segment_ms,omitempty"` // segment.ms UncleanLeaderElectionEnable *bool `json:"unclean_leader_election_enable,omitempty"` // unclean.leader.election.enable }
ConfigIn Kafka topic configuration
type ConfigOut ¶
type ConfigOut struct { CleanupPolicy *CleanupPolicyOut `json:"cleanup_policy,omitempty"` // cleanup.policy value, source and synonyms CompressionType *CompressionTypeOut `json:"compression_type,omitempty"` // compression.type value, source and synonyms DeleteRetentionMs *DeleteRetentionMsOut `json:"delete_retention_ms,omitempty"` // delete.retention.ms value, source and synonyms FileDeleteDelayMs *FileDeleteDelayMsOut `json:"file_delete_delay_ms,omitempty"` // file.delete.delay.ms value, source and synonyms FlushMessages *FlushMessagesOut `json:"flush_messages,omitempty"` // flush.messages value, source and synonyms FlushMs *FlushMsOut `json:"flush_ms,omitempty"` // flush.ms value, source and synonyms IndexIntervalBytes *IndexIntervalBytesOut `json:"index_interval_bytes,omitempty"` // index.interval.bytes value, source and synonyms LocalRetentionBytes *LocalRetentionBytesOut `json:"local_retention_bytes,omitempty"` // local.retention.bytes value, source and synonyms LocalRetentionMs *LocalRetentionMsOut `json:"local_retention_ms,omitempty"` // local.retention.ms value, source and synonyms MaxCompactionLagMs *MaxCompactionLagMsOut `json:"max_compaction_lag_ms,omitempty"` // max.compaction.lag.ms value, source and synonyms MaxMessageBytes *MaxMessageBytesOut `json:"max_message_bytes,omitempty"` // max.message.bytes value, source and synonyms MessageDownconversionEnable *MessageDownconversionEnableOut `json:"message_downconversion_enable,omitempty"` // message.downconversion.enable value, source and synonyms MessageFormatVersion *MessageFormatVersionOut `json:"message_format_version,omitempty"` // message.format.version value, source and synonyms MessageTimestampDifferenceMaxMs *MessageTimestampDifferenceMaxMsOut `json:"message_timestamp_difference_max_ms,omitempty"` // message.timestamp.difference.max.ms value, source and synonyms MessageTimestampType *MessageTimestampTypeOut `json:"message_timestamp_type,omitempty"` // message.timestamp.type value, source and synonyms MinCleanableDirtyRatio *MinCleanableDirtyRatioOut `json:"min_cleanable_dirty_ratio,omitempty"` // min.cleanable.dirty.ratio value, source and synonyms MinCompactionLagMs *MinCompactionLagMsOut `json:"min_compaction_lag_ms,omitempty"` // min.compaction.lag.ms value, source and synonyms MinInsyncReplicas *MinInsyncReplicasOut `json:"min_insync_replicas,omitempty"` // min.insync.replicas value, source and synonyms Preallocate *PreallocateOut `json:"preallocate,omitempty"` // preallocate value, source and synonyms RemoteStorageEnable *RemoteStorageEnableOut `json:"remote_storage_enable,omitempty"` // remote.storage.enable value, source and synonyms RetentionBytes *RetentionBytesOut `json:"retention_bytes,omitempty"` // retention.bytes value, source and synonyms RetentionMs *RetentionMsOut `json:"retention_ms,omitempty"` // retention.ms value, source and synonyms SegmentBytes *SegmentBytesOut `json:"segment_bytes,omitempty"` // segment.bytes value, source and synonyms SegmentIndexBytes *SegmentIndexBytesOut `json:"segment_index_bytes,omitempty"` // segment.index.bytes value, source and synonyms SegmentJitterMs *SegmentJitterMsOut `json:"segment_jitter_ms,omitempty"` // segment.jitter.ms value, source and synonyms SegmentMs *SegmentMsOut `json:"segment_ms,omitempty"` // segment.ms value, source and synonyms UncleanLeaderElectionEnable *UncleanLeaderElectionEnableOut `json:"unclean_leader_election_enable,omitempty"` // unclean.leader.election.enable value, source and synonyms }
ConfigOut Kafka topic configuration
type ConsumerGroupOut ¶
type DeleteRetentionMsOut ¶
type DeleteRetentionMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // delete.retention.ms }
DeleteRetentionMsOut delete.retention.ms value, source and synonyms
type FileDeleteDelayMsOut ¶
type FileDeleteDelayMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // file.delete.delay.ms }
FileDeleteDelayMsOut file.delete.delay.ms value, source and synonyms
type FlushMessagesOut ¶
type FlushMessagesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // flush.messages }
FlushMessagesOut flush.messages value, source and synonyms
type FlushMsOut ¶
type FlushMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // flush.ms }
FlushMsOut flush.ms value, source and synonyms
type FormatType ¶
type FormatType string
const ( FormatTypeBinary FormatType = "binary" FormatTypeJson FormatType = "json" FormatTypeAvro FormatType = "avro" FormatTypeProtobuf FormatType = "protobuf" FormatTypeJsonschema FormatType = "jsonschema" )
type Handler ¶
type Handler interface { // ServiceKafkaTopicCreate create a Kafka topic // POST /v1/project/{project}/service/{service_name}/topic // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicCreate ServiceKafkaTopicCreate(ctx context.Context, project string, serviceName string, in *ServiceKafkaTopicCreateIn) error // ServiceKafkaTopicDelete delete a Kafka topic // DELETE /v1/project/{project}/service/{service_name}/topic/{topic_name} // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicDelete ServiceKafkaTopicDelete(ctx context.Context, project string, serviceName string, topicName string) error // ServiceKafkaTopicGet get Kafka topic info // GET /v1/project/{project}/service/{service_name}/topic/{topic_name} // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicGet ServiceKafkaTopicGet(ctx context.Context, project string, serviceName string, topicName string) (*ServiceKafkaTopicGetOut, error) // ServiceKafkaTopicList get Kafka topic list // GET /v1/project/{project}/service/{service_name}/topic // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicList ServiceKafkaTopicList(ctx context.Context, project string, serviceName string) ([]TopicOut, error) // ServiceKafkaTopicMessageList list kafka topic messages // POST /v1/project/{project}/service/{service_name}/kafka/rest/topics/{topic_name}/messages // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicMessageList ServiceKafkaTopicMessageList(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageListIn) ([]MessageOut, error) // ServiceKafkaTopicMessageProduce produce message into a kafka topic // POST /v1/project/{project}/service/{service_name}/kafka/rest/topics/{topic_name}/produce // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicMessageProduce ServiceKafkaTopicMessageProduce(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageProduceIn) (*ServiceKafkaTopicMessageProduceOut, error) // ServiceKafkaTopicUpdate update a Kafka topic // PUT /v1/project/{project}/service/{service_name}/topic/{topic_name} // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaTopicUpdate ServiceKafkaTopicUpdate(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicUpdateIn) error }
type IndexIntervalBytesOut ¶
type IndexIntervalBytesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // index.interval.bytes }
IndexIntervalBytesOut index.interval.bytes value, source and synonyms
type KafkaTopicHandler ¶
type KafkaTopicHandler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(doer doer) KafkaTopicHandler
func (*KafkaTopicHandler) ServiceKafkaTopicCreate ¶
func (h *KafkaTopicHandler) ServiceKafkaTopicCreate(ctx context.Context, project string, serviceName string, in *ServiceKafkaTopicCreateIn) error
func (*KafkaTopicHandler) ServiceKafkaTopicDelete ¶
func (*KafkaTopicHandler) ServiceKafkaTopicGet ¶
func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project string, serviceName string, topicName string) (*ServiceKafkaTopicGetOut, error)
func (*KafkaTopicHandler) ServiceKafkaTopicList ¶
func (*KafkaTopicHandler) ServiceKafkaTopicMessageList ¶
func (h *KafkaTopicHandler) ServiceKafkaTopicMessageList(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageListIn) ([]MessageOut, error)
func (*KafkaTopicHandler) ServiceKafkaTopicMessageProduce ¶
func (h *KafkaTopicHandler) ServiceKafkaTopicMessageProduce(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageProduceIn) (*ServiceKafkaTopicMessageProduceOut, error)
func (*KafkaTopicHandler) ServiceKafkaTopicUpdate ¶
func (h *KafkaTopicHandler) ServiceKafkaTopicUpdate(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicUpdateIn) error
type LocalRetentionBytesOut ¶
type LocalRetentionBytesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // local.retention.ms }
LocalRetentionBytesOut local.retention.bytes value, source and synonyms
type LocalRetentionMsOut ¶
type LocalRetentionMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // local.retention.bytes }
LocalRetentionMsOut local.retention.ms value, source and synonyms
type MaxCompactionLagMsOut ¶
type MaxCompactionLagMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // max.compaction.lag.ms }
MaxCompactionLagMsOut max.compaction.lag.ms value, source and synonyms
type MaxMessageBytesOut ¶
type MaxMessageBytesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // max.message.bytes }
MaxMessageBytesOut max.message.bytes value, source and synonyms
type MessageDownconversionEnableOut ¶
type MessageDownconversionEnableOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *bool `json:"value,omitempty"` // message.downconversion.enable }
MessageDownconversionEnableOut message.downconversion.enable value, source and synonyms
type MessageFormatVersionOut ¶
type MessageFormatVersionOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value MessageFormatVersionType `json:"value,omitempty"` // message.format.version }
MessageFormatVersionOut message.format.version value, source and synonyms
type MessageFormatVersionType ¶
type MessageFormatVersionType string
const ( MessageFormatVersionType080 MessageFormatVersionType = "0.8.0" MessageFormatVersionType081 MessageFormatVersionType = "0.8.1" MessageFormatVersionType082 MessageFormatVersionType = "0.8.2" MessageFormatVersionType090 MessageFormatVersionType = "0.9.0" MessageFormatVersionType0100 MessageFormatVersionType = "0.10.0" MessageFormatVersionType0100Iv0 MessageFormatVersionType = "0.10.0-IV0" MessageFormatVersionType0100Iv1 MessageFormatVersionType = "0.10.0-IV1" MessageFormatVersionType0101 MessageFormatVersionType = "0.10.1" MessageFormatVersionType0101Iv0 MessageFormatVersionType = "0.10.1-IV0" MessageFormatVersionType0101Iv1 MessageFormatVersionType = "0.10.1-IV1" MessageFormatVersionType0101Iv2 MessageFormatVersionType = "0.10.1-IV2" MessageFormatVersionType0102 MessageFormatVersionType = "0.10.2" MessageFormatVersionType0102Iv0 MessageFormatVersionType = "0.10.2-IV0" MessageFormatVersionType0110 MessageFormatVersionType = "0.11.0" MessageFormatVersionType0110Iv0 MessageFormatVersionType = "0.11.0-IV0" MessageFormatVersionType0110Iv1 MessageFormatVersionType = "0.11.0-IV1" MessageFormatVersionType0110Iv2 MessageFormatVersionType = "0.11.0-IV2" MessageFormatVersionType10 MessageFormatVersionType = "1.0" MessageFormatVersionType10Iv0 MessageFormatVersionType = "1.0-IV0" MessageFormatVersionType11 MessageFormatVersionType = "1.1" MessageFormatVersionType11Iv0 MessageFormatVersionType = "1.1-IV0" MessageFormatVersionType20 MessageFormatVersionType = "2.0" MessageFormatVersionType20Iv0 MessageFormatVersionType = "2.0-IV0" MessageFormatVersionType20Iv1 MessageFormatVersionType = "2.0-IV1" MessageFormatVersionType21 MessageFormatVersionType = "2.1" MessageFormatVersionType21Iv0 MessageFormatVersionType = "2.1-IV0" MessageFormatVersionType21Iv1 MessageFormatVersionType = "2.1-IV1" MessageFormatVersionType21Iv2 MessageFormatVersionType = "2.1-IV2" MessageFormatVersionType22 MessageFormatVersionType = "2.2" MessageFormatVersionType22Iv0 MessageFormatVersionType = "2.2-IV0" MessageFormatVersionType22Iv1 MessageFormatVersionType = "2.2-IV1" MessageFormatVersionType23 MessageFormatVersionType = "2.3" MessageFormatVersionType23Iv0 MessageFormatVersionType = "2.3-IV0" MessageFormatVersionType23Iv1 MessageFormatVersionType = "2.3-IV1" MessageFormatVersionType24 MessageFormatVersionType = "2.4" MessageFormatVersionType24Iv0 MessageFormatVersionType = "2.4-IV0" MessageFormatVersionType24Iv1 MessageFormatVersionType = "2.4-IV1" MessageFormatVersionType25 MessageFormatVersionType = "2.5" MessageFormatVersionType25Iv0 MessageFormatVersionType = "2.5-IV0" MessageFormatVersionType26 MessageFormatVersionType = "2.6" MessageFormatVersionType26Iv0 MessageFormatVersionType = "2.6-IV0" MessageFormatVersionType27 MessageFormatVersionType = "2.7" MessageFormatVersionType27Iv0 MessageFormatVersionType = "2.7-IV0" MessageFormatVersionType27Iv1 MessageFormatVersionType = "2.7-IV1" MessageFormatVersionType27Iv2 MessageFormatVersionType = "2.7-IV2" MessageFormatVersionType28 MessageFormatVersionType = "2.8" MessageFormatVersionType28Iv0 MessageFormatVersionType = "2.8-IV0" MessageFormatVersionType28Iv1 MessageFormatVersionType = "2.8-IV1" MessageFormatVersionType30 MessageFormatVersionType = "3.0" MessageFormatVersionType30Iv0 MessageFormatVersionType = "3.0-IV0" MessageFormatVersionType30Iv1 MessageFormatVersionType = "3.0-IV1" MessageFormatVersionType31 MessageFormatVersionType = "3.1" MessageFormatVersionType31Iv0 MessageFormatVersionType = "3.1-IV0" MessageFormatVersionType32 MessageFormatVersionType = "3.2" MessageFormatVersionType32Iv0 MessageFormatVersionType = "3.2-IV0" MessageFormatVersionType33 MessageFormatVersionType = "3.3" MessageFormatVersionType33Iv0 MessageFormatVersionType = "3.3-IV0" MessageFormatVersionType33Iv1 MessageFormatVersionType = "3.3-IV1" MessageFormatVersionType33Iv2 MessageFormatVersionType = "3.3-IV2" MessageFormatVersionType33Iv3 MessageFormatVersionType = "3.3-IV3" MessageFormatVersionType34 MessageFormatVersionType = "3.4" MessageFormatVersionType34Iv0 MessageFormatVersionType = "3.4-IV0" MessageFormatVersionType35 MessageFormatVersionType = "3.5" MessageFormatVersionType35Iv0 MessageFormatVersionType = "3.5-IV0" MessageFormatVersionType35Iv1 MessageFormatVersionType = "3.5-IV1" MessageFormatVersionType35Iv2 MessageFormatVersionType = "3.5-IV2" MessageFormatVersionType36 MessageFormatVersionType = "3.6" MessageFormatVersionType36Iv0 MessageFormatVersionType = "3.6-IV0" MessageFormatVersionType36Iv1 MessageFormatVersionType = "3.6-IV1" MessageFormatVersionType36Iv2 MessageFormatVersionType = "3.6-IV2" MessageFormatVersionType37 MessageFormatVersionType = "3.7" MessageFormatVersionType37Iv0 MessageFormatVersionType = "3.7-IV0" MessageFormatVersionType37Iv1 MessageFormatVersionType = "3.7-IV1" MessageFormatVersionType37Iv2 MessageFormatVersionType = "3.7-IV2" MessageFormatVersionType37Iv3 MessageFormatVersionType = "3.7-IV3" MessageFormatVersionType37Iv4 MessageFormatVersionType = "3.7-IV4" )
type MessageOut ¶
type MessageOut struct { Key map[string]any `json:"key,omitempty"` // The message key, formatted according to the embedded format Offset *int `json:"offset,omitempty"` // Offset of the message Partition *int `json:"partition,omitempty"` // Partition of the message Topic *string `json:"topic,omitempty"` // The name of the topic Value map[string]any `json:"value,omitempty"` // The message value, formatted according to the embedded format }
type MessageTimestampDifferenceMaxMsOut ¶
type MessageTimestampDifferenceMaxMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // message.timestamp.difference.max.ms }
MessageTimestampDifferenceMaxMsOut message.timestamp.difference.max.ms value, source and synonyms
type MessageTimestampType ¶
type MessageTimestampType string
const ( MessageTimestampTypeCreateTime MessageTimestampType = "CreateTime" MessageTimestampTypeLogAppendTime MessageTimestampType = "LogAppendTime" )
type MessageTimestampTypeOut ¶
type MessageTimestampTypeOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value MessageTimestampTypeValue `json:"value,omitempty"` // message.timestamp.type }
MessageTimestampTypeOut message.timestamp.type value, source and synonyms
type MessageTimestampTypeValue ¶ added in v0.3.0
type MessageTimestampTypeValue string
const ( MessageTimestampTypeValueCreateTime MessageTimestampTypeValue = "CreateTime" MessageTimestampTypeValueLogAppendTime MessageTimestampTypeValue = "LogAppendTime" )
type MinCleanableDirtyRatioOut ¶
type MinCleanableDirtyRatioOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *float64 `json:"value,omitempty"` // min.cleanable.dirty.ratio }
MinCleanableDirtyRatioOut min.cleanable.dirty.ratio value, source and synonyms
type MinCompactionLagMsOut ¶
type MinCompactionLagMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // min.compaction.lag.ms }
MinCompactionLagMsOut min.compaction.lag.ms value, source and synonyms
type MinInsyncReplicasOut ¶
type MinInsyncReplicasOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // min.insync.replicas }
MinInsyncReplicasOut min.insync.replicas value, source and synonyms
type OffsetOut ¶
type OffsetOut struct { Error *string `json:"error,omitempty"` // An error message describing why the operation failed, or null if it succeeded ErrorCode *int `json:"error_code,omitempty"` // An error code classifying the reason this operation failed, or null if it succeeded. 1 = Non-retriable Kafka exception, 2 = Retriable Kafka exception; the message might be sent successfully if retried Offset *int `json:"offset,omitempty"` // Offset of the message, or null if publishing the message failed Partition *int `json:"partition,omitempty"` // Partition the message was published to, or null if publishing the message failed }
type PartitionOut ¶
type PartitionOut struct { ConsumerGroups []ConsumerGroupOut `json:"consumer_groups"` // List of Kafka consumer groups EarliestOffset int `json:"earliest_offset"` // Earliest partition message offset Isr int `json:"isr"` // Number of In Sync Replicas (ISR) LatestOffset int `json:"latest_offset"` // Latest partition message offset Partition int `json:"partition"` // Partition number RemoteSize *int `json:"remote_size,omitempty"` // Size of tiered data from partition in bytes Size int `json:"size"` // Size of partition in bytes }
type PreallocateOut ¶
type PreallocateOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *bool `json:"value,omitempty"` // preallocate }
PreallocateOut preallocate value, source and synonyms
type RemoteStorageEnableOut ¶
type RemoteStorageEnableOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *bool `json:"value,omitempty"` // remote.storage.enable }
RemoteStorageEnableOut remote.storage.enable value, source and synonyms
type RetentionBytesOut ¶
type RetentionBytesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // retention.bytes }
RetentionBytesOut retention.bytes value, source and synonyms
type RetentionMsOut ¶
type RetentionMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // retention.ms }
RetentionMsOut retention.ms value, source and synonyms
type SegmentBytesOut ¶
type SegmentBytesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // segment.bytes }
SegmentBytesOut segment.bytes value, source and synonyms
type SegmentIndexBytesOut ¶
type SegmentIndexBytesOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // segment.index.bytes }
SegmentIndexBytesOut segment.index.bytes value, source and synonyms
type SegmentJitterMsOut ¶
type SegmentJitterMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // segment.jitter.ms }
SegmentJitterMsOut segment.jitter.ms value, source and synonyms
type SegmentMsOut ¶
type SegmentMsOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *int `json:"value,omitempty"` // segment.ms }
SegmentMsOut segment.ms value, source and synonyms
type ServiceKafkaTopicCreateIn ¶
type ServiceKafkaTopicCreateIn struct { CleanupPolicy CleanupPolicyType `json:"cleanup_policy,omitempty"` // DEPRECATED: use config.cleanup_policy Config *ConfigIn `json:"config,omitempty"` // Kafka topic configuration MinInsyncReplicas *int `json:"min_insync_replicas,omitempty"` // DEPRECATED: use config.min_insync_replicas Partitions *int `json:"partitions,omitempty"` // Number of partitions Replication *int `json:"replication,omitempty"` // Number of replicas RetentionBytes *int `json:"retention_bytes,omitempty"` // DEPRECATED: use config.retention_bytes RetentionHours *int `json:"retention_hours,omitempty"` // DEPRECATED: use config.retention_ms Tags *[]TagIn `json:"tags,omitempty"` // Topic tags TopicName string `json:"topic_name"` // Topic name }
ServiceKafkaTopicCreateIn ServiceKafkaTopicCreateRequestBody
type ServiceKafkaTopicGetOut ¶
type ServiceKafkaTopicGetOut struct { CleanupPolicy string `json:"cleanup_policy"` // DEPRECATED: use config.cleanup_policy Config ConfigOut `json:"config"` // Kafka topic configuration MinInsyncReplicas int `json:"min_insync_replicas"` // DEPRECATED: use config.min_insync_replicas Partitions []PartitionOut `json:"partitions"` // Topic partitions Replication int `json:"replication"` // Number of replicas RetentionBytes int `json:"retention_bytes"` // DEPRECATED: use config.retention_bytes RetentionHours int `json:"retention_hours"` // DEPRECATED: use config.retention_ms State TopicStateType `json:"state"` // Topic state Tags []TagOut `json:"tags"` // Topic tags TopicName string `json:"topic_name"` // Topic name }
ServiceKafkaTopicGetOut Kafka topic information
type ServiceKafkaTopicMessageListIn ¶
type ServiceKafkaTopicMessageListIn struct { Format FormatType `json:"format,omitempty"` // The format of consumed messages, which is used to convert messages into a JSON-compatible form. If unspecified, defaults to binary MaxBytes *int `json:"max_bytes,omitempty"` // The maximum number of bytes of unencoded keys and values that should be included in the response. This provides approximate control over the size of responses and the amount of memory required to store the decoded response. The actual limit will be the minimum of this setting and the server-side configuration consumer.request.max.bytes. Default is unlimited Partitions map[string]any `json:"partitions"` // Object of desired partition / offset mappings Timeout *int `json:"timeout,omitempty"` // The maximum total time to wait for messages for a request if the maximum request size has not yet been reached }
ServiceKafkaTopicMessageListIn ServiceKafkaTopicMessageListRequestBody
type ServiceKafkaTopicMessageProduceIn ¶
type ServiceKafkaTopicMessageProduceIn struct { Format FormatType `json:"format"` // The format of the content. KeySchema *string `json:"key_schema,omitempty"` // Full schema encoded as a string (e.g. JSON serialized for Avro data) KeySchemaId *int `json:"key_schema_id,omitempty"` // ID returned by a previous request using the same schema. This ID corresponds to the ID of the schema in the registry. Records []RecordIn `json:"records"` // List of records to produce to the topic ValueSchema *string `json:"value_schema,omitempty"` // Full schema encoded as a string (e.g. JSON serialized for Avro data) ValueSchemaId *int `json:"value_schema_id,omitempty"` // ID returned by a previous request using the same schema. This ID corresponds to the ID of the schema in the registry. }
ServiceKafkaTopicMessageProduceIn ServiceKafkaTopicMessageProduceRequestBody
type ServiceKafkaTopicMessageProduceOut ¶
type ServiceKafkaTopicMessageProduceOut struct { KeySchemaId *int `json:"key_schema_id,omitempty"` // The ID for the schema used to produce keys, or null if keys were not used Offsets []OffsetOut `json:"offsets,omitempty"` // List of offsets for the produced record ValueSchemaId *int `json:"value_schema_id,omitempty"` // The ID for the schema used to produce values }
ServiceKafkaTopicMessageProduceOut ServiceKafkaTopicMessageProduceResponse
type ServiceKafkaTopicUpdateIn ¶
type ServiceKafkaTopicUpdateIn struct { Config *ConfigIn `json:"config,omitempty"` // Kafka topic configuration MinInsyncReplicas *int `json:"min_insync_replicas,omitempty"` // DEPRECATED: use config.min_insync_replicas Partitions *int `json:"partitions,omitempty"` // Number of partitions Replication *int `json:"replication,omitempty"` // Number of replicas RetentionBytes *int `json:"retention_bytes,omitempty"` // DEPRECATED: use config.retention_bytes RetentionHours *int `json:"retention_hours,omitempty"` // DEPRECATED: use config.retention_ms Tags *[]TagIn `json:"tags,omitempty"` // Topic tags }
ServiceKafkaTopicUpdateIn ServiceKafkaTopicUpdateRequestBody
type SourceType ¶ added in v0.3.0
type SourceType string
const ( SourceTypeUnknownConfig SourceType = "unknown_config" SourceTypeTopicConfig SourceType = "topic_config" SourceTypeDynamicBrokerConfig SourceType = "dynamic_broker_config" SourceTypeDynamicDefaultBrokerConfig SourceType = "dynamic_default_broker_config" SourceTypeStaticBrokerConfig SourceType = "static_broker_config" SourceTypeDefaultConfig SourceType = "default_config" SourceTypeDynamicBrokerLoggerConfig SourceType = "dynamic_broker_logger_config" )
type SynonymOut ¶
type SynonymOut struct { Name *string `json:"name,omitempty"` // Synonym name Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Value *bool `json:"value,omitempty"` // Synonym value }
type TopicOut ¶
type TopicOut struct { CleanupPolicy string `json:"cleanup_policy"` // cleanup.policy MinInsyncReplicas int `json:"min_insync_replicas"` // min.insync.replicas Partitions int `json:"partitions"` // Number of partitions RemoteStorageEnable *bool `json:"remote_storage_enable,omitempty"` // remote.storage.enable Replication int `json:"replication"` // Number of replicas RetentionBytes int `json:"retention_bytes"` // retention.bytes RetentionHours int `json:"retention_hours"` // Retention period (hours) State TopicStateType `json:"state"` // Topic state Tags []TagOut `json:"tags"` // Topic tags TopicName string `json:"topic_name"` // Topic name }
type TopicStateType ¶ added in v0.3.0
type TopicStateType string
const ( TopicStateTypeActive TopicStateType = "ACTIVE" TopicStateTypeConfiguring TopicStateType = "CONFIGURING" TopicStateTypeDeleting TopicStateType = "DELETING" )
type UncleanLeaderElectionEnableOut ¶
type UncleanLeaderElectionEnableOut struct { Source SourceType `json:"source,omitempty"` // Source of the Kafka topic configuration entry Synonyms []SynonymOut `json:"synonyms,omitempty"` // Configuration synonyms Value *bool `json:"value,omitempty"` // unclean.leader.election.enable }
UncleanLeaderElectionEnableOut unclean.leader.election.enable value, source and synonyms