Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisCoordinator ¶
type RedisCoordinator struct {
// contains filtered or unexported fields
}
func NewRedisCoordinator ¶
func NewRedisCoordinator() (*RedisCoordinator, error)
func (*RedisCoordinator) GetAllTimes ¶
func (r *RedisCoordinator) GetAllTimes() (map[string]int64, error)
func (*RedisCoordinator) GetLeastTime ¶
func (r *RedisCoordinator) GetLeastTime() (int64, error)
func (*RedisCoordinator) GetWorkerId ¶
func (r *RedisCoordinator) GetWorkerId() (uint64, error)
func (*RedisCoordinator) ReportTime ¶
func (r *RedisCoordinator) ReportTime(timestamp int64) error
Source Files
Click to show internal directories.
Click to hide internal directories.