transaction

type AddOffsetsToTxnRequest struct {
	TransactionID TransactionID
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	GroupID       string
}

type AddOffsetsToTxnResponse struct {
	ErrorCode ErrorCode
}

type AddPartitionsToTxnRequest struct {
	TransactionID TransactionID
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	Partitions    []PartitionMetadata
}

type AddPartitionsToTxnResponse struct {
	Errors map[string]map[int32]ErrorCode // topic -> partition -> error
}

type CoordinatorConfig struct {
	// Default transaction timeout
	DefaultTransactionTimeout time.Duration

	// Maximum transaction timeout allowed
	MaxTransactionTimeout time.Duration

	// How often to check for expired transactions
	ExpirationCheckInterval time.Duration

	// How long to keep completed transaction metadata
	TransactionRetentionTime time.Duration
}

type CoordinatorStats struct {
	ActiveTransactions    int
	CompletedTransactions int
	AbortedTransactions   int
	TotalProducers        int
}

type EndTxnRequest struct {
	TransactionID TransactionID
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	Commit        bool // true to commit, false to abort
}

type EndTxnResponse struct {
	ErrorCode ErrorCode
}

type ErrorCode int16

type InitProducerIDRequest struct {
	TransactionID      TransactionID
	TransactionTimeout time.Duration
}

type InitProducerIDResponse struct {
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	ErrorCode     ErrorCode
}

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

type OffsetMetadata struct {
	Offset   int64
	Metadata string
}

type PartitionMetadata struct {
	Topic     string
	Partition int32
}

type ProducerEpoch int16

type ProducerID int64

type ProducerMetadata struct {
	ProducerID         ProducerID
	ProducerEpoch      ProducerEpoch
	TransactionID      TransactionID
	TransactionTimeout time.Duration
	LastProducerEpoch  ProducerEpoch
	LastTimestamp      time.Time
}

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

type TransactionID string

type TransactionLog interface {
	Append(entry *TransactionLogEntry) error
	Read(txnID TransactionID) (*TransactionLogEntry, error)
	ReadAll() ([]*TransactionLogEntry, error)
	Delete(txnID TransactionID) error
}

type TransactionLogEntry struct {
	TransactionID TransactionID
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	State         TransactionState
	Partitions    []PartitionMetadata
	Timestamp     time.Time
}

type TransactionMarker struct {
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	Commit        bool // true for commit, false for abort
	Timestamp     int64
}

type TransactionMetadata struct {
	TransactionID      TransactionID
	ProducerID         ProducerID
	ProducerEpoch      ProducerEpoch
	State              TransactionState
	Partitions         []PartitionMetadata
	TransactionTimeout time.Duration
	StartTime          time.Time
	LastUpdateTime     time.Time
}

type TransactionResult int

type TransactionState int

type TxnOffsetCommitRequest struct {
	TransactionID TransactionID
	GroupID       string
	ProducerID    ProducerID
	ProducerEpoch ProducerEpoch
	Offsets       map[string]map[int32]OffsetMetadata // topic -> partition -> offset
}

type TxnOffsetCommitResponse struct {
	Errors map[string]map[int32]ErrorCode // topic -> partition -> error
}