http_gateway

Documentation

Index

• Constants
• type Gateway
  • func NewGateway(client pb.RoutedJournalClient) *Gateway
  • func (h *Gateway) ServeHTTP(w http.ResponseWriter, r *http.Request)

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"
)

Types

type Gateway

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

func NewGateway(client pb.RoutedJournalClient) *Gateway

NewGateway returns a Gateway using the BrokerClient.

func (*Gateway) ServeHTTP

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