events

Documentation

Index

• type EventBatch
  • func NewEventBatch(tables tablemeta.YtTables) *EventBatch
  • func (e *EventBatch) Count() int
  • func (e *EventBatch) Event() (base.Event, error)
  • func (e *EventBatch) Next() bool
  • func (e *EventBatch) Progress() base.EventSourceProgress
  • func (e *EventBatch) Size() int
  • func (e *EventBatch) TableProcessed()
• type TableEvent

Types

type EventBatch

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

func NewEventBatch

func NewEventBatch(tables tablemeta.YtTables) *EventBatch

func (*EventBatch) Count

func (e *EventBatch) Count() int

func (*EventBatch) Event

func (e *EventBatch) Event() (base.Event, error)

func (*EventBatch) Next

func (e *EventBatch) Next() bool

func (*EventBatch) Progress

func (e *EventBatch) Progress() base.EventSourceProgress

func (*EventBatch) Size

func (e *EventBatch) Size() int

func (*EventBatch) TableProcessed

func (e *EventBatch) TableProcessed()

type TableEvent

type TableEvent interface {
	base.Event
	Table() *tablemeta.YtTableMeta
}