Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + func NewIngestionAssignmentTask(p common.IngestionAssignmentTaskParams) common.Task + type ElectionStatus int + const Follower + const Leader + const Unknown + type LeaderElector interface + C func() <-chan struct{} + Close func() error + Resign func() error + Start func() error + Status func() ElectionStatus + func NewLeaderElector(service services.LeaderService) LeaderElector
Go to main page