internal

package

v0.0.0-...-838d9ca Latest Latest Go to latest Published: Jan 6, 2021 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/adolsalamanca/consul-go-poc

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ForWaitLeadership(client Clienter, kvRetriever KvRetriever, p *consul.KVPair, isLeader chan bool, ...)
func ListenShutdown(c Clienter, kvRetriever KvRetriever, sig chan os.Signal, isLeader chan bool, ...)
func RenewSession(client Clienter, sessionID string, doneChan chan struct{})
func WaitLeadership(client Clienter, kvRetriever KvRetriever, p *consul.KVPair, isLeader chan bool, ...)
type Clienter
type KeyValuer
- func KvFromClient(c Clienter) KeyValuer
type KvRetriever

Constants ¶

View Source

const (
	RenewSessionTime      = "5s"
	NotLeaderPoolInterval = 1
	LeaderPoolInterval    = 3
)

Variables ¶

View Source

var OsExit = os.Exit

Functions ¶

func ForWaitLeadership ¶

func ForWaitLeadership(client Clienter, kvRetriever KvRetriever, p *consul.KVPair, isLeader chan bool, h string)

func ListenShutdown ¶

func ListenShutdown(c Clienter, kvRetriever KvRetriever, sig chan os.Signal, isLeader chan bool, p *consul.KVPair)

func RenewSession ¶

func RenewSession(client Clienter, sessionID string, doneChan chan struct{})

func WaitLeadership ¶

func WaitLeadership(client Clienter, kvRetriever KvRetriever, p *consul.KVPair, isLeader chan bool, h string)

Types ¶

type Clienter ¶

type Clienter interface {
	Agent() *consul.Agent
	Session() *consul.Session
	KV() *consul.KV
}

type KeyValuer ¶

type KeyValuer interface {
	Acquire(p *consul.KVPair, q *consul.WriteOptions) (bool, *consul.WriteMeta, error)
	Release(p *consul.KVPair, q *consul.WriteOptions) (bool, *consul.WriteMeta, error)
}

func KvFromClient ¶

func KvFromClient(c Clienter) KeyValuer

type KvRetriever ¶

type KvRetriever func(c Clienter) KeyValuer

Source Files ¶

View all Source files

logic.go

Directories ¶

Path	Synopsis
mocks Package mocks is a generated GoMock package.	Package mocks is a generated GoMock package.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL