kafkatopic

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: May 13, 2024 License: Apache-2.0 Imports: 3 Imported by: 2

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

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

type FileDeleteDelayMsOut 

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

type FlushMessagesOut 

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

type FlushMsOut 

type FlushMsOut struct {
	Source   SourceType   `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 /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"`
	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   SourceType   `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *int         `json:"value,omitempty"`
}

type LocalRetentionMsOut 

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

type MaxCompactionLagMsOut 

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

type MaxMessageBytesOut 

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

type MessageDownconversionEnableOut 

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

type MessageFormatVersionOut 

type MessageFormatVersionOut struct {
	Source   SourceType               `json:"source,omitempty"`
	Synonyms []SynonymOut             `json:"synonyms,omitempty"`
	Value    MessageFormatVersionType `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"
	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"`
	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   SourceType   `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   SourceType                `json:"source,omitempty"`
	Synonyms []SynonymOut              `json:"synonyms,omitempty"`
	Value    MessageTimestampTypeValue `json:"value,omitempty"`
}

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

type MinCompactionLagMsOut 

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

type MinInsyncReplicasOut 

type MinInsyncReplicasOut struct {
	Source   SourceType   `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"`
	RemoteSize     *int               `json:"remote_size,omitempty"`
	Size           int                `json:"size"`
}

type PreallocateOut 

type PreallocateOut struct {
	Source   SourceType   `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   SourceType   `json:"source,omitempty"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *bool        `json:"value,omitempty"`
}

type RetentionBytesOut 

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

type RetentionMsOut 

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

type SegmentBytesOut 

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

type SegmentIndexBytesOut 

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

type SegmentJitterMsOut 

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

type SegmentMsOut 

type SegmentMsOut struct {
	Source   SourceType   `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             TopicStateType `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 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"`
	Source SourceType `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               TopicStateType `json:"state"`
	Tags                []TagOut       `json:"tags"`
	TopicName           string         `json:"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"`
	Synonyms []SynonymOut `json:"synonyms,omitempty"`
	Value    *bool        `json:"value,omitempty"`
}

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.