Documentation
¶
Index ¶
Constants ¶
View Source
const CName = "common.subscribeclient"
Variables ¶
View Source
var ErrShutdown = errors.New("stream shutted down")
Functions ¶
This section is empty.
Types ¶
type EventCallback ¶
type EventCallback func(*coordinatorproto.NotifySubscribeEvent)
type SubscribeClientService ¶
type SubscribeClientService interface {
Subscribe(eventType coordinatorproto.NotifyEventType, callback EventCallback) error
app.ComponentRunnable
}
func New ¶
func New() SubscribeClientService
Directories
¶
| Path | Synopsis |
|---|---|
|
Package mock_subscribeclient is a generated GoMock package.
|
Package mock_subscribeclient is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.