kafkatopic

Documentation

Index

• func CleanupPolicyTypeChoices() []string
• func CompressionTypeChoices() []string
• func FormatTypeChoices() []string
• func MessageFormatVersionTypeChoices() []string
• func MessageTimestampTypeChoices() []string
• type CleanupPolicyOut
• type CleanupPolicyType
• type CompressionType
• type CompressionTypeOut
• type ConfigIn
• type ConfigOut
• type ConsumerGroupOut
• type DeleteRetentionMsOut
• type FileDeleteDelayMsOut
• type FlushMessagesOut
• type FlushMsOut
• type FormatType
• type Handler
• type IndexIntervalBytesOut
• type KafkaTopicHandler
  • func NewHandler(doer doer) 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 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 SynonymOut
• type TagIn
• type TagOut
• type TopicOut
• type UncleanLeaderElectionEnableOut

Functions

func CleanupPolicyTypeChoices

func CleanupPolicyTypeChoices() []string

func CompressionTypeChoices

func CompressionTypeChoices() []string

func FormatTypeChoices

func FormatTypeChoices() []string

func MessageFormatVersionTypeChoices

func MessageFormatVersionTypeChoices() []string

func MessageTimestampTypeChoices

func MessageTimestampTypeChoices() []string

Types

type CleanupPolicyOut

type CleanupPolicyOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    string       `json:"value,omitempty"`
}

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   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    string       `json:"value,omitempty"`
}

type ConfigIn

type ConfigIn struct {
	CleanupPolicy                   CleanupPolicyType        `json:"cleanup_policy,omitempty"`
	CompressionType                 CompressionType          `json:"compression_type,omitempty"`
	DeleteRetentionMs               *int                     `json:"delete_retention_ms,omitempty"`
	FileDeleteDelayMs               *int                     `json:"file_delete_delay_ms,omitempty"`
	FlushMessages                   *int                     `json:"flush_messages,omitempty"`
	FlushMs                         *int                     `json:"flush_ms,omitempty"`
	IndexIntervalBytes              *int                     `json:"index_interval_bytes,omitempty"`
	LocalRetentionBytes             *int                     `json:"local_retention_bytes,omitempty"`
	LocalRetentionMs                *int                     `json:"local_retention_ms,omitempty"`
	MaxCompactionLagMs              *int                     `json:"max_compaction_lag_ms,omitempty"`
	MaxMessageBytes                 *int                     `json:"max_message_bytes,omitempty"`
	MessageDownconversionEnable     *bool                    `json:"message_downconversion_enable,omitempty"`
	MessageFormatVersion            MessageFormatVersionType `json:"message_format_version,omitempty"`
	MessageTimestampDifferenceMaxMs *int                     `json:"message_timestamp_difference_max_ms,omitempty"`
	MessageTimestampType            MessageTimestampType     `json:"message_timestamp_type,omitempty"`
	MinCleanableDirtyRatio          *float64                 `json:"min_cleanable_dirty_ratio,omitempty"`
	MinCompactionLagMs              *int                     `json:"min_compaction_lag_ms,omitempty"`
	MinInsyncReplicas               *int                     `json:"min_insync_replicas,omitempty"`
	Preallocate                     *bool                    `json:"preallocate,omitempty"`
	RemoteStorageEnable             *bool                    `json:"remote_storage_enable,omitempty"`
	RetentionBytes                  *int                     `json:"retention_bytes,omitempty"`
	RetentionMs                     *int                     `json:"retention_ms,omitempty"`
	SegmentBytes                    *int                     `json:"segment_bytes,omitempty"`
	SegmentIndexBytes               *int                     `json:"segment_index_bytes,omitempty"`
	SegmentJitterMs                 *int                     `json:"segment_jitter_ms,omitempty"`
	SegmentMs                       *int                     `json:"segment_ms,omitempty"`
	UncleanLeaderElectionEnable     *bool                    `json:"unclean_leader_election_enable,omitempty"`
}

type ConfigOut

