Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoStreamingNodeDeployed = errors.New("no streaming node deployed")
)
Functions ¶
func GetLocalAvailableWAL ¶
func GetLocalAvailableWAL(channel types.PChannelInfo) (wal.WAL, error)
GetLocalAvailableWAL returns a available wal instance for the channel.
func GetLocalWALMetrics ¶
func GetLocalWALMetrics() (*types.StreamingNodeMetrics, error)
GetLocalWALMetrics returns all the metrics of current wal manager.
func RegisterLocalWALManager ¶
func RegisterLocalWALManager(manager WALManager)
RegisterLocalWALManager registers the local wal manager. When the streaming node is started, it should call this function to register the wal manager.
Types ¶
type WALManager ¶
type WALManager interface {
// GetAvailableWAL returns a available wal instance for the channel.
// Return nil if the wal instance is not found.
GetAvailableWAL(channel types.PChannelInfo) (wal.WAL, error)
// Metrics return all the metrics of current wal manager.
Metrics() (*types.StreamingNodeMetrics, error)
}
WALManager is a hint type for wal manager at streaming node.
Source Files
Click to show internal directories.
Click to hide internal directories.