mirror of
https://github.com/eosswedenorg/thalos
synced 2026-06-16 04:24:56 +02:00
17 lines
522 B
Go
17 lines
522 B
Go
package api
|
|
|
|
// Reader interface defines the required method
|
|
// to read a message from an channel.
|
|
//
|
|
// This is a low-level interface typically implemented by backend drivers
|
|
type Reader interface {
|
|
// Read a message from a channel.
|
|
// Read may block until a message is ready or an error occured.
|
|
//
|
|
// This function should be designed to handle concurrent calls. eg. thread safe.
|
|
Read(channel Channel) ([]byte, error)
|
|
|
|
// Close closes the reader
|
|
// Any blocked Read operations will be unblocked.
|
|
Close() error
|
|
}
|