mirror of
https://github.com/eosswedenorg/thalos
synced 2026-06-16 04:24:56 +02:00
17 lines
536 B
Go
17 lines
536 B
Go
package api
|
|
|
|
// Writer interface defines the required methods
|
|
// to send messages over an channel.
|
|
type Writer interface {
|
|
// Write writes a message over a channel.
|
|
// The message may or may not be buffered depending on the implementation.
|
|
Write(channel Channel, payload []byte) error
|
|
|
|
// Flush writes any buffered messages to the channel.
|
|
// If the implementation does not support buffering. this is a noop.
|
|
Flush() error
|
|
|
|
// Close closes the writer
|
|
// Any blocked Flush or Write operations will be unblocked.
|
|
Close() error
|
|
}
|