consul

Oct 21, 2021

Changes in this version

type Client

+ func (c *Client) ClearSession() error

+ func (c *Client) SessionID() string

Sep 22, 2021

Changes in this version

type Client

+ func (c *Client) AcquireLock(key string) error

+ func (c *Client) Shutdown()

Sep 17, 2021

Changes in this version

+ type AgentConfig struct

+ ServiceCheckAddress string

+ ServiceCheckInterval time.Duration

type Config

+ Agent *AgentConfig

+ Datacenter string

+ Namespace string

+ Session *SessionConfig

+ TLS consul.TLSConfig

+ Token string

+ TokenFile string

+ type SessionConfig struct

+ CheckInterval time.Duration

Jun 5, 2021

Changes in this version

+ func AcquireLock(logger log.Logger, client *Client, consulSession *Session) error

+ type Client struct

+ ConsulClient *consul.Client

+ NodeId string

+ func NewConsulClient(logger log.Logger, config *Config) (*Client, error)

+ type Config struct

+ Address string

+ HealthCheckInterval time.Duration

+ Scheme string

+ SessionPath string

+ Tags []string

+ type Session struct

+ ID string

+ Name string

+ func NewSession(logger log.Logger, consulClient *Client, shardName string) (*Session, error)

+ type Wrapper struct

+ func NewWrapper(logger log.Logger, client *Client) *Wrapper

+ func (w *Wrapper) Acquire(shardKey string) (isLeader bool, err error)

+ func (w *Wrapper) Shutdown()