observer

README

observer

Package observer contains a base set of observers to observe any update events.

See the main repository README.md for build and documentation details.

Documentation

Overview

Package observer implements an observer for Tarantool 3.0.

Index

• type Accumulator
  • func NewAccumulator(observer discovery.Observer) *Accumulator
  • func (o *Accumulator) Observe(events []discovery.Event, err error)

Types

type Accumulator

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

Accumulator accumulates events and sends them by batches. It helps not to delay a subscription with a slow observer. While one batch is being sent, the other is accumulating.

func NewAccumulator

func NewAccumulator(observer discovery.Observer) *Accumulator

NewAccumulator creates an Observer with given inner observer.

func (*Accumulator) Observe

func (o *Accumulator) Observe(events []discovery.Event, err error)

Observe adds events to the event storage. In case of an error, Accumulator will send all stored events with the error.