DeleteRequest represents a request to the key-value store to delete the record associated with a key

DeleteResponse represents a response from the key-value store for a Delete action.

Here is a real implementation of Sayer

Effector is the function that you want to subject to throttling.

GetRequest represents a request to the key-value store for the value associated with a particular key

GetResponse represents a response from the key-value store for a particular value

KeyValueClient is the client API for KeyValue service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go

KeyValueServer is the server API for KeyValue service. All implementations must embed UnimplementedKeyValueServer for forward compatibility

PutRequest represents a request to the key-value store for the value associated with a particular key

PutResponse represents a response from the key-value store for a Put action.

Sayer says what an animal says.

Sayer says what an animal says.

This is the implementation of plugin.Plugin so we can serve/consume this This has two methods: Server must return an RPC server for this plugin type.

Here is an implementation that talks over RPC

Here is the RPC server that SayerRPC talks to, conforming to the requirements of net/rpc

Throttled wraps an Effector. It accepts the same parameters, plus a "uid" string that represents a caller identity. It returns the same, plus a bool t

UnimplementedKeyValueServer must be embedded to have forward compatible implementations.

A bucket tracks the requests associated with a uid.