consul

Documentation

Index

• func AcquireLock(logger log.Logger, client *Client, consulSession *Session) error
• type Client
  • func NewConsulClient(logger log.Logger, config *Config) (*Client, error)
• type Config
• type Session
  • func NewSession(logger log.Logger, consulClient *Client, shardName string) (*Session, error)
• type Wrapper
  • func NewWrapper(logger log.Logger, client *Client) *Wrapper
  • func (w *Wrapper) Acquire(shardKey string) (isLeader bool, err error)
  • func (w *Wrapper) Shutdown()

Functions

func AcquireLock

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

Types

type Client

type Client struct {
	ConsulClient *consul.Client
	NodeId       string
	// contains filtered or unexported fields
}

func NewConsulClient

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

type Config

type Config struct {
	Address             string
	Scheme              string
	SessionPath         string
	Tags                []string
	HealthCheckInterval time.Duration
}

type Session

type Session struct {
	ID   string
	Name string
}

func NewSession

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

type Wrapper

type Wrapper struct {
	// contains filtered or unexported fields
}

func NewWrapper

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

func (*Wrapper) Acquire

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

func (*Wrapper) Shutdown

func (w *Wrapper) Shutdown()