electorconsul

Documentation

Overview

实现文件 electorconsul 基于 consul 实现的选举

Index

• Constants
• Variables
• func BuildWithOption(info meta.ServiceInfo, opts ...Option) module.IElector
• type Option
  • func WithConsulClient(cli *bconsul.Client) Option
  • func WithLockTick(t time.Duration) Option
  • func WithLog(log *blog.Logger) Option
  • func WithPubsub(pubsub module.IPubsub) Option
  • func WithSessionTick(t time.Duration) Option
• type Parm

Constants

const (
	// Name 选举器名称
	Name = "ConsulElection"
)

Variables

var (
	// ErrConfigConvert 配置转换失败
	ErrConfigConvert = errors.New("[Elector] convert config error")
)

Functions

func BuildWithOption

func BuildWithOption(info meta.ServiceInfo, opts ...Option) module.IElector

Types

type Option

type Option func(*Parm)

Option consul discover config wrapper

func WithConsulClient

func WithConsulClient(cli *bconsul.Client) Option

func WithLockTick

func WithLockTick(t time.Duration) Option

WithLockTick with lock tick

func WithLog

func WithLog(log *blog.Logger) Option

func WithPubsub

func WithPubsub(pubsub module.IPubsub) Option

func WithSessionTick

func WithSessionTick(t time.Duration) Option

WithSessionTick with session tick

type Parm

type Parm struct {
	LockTick          time.Duration
	RefushSessionTick time.Duration

	ConsulCli *bconsul.Client

	Pubsub module.IPubsub

	Log *blog.Logger
}

Parm 选举器配置项