position

Documentation

Index

• Constants
• type EntryPosition
  • func NewEntryPosition(journalName string, position int64, timestamp int64, serverId int64, ...) *EntryPosition
• type LogIdentity
• type LogPosition
• type MetaqPosition
• type Position
• type TimePosition
  • func NewTimePosition(timestamp int64) *TimePosition

Constants

const (
	EVENTIDENTITY_SEGMENT = 3
	EVENTIDENTITY_SPLIT   = 5
)

Types

type EntryPosition

type EntryPosition struct {
	TimePosition
	Included    bool
	JournalName string
	Position    int64
	ServerId    int64
}

func NewEntryPosition

func NewEntryPosition(journalName string, position int64, timestamp int64, serverId int64, Included bool) *EntryPosition

type LogIdentity

type LogIdentity struct {
	SourceAddress string
	SlaveId       int64
}

type LogPosition

type LogPosition struct {
	Identity LogIdentity
	Postion  EntryPosition
}

type MetaqPosition

type MetaqPosition struct {
	Topic    string
	MsgNewId string
	Offset   int64
}

type Position

type Position interface {
}

type TimePosition

type TimePosition struct {
	Timestamp int64
}

func NewTimePosition

func NewTimePosition(timestamp int64) *TimePosition