聊聊canal-go的position

package position
​
type Position interface {
}

package position
​
type MetaqPosition struct {
    Topic    string
    MsgNewId string
    Offset   int64
}

package position
​
type TimePosition struct {
    Timestamp int64
}
​
func NewTimePosition(timestamp int64) *TimePosition {
    tstamp := &TimePosition{Timestamp: timestamp}
    return tstamp
}

package position
​
const (
    EVENTIDENTITY_SEGMENT = 3
    EVENTIDENTITY_SPLIT   = 5
)
​
type EntryPosition struct {
    TimePosition
    Included    bool
    JournalName string
    Position    int64
    ServerId    int64
}
​
func NewEntryPosition(journalName string, position int64, timestamp int64, serverId int64, Included bool) *EntryPosition {
    entryPosition := &EntryPosition{TimePosition{timestamp}, false, journalName, position, serverId}
    return entryPosition
}

package position
​
type LogPosition struct {
    Identity LogIdentity
    Postion  EntryPosition
}