feedstypes

Documentation

Index

• type ClientDataStream
  • func (cds *ClientDataStream) GetDataStream() *types.ActDataStreamUpdate
  • func (cds *ClientDataStream) GetOffset() int64
• type EventReadStream
  • func (es *EventReadStream) GetOffset() int64
• type Feed
• type KeyChangeStream
  • func (kcs *KeyChangeStream) GetDataStream() *types.KeyChangeStream
  • func (kcs *KeyChangeStream) GetOffset() int64
• type PresenceDataStream
  • func (pds *PresenceDataStream) GetDataStream() *types.PresenceStream
  • func (pds *PresenceDataStream) GetOffset() int64
• type ReceiptDataStream
  • func (rds *ReceiptDataStream) GetDataStream() *types.ReceiptStream
  • func (rds *ReceiptDataStream) GetOffset() int64
• type STDEventStream
  • func (stdEventStream *STDEventStream) GetDataStream() *types.StdEvent
  • func (stdEventStream *STDEventStream) GetOffset() int64
• type StreamEvent
  • func (se *StreamEvent) GetEv() *gomatrixserverlib.ClientEvent
  • func (se *StreamEvent) GetOffset() int64
• type TimeLineEvent
  • func (se *TimeLineEvent) GetEv() *syncapitypes.UserTimeLineStream
  • func (se *TimeLineEvent) GetOffset() int64
• type TimeLines
  • func NewEvTimeLines(size int, limit bool) *TimeLines
  • func (tl *TimeLines) Add(feed Feed) Feed
  • func (tl *TimeLines) Console()
  • func (tl *TimeLines) Expanse() int
  • func (tl *TimeLines) ForRange(f func(offset int, feed Feed) bool)
  • func (tl *TimeLines) ForRangeReverse(f func(offset int, feed Feed) bool)
  • func (tl *TimeLines) GetAllFeeds() ([]Feed, int, int, int64, int64)
  • func (tl *TimeLines) GetAllFeedsReverse() ([]Feed, int, int, int64, int64)
  • func (tl *TimeLines) GetFeedRange() (int64, int64)
  • func (tl *TimeLines) GetFeeds(fromPos, endPos int64) ([]Feed, int, int, int64, int64)
  • func (tl *TimeLines) GetRange() (int, int)
  • func (tl *TimeLines) RAtomic(f func(data *TimeLinesAtomicData))
• type TimeLinesAtomicData

Types

type ClientDataStream

type ClientDataStream struct {
	Offset     int64
	DataStream *types.ActDataStreamUpdate
}

func (*ClientDataStream) GetDataStream

func (cds *ClientDataStream) GetDataStream() *types.ActDataStreamUpdate

func (*ClientDataStream) GetOffset

func (cds *ClientDataStream) GetOffset() int64

type EventReadStream

type EventReadStream struct {
	Offset    int64
	EventID   string
	EventType string
}

func (*EventReadStream) GetOffset

func (es *EventReadStream) GetOffset() int64

type Feed

type Feed interface {
	GetOffset() int64
}

type KeyChangeStream

type KeyChangeStream struct {
	Offset     int64
	DataStream *types.KeyChangeStream
}

func (*KeyChangeStream) GetDataStream

func (kcs *KeyChangeStream) GetDataStream() *types.KeyChangeStream

func (*KeyChangeStream) GetOffset

func (kcs *KeyChangeStream) GetOffset() int64

type PresenceDataStream

type PresenceDataStream struct {
	Offset     int64
	DataStream *types.PresenceStream
}

func (*PresenceDataStream) GetDataStream

func (pds *PresenceDataStream) GetDataStream() *types.PresenceStream

func (*PresenceDataStream) GetOffset

func (pds *PresenceDataStream) GetOffset() int64

type ReceiptDataStream

type ReceiptDataStream struct {
	Offset     int64
	DataStream *types.ReceiptStream
	Written    bool
}

func (*ReceiptDataStream) GetDataStream

func (rds *ReceiptDataStream) GetDataStream() *types.ReceiptStream

func (*ReceiptDataStream) GetOffset

func (rds *ReceiptDataStream) GetOffset() int64

type STDEventStream

type STDEventStream struct {
	Offset         int64
	DataStream     *types.StdEvent
	TargetUserID   string
	TargetDeviceID string
	Written        bool
	Read           bool
}

func (*STDEventStream) GetDataStream

func (stdEventStream *STDEventStream) GetDataStream() *types.StdEvent

func (*STDEventStream) GetOffset

func (stdEventStream *STDEventStream) GetOffset() int64

type StreamEvent

type StreamEvent struct {
	Offset    int64
	Ev        *gomatrixserverlib.ClientEvent
	IsDeleted bool
}

func (*StreamEvent) GetEv

func (se *StreamEvent) GetEv() *gomatrixserverlib.ClientEvent

func (*StreamEvent) GetOffset

func (se *StreamEvent) GetOffset() int64

type TimeLineEvent

type TimeLineEvent struct {
	Offset int64
	Ev     *syncapitypes.UserTimeLineStream
}

func (*TimeLineEvent) GetEv

func (se *TimeLineEvent) GetEv() *syncapitypes.UserTimeLineStream

func (*TimeLineEvent) GetOffset

func (se *TimeLineEvent) GetOffset() int64

type TimeLines

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

func NewEvTimeLines

func NewEvTimeLines(size int, limit bool) *TimeLines

func (*TimeLines) Add

func (tl *TimeLines) Add(feed Feed) Feed

func (*TimeLines) Console

func (tl *TimeLines) Console()

func (*TimeLines) Expanse

func (tl *TimeLines) Expanse() int

func (*TimeLines) ForRange

func (tl *TimeLines) ForRange(f func(offset int, feed Feed) bool)

func (*TimeLines) ForRangeReverse

func (tl *TimeLines) ForRangeReverse(f func(offset int, feed Feed) bool)

func (*TimeLines) GetAllFeeds

func (tl *TimeLines) GetAllFeeds() ([]Feed, int, int, int64, int64)

func (*TimeLines) GetAllFeedsReverse

func (tl *TimeLines) GetAllFeedsReverse() ([]Feed, int, int, int64, int64)

func (*TimeLines) GetFeedRange

func (tl *TimeLines) GetFeedRange() (int64, int64)

func (*TimeLines) GetFeeds

func (tl *TimeLines) GetFeeds(fromPos, endPos int64) ([]Feed, int, int, int64, int64)

func (*TimeLines) GetRange

func (tl *TimeLines) GetRange() (int, int)

func (*TimeLines) RAtomic

func (tl *TimeLines) RAtomic(f func(data *TimeLinesAtomicData))

RAtomic 原子性读操作，尽量在回调中减少计算量，否则锁的时间加长

type TimeLinesAtomicData

type TimeLinesAtomicData struct {
	Size   int
	Offset int
	Limit  bool

	Start int
	End   int
	Lower int64
	Upper int64
	Data  []Feed
	Ofo   bool
}