kafkatopic

package
v0.24.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 23, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

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 ConsumerGroupOut struct {
	GroupName string `json:"group_name"` // consumer group
	Offset    int    `json:"offset"`     // Latest partition message offset
}

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 (h *KafkaTopicHandler) ServiceKafkaTopicDelete(ctx context.Context, project string, serviceName string, topicName string) error

func (*KafkaTopicHandler) ServiceKafkaTopicGet 

func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project string, serviceName string, topicName string) (*ServiceKafkaTopicGetOut, error)

func (*KafkaTopicHandler) ServiceKafkaTopicList 

func (h *KafkaTopicHandler) ServiceKafkaTopicList(ctx context.Context, project string, serviceName string) ([]TopicOut, error)

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"
	MessageFormatVersionType38      MessageFormatVersionType = "3.8"
	MessageFormatVersionType38Iv0   MessageFormatVersionType = "3.8-IV0"
	MessageFormatVersionType39      MessageFormatVersionType = "3.9"
	MessageFormatVersionType39Iv0   MessageFormatVersionType = "3.9-IV0"
	MessageFormatVersionType39Iv1   MessageFormatVersionType = "3.9-IV1"
)

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 RecordIn 

type RecordIn struct {
	Key       *map[string]any `json:"key,omitempty"`       // Key for the produced record
	Partition *int            `json:"partition,omitempty"` // Optionally specify the partition where to produce the record
	Value     *map[string]any `json:"value,omitempty"`     // Value for the produced record
}

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 TagIn 

type TagIn struct {
	Key   string `json:"key"`   // Tag key
	Value string `json:"value"` // Tag value
}

type TagOut 

type TagOut struct {
	Key   string `json:"key"`   // Tag key
	Value string `json:"value"` // Tag 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.