Documentation
¶
Overview ¶
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright (c) 2017-2018 Uber Technologies, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewIngestionAssignmentTask ¶
func NewIngestionAssignmentTask(p common.IngestionAssignmentTaskParams) common.Task
NewIngestionAssignmentTask creates a new instance of ingestionAssignmentTask
Types ¶
type ElectionStatus ¶
type ElectionStatus int
ElectionStatus represents the leader election status
const ( // Unknown status Unknown ElectionStatus = iota // Leader status Leader // Follower status Follower )
type LeaderElector ¶
type LeaderElector interface {
// Start starts leader election
Start() error
// nofity channel for change in status
C() <-chan struct{}
// Status check current leader election status
Status() ElectionStatus
// Resign leader status if leader
Resign() error
// Close election
Close() error
}
LeaderElector is the interface for start leader election
func NewLeaderElector ¶
func NewLeaderElector(service services.LeaderService) LeaderElector
NewLeaderElector creates a leader elector
Source Files