http

Nov 16, 2023

Changes in this version

+ const DefaultIdleTimeout

+ const DefaultReadHeaderTimeout

+ const DefaultReadTimeout

+ const DefaultWriteTimeout

type ProxyServer

+ IdleTimeout time.Duration

+ ReadHeaderTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

Oct 26, 2023

Changes in this version

type ProxyServer

+ AlwaysForward []*regexp.Regexp

Oct 4, 2023

Changes in this version

+ const DefaultPrimaryRedirectTimeout

type ProxyServer

+ PrimaryRedirectTimeout time.Duration

Sep 6, 2023

Changes in this version

type Server

+ SnapshotTimeout time.Duration

Aug 11, 2023

Changes in this version

+ const DefaultMaxLag

type ProxyServer

+ MaxLag time.Duration

Jul 26, 2023

Changes in this version

type ProxyServer

+ HTTPTransport *http.Transport

Jun 23, 2023

Changes in this version

+ const HeaderClusterID

+ const HeaderNodeID

+ const HeartbeatInterval

+ type Stream struct

+ func (s *Stream) ClusterID() string

Apr 11, 2023

Changes in this version

+ const DefaultCookieExpiry

+ const DefaultPollTXIDInterval

+ const DefaultPollTXIDTimeout

+ const TXIDCookieName

+ var ErrProxyServerClosed = fmt.Errorf("canceled, proxy server closed")

+ var ErrServerClosed = fmt.Errorf("canceled, http server closed")

+ func CompileMatch(s string) (*regexp.Regexp, error)

type Client

+ func (c *Client) AcquireHaltLock(ctx context.Context, primaryURL string, nodeID uint64, name string, ...) (_ *litefs.HaltLock, retErr error)

+ func (c *Client) Commit(ctx context.Context, primaryURL string, nodeID uint64, name string, ...) error

+ func (c *Client) Export(ctx context.Context, primaryURL, name string) (io.ReadCloser, error)

+ func (c *Client) Handoff(ctx context.Context, primaryURL string, nodeID uint64) error

+ func (c *Client) Info(ctx context.Context, baseURL string) (info litefs.NodeInfo, err error)

+ func (c *Client) Promote(ctx context.Context, baseURL string) error

+ func (c *Client) ReleaseHaltLock(ctx context.Context, primaryURL string, nodeID uint64, name string, ...) error

+ type ProxyServer struct

+ Addr string

+ CookieExpiry time.Duration

+ DBName string

+ Debug bool

+ Passthroughs []*regexp.Regexp

+ PollTXIDInterval time.Duration

+ PollTXIDTimeout time.Duration

+ Target string

+ func NewProxyServer(store *litefs.Store) *ProxyServer

+ func (s *ProxyServer) Close() (err error)

+ func (s *ProxyServer) Listen() (err error)

+ func (s *ProxyServer) Port() int

+ func (s *ProxyServer) Serve()

+ func (s *ProxyServer) URL() string

+ type RemoteTx struct

+ func (tx *RemoteTx) Commit(r io.Reader) error

+ func (tx *RemoteTx) ID() uint64

+ func (tx *RemoteTx) PreApplyChecksum() uint64

+ func (tx *RemoteTx) Rollback() error

Dec 26, 2022

Changes in this version

type Client

+ func (c *Client) Import(ctx context.Context, rawurl, name string, r io.Reader) error

Jul 26, 2022

Changes in this version

+ const DefaultAddr

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

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

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

+ type Client struct

+ HTTPClient *http.Client

+ func NewClient() *Client

+ func (c *Client) Stream(ctx context.Context, rawurl string, posMap map[uint32]litefs.Pos) (litefs.StreamReader, error)

+ type Server struct

+ 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

+ func (s *Server) Serve()

+ func (s *Server) URL() string

+ type StreamReader struct

+ func (r *StreamReader) Close() (err error)

+ func (r *StreamReader) NextFrame() (litefs.StreamFrame, error)

+ func (r *StreamReader) Read(p []byte) (n int, err error)