core: Index | Files

package http_gateway

import ""


Package Files



const (
    FragmentLastModifiedHeader = "X-Fragment-Last-Modified"
    FragmentLocationHeader     = "X-Fragment-Location"
    FragmentNameHeader         = "X-Fragment-Name"
    RouteTokenHeader           = "X-Route-Token"
    CloseErrorHeader           = "X-Close-Error"

    WriteHeadHeader   = "X-Write-Head"
    CommitBeginHeader = "X-Commit-Begin"
    CommitEndHeader   = "X-Commit-End"
    CommitSumHeader   = "X-Commit-SHA1-Sum"

type Gateway Uses

type Gateway struct {
    // contains filtered or unexported fields

Gateway presents an HTTP gateway to Gazette brokers, by mapping GET, HEAD, and PUT requests into equivalent Read RPCs and Append RPCs.

func NewGateway Uses

func NewGateway(client pb.RoutedJournalClient) *Gateway

NewGateway returns a Gateway using the BrokerClient.

func (*Gateway) ServeHTTP Uses

func (h *Gateway) ServeHTTP(w http.ResponseWriter, r *http.Request)

Package http_gateway imports 16 packages (graph) and is imported by 3 packages. Updated 2019-11-02. Refresh now. Tools for package owners.