Function nextChannelViewEntry

db/changes_view.go:34–52

(ctx context.Context, results sgbucket.QueryResultIterator, collectionID uint32)

}

func nextChannelViewEntry(ctx context.Context, results sgbucket.QueryResultIterator, collectionID uint32) (*LogEntry, bool) {

	var viewRow channelsViewRow
	found := results.Next(ctx, &viewRow)
	if !found {
		return nil, false
	}

	// Channels view uses composite Key of the form [channelName, sequence]
	entry := &LogEntry{
		Sequence:     uint64(viewRow.Key[1].(float64)),
		DocID:        viewRow.ID,
		Flags:        viewRow.Value.Flags,
		TimeReceived: channels.NewFeedTimestampFromNow(),
		CollectionID: collectionID,
	}
	entry.SetRevAndVersion(viewRow.Value.Rev)
	return entry, true
}

func nextChannelQueryEntry(ctx context.Context, results sgbucket.QueryResultIterator, collectionID uint32) (*LogEntry, bool) {