simkafka

Documentation

Overview

Package simkafka is a toy simulation of a Kafka commit log.

Index

• func Append(which string, what string) int
• func Read(which string, offset int) string
• func ReadLast(which string) (string, int)
• func ReadMultiple(which string, offset, max int) []string
• func Status() string

Functions

func Append

func Append(which string, what string) int

Append adds a value to the end of a topic, and returns the offset of the added value.

func Read

func Read(which string, offset int) string

Read returns a value for a topic at a specific offset.

func ReadLast

func ReadLast(which string) (string, int)

ReadLast returns the latest value for a topic, and its offset

func ReadMultiple

func ReadMultiple(which string, offset, max int) []string

ReadMultiple reads values for a topic, starting at the given offset, up to the given maximum number of results.

func Status

func Status() string

Status reports the current status of the simulated Kafka instance