inflight

Documentation

Overview

Deprecated pkg Package inflight provides storage for manipulating inflight message offsets.

server               client
  |                    |
  |               Sub  |
  |<-------------------|
  |                    |
  | Ok/TakeOff(1)      |
  |------------------->|
  |                    |
  |        Sub/Land(1) |
  |<-------------------|
  |                    |
  | Ok/TakeOff(2)      |
  |------------------->|
  |                    |
  |        Sub/Land(2) |
  |<-------------------|
  |                    |

Index

• Variables
• type Inflight

Variables

var (
	ErrOutOfOrder = errors.New("out of order inflight offset")
)

Types

type Inflight

type Inflight interface {
	Land(cluster, topic, group, partition string, offset int64) error

	LandX(cluster, topic, group, partition string, offset int64) ([]byte, error)

	TakeOff(cluster, topic, group, partition string, offset int64, msg []byte) error

	Init() error
	Stop() error
}

var Default Inflight