rawtopic

type AlterAutoPartitioningSettings struct {
	SetStrategy            AutoPartitioningStrategy
	SetPartitionWriteSpeed *AlterAutoPartitioningWriteSpeedStrategy
}

type AlterAutoPartitioningWriteSpeedStrategy struct {
	SetStabilizationWindow    rawoptional.Duration
	SetUpUtilizationPercent   rawoptional.Int32
	SetDownUtilizationPercent rawoptional.Int32
}

type AlterConsumer struct {
	Name               string
	SetImportant       rawoptional.Bool
	SetReadFrom        rawoptional.Time
	SetSupportedCodecs rawtopiccommon.SupportedCodecs
	AlterAttributes    map[string]string
}

type AlterPartitioningSettings struct {
	SetMinActivePartitions        rawoptional.Int64
	SetMaxActivePartitions        rawoptional.Int64
	SetPartitionCountLimit        rawoptional.Int64
	AlterAutoPartitioningSettings *AlterAutoPartitioningSettings
}

type AlterTopicRequest struct {
	OperationParams rawydb.OperationParams

	Path string

	AlterPartitionSettings               AlterPartitioningSettings
	SetRetentionPeriod                   rawoptional.Duration
	SetRetentionStorageMB                rawoptional.Int64
	SetSupportedCodecs                   bool
	SetSupportedCodecsValue              rawtopiccommon.SupportedCodecs
	SetPartitionWriteSpeedBytesPerSecond rawoptional.Int64
	SetPartitionWriteBurstBytes          rawoptional.Int64
	AlterAttributes                      map[string]string
	AddConsumers                         []Consumer
	DropConsumers                        []string
	AlterConsumers                       []AlterConsumer
	SetMeteringMode                      MeteringMode
}

type AlterTopicResult struct {
	Operation rawydb.Operation
}

type AutoPartitioningSettings struct {
	AutoPartitioningStrategy           AutoPartitioningStrategy
	AutoPartitioningWriteSpeedStrategy AutoPartitioningWriteSpeedStrategy
}

type AutoPartitioningStrategy int32

type AutoPartitioningWriteSpeedStrategy struct {
	StabilizationWindow    rawoptional.Duration
	UpUtilizationPercent   int32
	DownUtilizationPercent int32
}

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

type Consumer struct {
	Name            string
	Important       bool
	SupportedCodecs rawtopiccommon.SupportedCodecs
	ReadFrom        rawoptional.Time
	Attributes      map[string]string
}

type CreateTopicRequest struct {
	OperationParams rawydb.OperationParams

	Path                              string
	PartitioningSettings              PartitioningSettings
	RetentionPeriod                   time.Duration
	RetentionStorageMB                int64
	SupportedCodecs                   rawtopiccommon.SupportedCodecs
	PartitionWriteSpeedBytesPerSecond int64
	PartitionWriteBurstBytes          int64
	Attributes                        map[string]string
	Consumers                         []Consumer
	MeteringMode                      MeteringMode
}

type CreateTopicResult struct {
	Operation rawydb.Operation
}

type DescribeConsumerRequest struct {
	OperationParams rawydb.OperationParams
	Path            string
	Consumer        string
	IncludeStats    bool
}

type DescribeConsumerResult struct {
	Operation  rawydb.Operation
	Self       rawscheme.Entry
	Consumer   Consumer
	Partitions []DescribeConsumerResultPartitionInfo
}

type DescribeConsumerResultPartitionInfo struct {
	PartitionID            int64
	Active                 bool
	ChildPartitionIDs      []int64
	ParentPartitionIDs     []int64
	PartitionStats         PartitionStats
	PartitionConsumerStats PartitionConsumerStats
}

type DescribeTopicRequest struct {
	OperationParams rawydb.OperationParams
	Path            string
	IncludeStats    bool
}

type DescribeTopicResult struct {
	Operation rawydb.Operation

	Self                              rawscheme.Entry
	PartitioningSettings              PartitioningSettings
	Partitions                        []PartitionInfo
	RetentionPeriod                   time.Duration
	RetentionStorageMB                int64
	SupportedCodecs                   rawtopiccommon.SupportedCodecs
	PartitionWriteSpeedBytesPerSecond int64
	PartitionWriteBurstBytes          int64
	Attributes                        map[string]string
	Consumers                         []Consumer
	MeteringMode                      MeteringMode
}

type DropTopicRequest struct {
	OperationParams rawydb.OperationParams
	Path            string
}

type DropTopicResult struct {
	Operation rawydb.Operation
}

type MeteringMode int

type MultipleWindowsStat struct {
	PerMinute int64
	PerHour   int64
	PerDay    int64
}

type PartitionConsumerStats struct {
	LastReadOffset                 int64
	CommittedOffset                int64
	ReadSessionID                  string
	PartitionReadSessionCreateTime rawoptional.Time
	LastReadTime                   rawoptional.Time
	MaxReadTimeLag                 rawoptional.Duration
	MaxWriteTimeLag                rawoptional.Duration
	BytesRead                      MultipleWindowsStat
	ReaderName                     string
}

type PartitionInfo struct {
	PartitionID        int64
	Active             bool
	ChildPartitionIDs  []int64
	ParentPartitionIDs []int64
	PartitionStats     PartitionStats
}

type PartitionStats struct {
	PartitionsOffset rawtopiccommon.OffsetRange
	StoreSizeBytes   int64
	LastWriteTime    rawoptional.Time
	MaxWriteTimeLag  rawoptional.Duration
	BytesWritten     MultipleWindowsStat
}

type PartitioningSettings struct {
	MinActivePartitions      int64
	MaxActivePartitions      int64
	PartitionCountLimit      int64
	AutoPartitioningSettings AutoPartitioningSettings
}

type UpdateOffsetsInTransactionRequest struct {
	OperationParams rawydb.OperationParams
	Tx              rawtopiccommon.TransactionIdentity
	Topics          []UpdateOffsetsInTransactionRequest_TopicOffsets
	Consumer        string
}

type UpdateOffsetsInTransactionRequest_PartitionOffsets struct {
	PartitionID      int64
	PartitionOffsets []rawtopiccommon.OffsetRange
}

type UpdateOffsetsInTransactionRequest_TopicOffsets struct {
	Path       string // Topic path
	Partitions []UpdateOffsetsInTransactionRequest_PartitionOffsets
}