core: go.gazette.dev/core/broker/http_gateway Index | Files

package http_gateway

import "go.gazette.dev/core/broker/http_gateway"

Index

Package Files

http_gateway.go

Constants

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.