Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrUnsupportedEndpointType = errors.New("given endpoint type not supported")
Functions ¶
This section is empty.
Types ¶
type ConsulLeaderChecker ¶
type ConsulLeaderChecker struct {
// contains filtered or unexported fields
}
func NewConsulLeaderChecker ¶
func NewConsulLeaderChecker(con vipconfig.Config) (*ConsulLeaderChecker, error)
func NewConsulLeaderChecker(endpoint, key, nodename string) (*ConsulLeaderChecker, error) {
func (*ConsulLeaderChecker) GetChangeNotificationStream ¶
func (c *ConsulLeaderChecker) GetChangeNotificationStream(ctx context.Context, out chan<- bool) error
type EtcdLeaderChecker ¶
type EtcdLeaderChecker struct {
// contains filtered or unexported fields
}
func NewEtcdLeaderChecker ¶
func NewEtcdLeaderChecker(con vipconfig.Config) (*EtcdLeaderChecker, error)
func NewEtcdLeaderChecker(endpoint, key, nodename string, etcd_user string, etcd_password string) (*EtcdLeaderChecker, error) {
func (*EtcdLeaderChecker) GetChangeNotificationStream ¶
func (e *EtcdLeaderChecker) GetChangeNotificationStream(ctx context.Context, out chan<- bool) error
type LeaderChecker ¶
type LeaderChecker interface {
GetChangeNotificationStream(ctx context.Context, out chan<- bool) error
}
func NewLeaderChecker ¶
func NewLeaderChecker(con vipconfig.Config) (LeaderChecker, error)
func NewLeaderChecker(endpointType, endpoint, key, nodename string, etcd_user string, etcd_password string) (LeaderChecker, error) {
Source Files
Click to show internal directories.
Click to hide internal directories.