partition

package

v0.1.0-alpha Latest Latest Go to latest Published: Dec 31, 2024 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

func Less(r, t Record) bool

type Information struct {
	PartitionKey   string
	RecordCount    int
	FirstWatermark time.Time
}

type Record interface {
	GetID() string
	GetPartitionKey() string
	GetWatermark() time.Time
	GetData() []byte
}

var (
	Max Record = RecordImpl{
		ID:           maxPossibleString,
		PartitionKey: maxPossibleString,

		Timestamp: maxTime,
	}
)

type RecordImpl struct {
	ID           string
	PartitionKey string
	Timestamp    time.Time
	Data         []byte
}

func (r RecordImpl) GetData() []byte

func (r RecordImpl) GetID() string

func (r RecordImpl) GetPartitionKey() string

func (r RecordImpl) GetWatermark() time.Time

type Strategy interface {
	ShouldRotate(information Information, watermark time.Time) bool
}