type ConfigOut struct {
	CleanupPolicy                   *CleanupPolicyOut                   `json:"cleanup_policy,omitempty"`
	CompressionType                 *CompressionTypeOut                 `json:"compression_type,omitempty"`
	DeleteRetentionMs               *DeleteRetentionMsOut               `json:"delete_retention_ms,omitempty"`
	FileDeleteDelayMs               *FileDeleteDelayMsOut               `json:"file_delete_delay_ms,omitempty"`
	FlushMessages                   *FlushMessagesOut                   `json:"flush_messages,omitempty"`
	FlushMs                         *FlushMsOut                         `json:"flush_ms,omitempty"`
	IndexIntervalBytes              *IndexIntervalBytesOut              `json:"index_interval_bytes,omitempty"`
	LocalRetentionBytes             *LocalRetentionBytesOut             `json:"local_retention_bytes,omitempty"`
	LocalRetentionMs                *LocalRetentionMsOut                `json:"local_retention_ms,omitempty"`
	MaxCompactionLagMs              *MaxCompactionLagMsOut              `json:"max_compaction_lag_ms,omitempty"`
	MaxMessageBytes                 *MaxMessageBytesOut                 `json:"max_message_bytes,omitempty"`
	MessageDownconversionEnable     *MessageDownconversionEnableOut     `json:"message_downconversion_enable,omitempty"`
	MessageFormatVersion            *MessageFormatVersionOut            `json:"message_format_version,omitempty"`
	MessageTimestampDifferenceMaxMs *MessageTimestampDifferenceMaxMsOut `json:"message_timestamp_difference_max_ms,omitempty"`
	MessageTimestampType            *MessageTimestampTypeOut            `json:"message_timestamp_type,omitempty"`
	MinCleanableDirtyRatio          *MinCleanableDirtyRatioOut          `json:"min_cleanable_dirty_ratio,omitempty"`
	MinCompactionLagMs              *MinCompactionLagMsOut              `json:"min_compaction_lag_ms,omitempty"`
	MinInsyncReplicas               *MinInsyncReplicasOut               `json:"min_insync_replicas,omitempty"`
	Preallocate                     *PreallocateOut                     `json:"preallocate,omitempty"`
	RemoteStorageEnable             *RemoteStorageEnableOut             `json:"remote_storage_enable,omitempty"`
	RetentionBytes                  *RetentionBytesOut                  `json:"retention_bytes,omitempty"`
	RetentionMs                     *RetentionMsOut                     `json:"retention_ms,omitempty"`
	SegmentBytes                    *SegmentBytesOut                    `json:"segment_bytes,omitempty"`
	SegmentIndexBytes               *SegmentIndexBytesOut               `json:"segment_index_bytes,omitempty"`
	SegmentJitterMs                 *SegmentJitterMsOut                 `json:"segment_jitter_ms,omitempty"`
	SegmentMs                       *SegmentMsOut                       `json:"segment_ms,omitempty"`
	UncleanLeaderElectionEnable     *UncleanLeaderElectionEnableOut     `json:"unclean_leader_election_enable,omitempty"`
}

type ConsumerGroupOut

type ConsumerGroupOut struct {
	GroupName string `json:"group_name"`
	Offset    int    `json:"offset"`
}

type DeleteRetentionMsOut

type DeleteRetentionMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type FileDeleteDelayMsOut

type FileDeleteDelayMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type FlushMessagesOut

type FlushMessagesOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type FlushMsOut

type FlushMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

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 /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 /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 /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 /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 /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 /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 /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   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

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   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type LocalRetentionMsOut

type LocalRetentionMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type MaxCompactionLagMsOut

type MaxCompactionLagMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type MaxMessageBytesOut

type MaxMessageBytesOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type MessageDownconversionEnableOut

type MessageDownconversionEnableOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *bool        `json:"value,omitempty"`
}

type MessageFormatVersionOut

type MessageFormatVersionOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    string       `json:"value,omitempty"`
}

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"
)

type MessageOut

type MessageOut struct {
	Key       map[string]any `json:"key,omitempty"`
	Offset    *int           `json:"offset,omitempty"`
	Partition *int           `json:"partition,omitempty"`
	Topic     string         `json:"topic,omitempty"`
	Value     map[string]any `json:"value,omitempty"`
}

type MessageTimestampDifferenceMaxMsOut

type MessageTimestampDifferenceMaxMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type MessageTimestampType

type MessageTimestampType string

const (
	MessageTimestampTypeCreateTime    MessageTimestampType = "CreateTime"
	MessageTimestampTypeLogAppendTime MessageTimestampType = "LogAppendTime"
)

type MessageTimestampTypeOut

type MessageTimestampTypeOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    string       `json:"value,omitempty"`
}

type MinCleanableDirtyRatioOut

type MinCleanableDirtyRatioOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *float64     `json:"value,omitempty"`
}

type MinCompactionLagMsOut

type MinCompactionLagMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type MinInsyncReplicasOut

type MinInsyncReplicasOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type OffsetOut

type OffsetOut struct {
	Error     string `json:"error,omitempty"`
	ErrorCode *int   `json:"error_code,omitempty"`
	Offset    *int   `json:"offset,omitempty"`
	Partition *int   `json:"partition,omitempty"`
}

type PartitionOut

type PartitionOut struct {
	ConsumerGroups []ConsumerGroupOut `json:"consumer_groups"`
	EarliestOffset int                `json:"earliest_offset"`
	Isr            int                `json:"isr"`
	LatestOffset   int                `json:"latest_offset"`
	Partition      int                `json:"partition"`
	Size           int                `json:"size"`
}

type PreallocateOut

type PreallocateOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *bool        `json:"value,omitempty"`
}

type RecordIn

type RecordIn struct {
	Key       *map[string]any `json:"key,omitempty"`
	Partition *int            `json:"partition,omitempty"`
	Value     *map[string]any `json:"value,omitempty"`
}

type RemoteStorageEnableOut

type RemoteStorageEnableOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *bool        `json:"value,omitempty"`
}

type RetentionBytesOut

type RetentionBytesOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type RetentionMsOut

type RetentionMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type SegmentBytesOut

type SegmentBytesOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type SegmentIndexBytesOut

type SegmentIndexBytesOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type SegmentJitterMsOut

type SegmentJitterMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type SegmentMsOut

type SegmentMsOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type ServiceKafkaTopicCreateIn

type ServiceKafkaTopicCreateIn struct {
	CleanupPolicy     CleanupPolicyType `json:"cleanup_policy,omitempty"`
	Config            *ConfigIn         `json:"config,omitempty"`
	MinInsyncReplicas *int              `json:"min_insync_replicas,omitempty"`
	Partitions        *int              `json:"partitions,omitempty"`
	Replication       *int              `json:"replication,omitempty"`
	RetentionBytes    *int              `json:"retention_bytes,omitempty"`
	RetentionHours    *int              `json:"retention_hours,omitempty"`
	Tags              *[]TagIn          `json:"tags,omitempty"`
	TopicName         string            `json:"topic_name"`
}

type ServiceKafkaTopicGetOut

type ServiceKafkaTopicGetOut struct {
	CleanupPolicy     string         `json:"cleanup_policy"`
	Config            ConfigOut      `json:"config"`
	MinInsyncReplicas int            `json:"min_insync_replicas"`
	Partitions        []PartitionOut `json:"partitions"`
	Replication       int            `json:"replication"`
	RetentionBytes    int            `json:"retention_bytes"`
	RetentionHours    int            `json:"retention_hours"`
	State             string         `json:"state"`
	Tags              []TagOut       `json:"tags"`
	TopicName         string         `json:"topic_name"`
}

type ServiceKafkaTopicMessageListIn

type ServiceKafkaTopicMessageListIn struct {
	Format     FormatType     `json:"format,omitempty"`
	MaxBytes   *int           `json:"max_bytes,omitempty"`
	Partitions map[string]any `json:"partitions"`
	Timeout    *int           `json:"timeout,omitempty"`
}

type ServiceKafkaTopicMessageProduceIn

type ServiceKafkaTopicMessageProduceIn struct {
	Format        FormatType `json:"format"`
	KeySchema     string     `json:"key_schema,omitempty"`
	KeySchemaId   *int       `json:"key_schema_id,omitempty"`
	Records       []RecordIn `json:"records"`
	ValueSchema   string     `json:"value_schema,omitempty"`
	ValueSchemaId *int       `json:"value_schema_id,omitempty"`
}

type ServiceKafkaTopicMessageProduceOut

type ServiceKafkaTopicMessageProduceOut struct {
	KeySchemaId   *int        `json:"key_schema_id,omitempty"`
	Offsets       []OffsetOut `json:"offsets,omitempty"`
	ValueSchemaId *int        `json:"value_schema_id,omitempty"`
}

type ServiceKafkaTopicUpdateIn

type ServiceKafkaTopicUpdateIn struct {
	Config            *ConfigIn `json:"config,omitempty"`
	MinInsyncReplicas *int      `json:"min_insync_replicas,omitempty"`
	Partitions        *int      `json:"partitions,omitempty"`
	Replication       *int      `json:"replication,omitempty"`
	RetentionBytes    *int      `json:"retention_bytes,omitempty"`
	RetentionHours    *int      `json:"retention_hours,omitempty"`
	Tags              *[]TagIn  `json:"tags,omitempty"`
}

type SynonymOut

type SynonymOut struct {
	Name   string `json:"name,omitempty"`
	Source string `json:"source,omitempty"`
	Value  *bool  `json:"value,omitempty"`
}

type TagIn

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

type TagOut

type TagOut struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type TopicOut

type TopicOut struct {
	CleanupPolicy       string   `json:"cleanup_policy"`
	MinInsyncReplicas   int      `json:"min_insync_replicas"`
	Partitions          int      `json:"partitions"`
	RemoteStorageEnable *bool    `json:"remote_storage_enable,omitempty"`
	Replication         int      `json:"replication"`
	RetentionBytes      int      `json:"retention_bytes"`
	RetentionHours      int      `json:"retention_hours"`
	State               string   `json:"state"`
	Tags                []TagOut `json:"tags"`
	TopicName           string   `json:"topic_name"`
}

type UncleanLeaderElectionEnableOut

type UncleanLeaderElectionEnableOut struct {
	Source   string       `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *bool        `json:"value,omitempty"`
}