client

package

v0.0.0-...-3e94386 Latest Latest Go to latest Published: Dec 6, 2018 License: MIT Imports: 9 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

Package client is a package for the grpc calls to other nodes in the cluster.

This section is empty.

This section is empty.

func SendInquire(peer string, config *Config) (*pb.InquireReply, error)

SendInquire is a grpc method for sending an inquire message to another node in the quorum(s).

func SendRelinquish(peer string, config *Config, wg *sync.WaitGroup)

SendRelinquish is a grpc method for sending a lock release notification message to another node in the quorum(s).

func SendReply(reqArgs *queue.Mssg, config *Config) error

SendReply is a grpc method for sending a Reply message to another node in the quorum(s).

func SendRequest(peer string, config *Config, ch chan<- *LockError, wg *sync.WaitGroup, lockReq *pb.LockReq)

SendRequest is a grpc method for sending a lock request message to another node in the quorum(s).

func SendValidate(peer string, config *Config) (*pb.ValidateReply, error)

SendValidate is a grpc method for sending a Validate message to another node in the quorum(s).

type Config struct {
	RPCPort    string
	RPCTimeout time.Duration
	LocalAddr  string
	TLSCRT     string
}

Config is a type for keeping the necessary configurations when making grpc calls to other nodes in the cluster.

type LockError struct {
	Node string
	Err  error
}

LockError captures the rpc error and associated peer Node.