package
0.2.11
Repository: https://github.com/tehsphinx/quasar.git
Documentation: pkg.go.dev

# Functions

NewDRPCTransport creates a drpc (grpc drop-in replacement) transport layer for the cache.
NewInmemAddr returns a new in-memory addr with a randomly generate UUID as the ID.
NewInmemTransport is used to initialize a new transport and generates a random local address if none is specified.
NewInmemTransportWithTimeout is used to initialize a new transport and generates a random local address if none is specified.
NewNATSTransport creates a new NATS based transport.
NewTCPTransport creates a tcp transport layer for the cache.
WithDRPCTimeout adds a timout for drpc requests.
WithNATSLogger sets the logger.
WithNATSLogOutput sets the output writer for logging.
WithNATSTimeout adds a timout for nats requests.
WithTCPConfig uses given configuration to create the transport.
WithTCPLogger sets the logger.
WithTCPLogOutput sets the output writer for logging.
WithTCPMaxPool limits the max amount of connections in the TCP connection pool.
WithTCPTimeout adds a timout for tcp requests.

# Constants

Aborted indicates the operation was aborted, typically due to a concurrency issue like sequencer check failures, transaction aborts, etc.
AlreadyExists means an attempt to create an entity failed because one already exists.
Canceled indicates the operation was canceled (typically by the caller).
DataLoss indicates unrecoverable data loss or corruption.
DeadlineExceeded means operation expired before completion.
FailedPrecondition indicates operation was rejected because the system is not in a state required for the operation's execution.
Internal errors.
InvalidArgument indicates client specified an invalid argument.
NotFound means some requested entity (e.g., file or directory) was not found.
OK is returned on success.
OutOfRange means operation was attempted past the valid range.
PermissionDenied indicates the caller does not have permission to execute the specified operation.
ResourceExhausted indicates some resource has been exhausted, perhaps a per-user quota, or perhaps the entire file system is out of space.
Unauthenticated indicates the request does not have valid authentication credentials for the operation.
Unavailable indicates the service is currently unavailable.
Unimplemented indicates operation is not implemented or not supported/enabled in this service.
Unknown error.

# Structs

DRPCTransport defines a drpc based transport layer for the cache.
InmemTransport Implements the Transport interface, to allow Raft to be tested in-memory without going over a network.
NATSTransport implements the transport layer for the quasar.Cache using NATS.
TCPStreamLayer implements StreamLayer interface for plain TCP.
TCPTransport provides a network based transport that can be used to communicate with Raft on remote machines.

# Interfaces

Transport defines an extended raft.Transport with additional commands for the cache.

# Type aliases

DRPCOption defines an option for NewTCPTransport creation.
NATSOption defines an option for NewNATSTransport creation.
TCPOption defines an option for NewTCPTransport creation.