http

package

v0.3.0-beta1 Latest Latest Go to latest Published: Nov 8, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Details

View Source

const (
	DefaultAddr = ":20202"
)

Default settings

This section is empty.

func Error(w http.ResponseWriter, r *http.Request, err error, code int)

func ReadPosMapFrom(r io.Reader) (map[string]litefs.Pos, error)

func WritePosMapTo(w io.Writer, m map[string]litefs.Pos) error

type Client struct {
	// Underlying HTTP client
	HTTPClient *http.Client
}

Client represents an client for a streaming LiteFS HTTP server.

func NewClient() *Client

NewClient returns an instance of Client.

func (c *Client) Stream(ctx context.Context, rawurl string, nodeID string, posMap map[string]litefs.Pos) (io.ReadCloser, error)

Stream returns a snapshot and continuous stream of WAL updates.

type Server struct {
	// contains filtered or unexported fields
}

Server represents an HTTP API server for LiteFS.

func NewServer(store *litefs.Store, addr string) *Server

func (s *Server) Close() (err error)

func (s *Server) Listen() (err error)

func (s *Server) Port() int

Port returns the port the listener is running on.

func (s *Server) Serve()

func (s *Server) URL() string

URL returns the full base URL for the running server.