tail

type TailSession struct {
	TailSessionOptions
	BQBuf    []byte
	BQSess   *bigquery.ReaderSession
	Data     []byte
	Addr     *domain.SegmentAddress
	Bookmark *domain.Bookmark
	EOF      bool
	Req      *v1.TailRequest
}

type TailSessionOptions struct {
	BQReaderService *bigquery.ReaderService
	Sess            *etcd.TailSession
	Topic           *domain.Topic
	Subscription    types.SubscriptionId
}