stream

package
Version: v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 8, 2019 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ReceiveFunc

type ReceiveFunc func(context.Context, string, string, string) error

ReceiveFunc function reference with partition_id sequence number and message data

type Stream

type Stream interface {
	// Send Message
	Send(message string) error
	// Receive Messages
	Receive(receiveFunc ReceiveFunc) error
}

Stream interface

Source Files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL