tail

Documentation

Index

• type TailSession
  • func (t *TailSession) Commit(ctx context.Context, msgId uuid.UUID) error
  • func (t *TailSession) Done() <-chan struct{}
  • func (t *TailSession) Poll(ctx context.Context) (data []byte, err error)
• type TailSessionOptions

Types

type TailSession

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

func (*TailSession) Commit

func (t *TailSession) Commit(ctx context.Context, msgId uuid.UUID) error

func (*TailSession) Done

func (t *TailSession) Done() <-chan struct{}

func (*TailSession) Poll

func (t *TailSession) Poll(ctx context.Context) (data []byte, err error)

type TailSessionOptions

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