httpapi

type AcceptorClient ¶

type AcceptorClient struct {
	// URL of the remote acceptor HTTP API. Required.
	URL *url.URL

	// HTTPClient used to make remote HTTP requests. Optional.
	// By default, http.DefaultClient is used.
	HTTPClient interface {
		Do(*http.Request) (*http.Response, error)
	}
}

AcceptorClient implements qkstore.Acceptor by making HTTP requests to a remote AcceptorServer.

func (ac AcceptorClient) Accept(ctx context.Context, key string, b qkstore.Ballot, value []byte) error

func (ac AcceptorClient) Address() string

func (ac AcceptorClient) Prepare(ctx context.Context, key string, b qkstore.Ballot) (value []byte, current qkstore.Ballot, err error)

type AcceptorServer ¶

type AcceptorServer struct {
	http.Handler
	// contains filtered or unexported fields
}

AcceptorServer wraps a qkstore.Acceptor and provides a basic HTTP API. It's an internal API; it should only be called by proposers, via the AcceptorClient.

POST /prepare/{key}
    Prepare request for the given key.
    Expects and returns "X-Caspaxos-Ballot: Counter/ID" header.
    Returns 412 Precondition Failed on protocol error.

POST /accept/{key}?value=VALUE
    Accept request for the given key and value. Value may be empty.
    Expects "X-Caspaxos-Ballot: Counter/ID" header.
    Returns 406 Not Acceptable on protocol error.

func NewAcceptorServer(acceptor qkstore.Acceptor, logger log.Logger) AcceptorServer

type ProposerServer ¶

type ProposerServer struct {
	http.Handler
	// contains filtered or unexported fields
}

ProposerServer wraps a qkstore.Proposer and provides a basic HTTP API. Note that this is an artificially restricted API. The protocol itself is much more expressive, this is mostly meant as a tech demo.

GET /{key}
    Returns the current version and value for key.
    Returns 404 Not Found if the key doesn't exist.

POST /{key}?version={version}&value={value}
    Performs a compare-and-swap, writing value to key.
    Version should be the current version of the key.
    Returns 412 Precondition Failed on version error.

DELETE /{key}?version={version}
    Deletes the key, if the version matches.
    Returns 404 Not Found if the key doesn't exist.
    Returns 412 Precondition Failed on version error.

func NewProposerServer(proposer qkstore.Proposer, logger log.Logger) ProposerServer