client

package

v0.0.0-...-e65b650 Latest Latest Go to latest Published: Jun 1, 2022 License: MIT Imports: 17 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

This section is empty.

This section is empty.

func GetSugaredZapLogger(logFile string, errFile string, verbose bool) *zap.SugaredLogger

Set up logger at the specified verbosity level

func LoadTLSCredentials(certDir string) (credentials.TransportCredentials, error)

Utility function to set up mTLS config and credentials

func NewCacheClient(cert_dir string, server_host string, server_port int, enableHTTPS bool) (pb.CacheServiceClient, error)

Utility funciton to get a new Cache Client which uses gRPC secured with mTLS

type ClientWrapper struct {
	Config  nodelib.NodesConfig
	Ring    *ring.Ring
	Logger  *zap.SugaredLogger
	CertDir string
}

Client wrapper for interacting with Identity Server

func NewClientWrapper(certDir string, configFile string, insecure bool, verbose bool) *ClientWrapper

Create new Client struct instance and sets up node ring with consistent hashing

func (c *ClientWrapper) Get(key string) (string, error)

Get item from cache. Hash the key to find which node has the value stored.

func (c *ClientWrapper) GetGrpc(key string) (string, error)

func (c *ClientWrapper) Put(key string, value string) error

Put key-value pair into cache. Hash the key to find which node to store it in.

func (c *ClientWrapper) PutGrpc(key string, value string) error

func (c *ClientWrapper) StartClusterConfigWatcher(shutdownChan <-chan bool)

Checks cluster config every 5 seconds and updates ring with any changes. Runs in infinite loop.

type Payload struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}