github.com/lestrrat-go/httprc/v2

httprc is a HTTP "Refresh" Cache. Its aim is to cache a remote resource that can be fetched via HTTP, but keep the cached content up-to-date based on periodic refreshing.

SYNOPSIS

package httprc_test

import (
  "context"
  "fmt"
  "net/http"
  "net/http/httptest"
  "sync"
  "time"

  "github.com/lestrrat-go/httprc/v2"
)

const (
  helloWorld   = `Hello World!`
  goodbyeWorld = `Goodbye World!`
)

func ExampleCache() {
  var mu sync.RWMutex

  msg := helloWorld

  srv := httptest.NewTLSServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    w.Header().Set(`Cache-Control`, fmt.Sprintf(`max-age=%d`, 2))
    w.WriteHeader(http.StatusOK)
    mu.RLock()
    fmt.Fprint(w, msg)
    mu.RUnlock()
  }))
  defer srv.Close()

  ctx, cancel := context.WithCancel(context.Background())
  defer cancel()

  errSink := httprc.ErrSinkFunc(func(err error) {
    fmt.Printf("%s\n", err)
  })

  c := httprc.NewCache(ctx,
    httprc.WithErrSink(errSink),
    httprc.WithRefreshWindow(time.Second), // force checks every second
  )

  c.Register(srv.URL,
    httprc.WithHTTPClient(srv.Client()),        // we need client with TLS settings
    httprc.WithMinRefreshInterval(time.Second), // allow max-age=1 (smallest)
  )

  payload, err := c.Get(ctx, srv.URL)
  if err != nil {
    fmt.Printf("%s\n", err)
    return
  }

  if string(payload.([]byte)) != helloWorld {
    fmt.Printf("payload mismatch: %s\n", payload)
    return
  }

  mu.Lock()
  msg = goodbyeWorld
  mu.Unlock()

  time.Sleep(4 * time.Second)

  payload, err = c.Get(ctx, srv.URL)
  if err != nil {
    fmt.Printf("%s\n", err)
    return
  }

  if string(payload.([]byte)) != goodbyeWorld {
    fmt.Printf("payload mismatch: %s\n", payload)
    return
  }

  cancel()

  // OUTPUT:
}

source: httprc_example_test.go

Sequence Diagram

sequenceDiagram
  autonumber
  actor User
  participant httprc.Cache
  participant httprc.registry
  participant httprc.HTTPClient
  User->>httprc.Cache: Fetch URL `u`
  activate httprc.registry
  httprc.Cache->>httprc.registry: Fetch local cache for `u`
  alt Cache exists
    httprc.registry-->httprc.Cache: Return local cache
    httprc.Cache-->>User: Return data
    Note over httprc.registry: If the cache exists, there's nothing more to do.<br />The cached content will be updated periodically in httprc.queue
    deactivate httprc.registry
  else Cache does not exist
    activate httprc.HTTPClient
    httprc.Cache->>httprc.HTTPClient: Fetch remote resource `u`
    httprc.HTTPClient-->>httprc.Cache: Return fetched data
    deactivate httprc.HTTPClient
    httprc.Cache-->>User: Return data
    httprc.Cache-)httprc.queue: Enqueue into auto-refresh queue
    activate httprc.queue
    loop queue Loop
      Note over httprc.registry,httprc.Fetcher: Cached contents are updated synchronously
      httprc.queue->>httprc.queue: Wait until next refresh
      httprc.queue-->>httprc.Fetcher: Request fetch
      httprc.HTTPClient->>httprc.queue: Return fetched data
      httprc.queue-->>httprc.registry: Store new version in cache
      httprc.queue->>httprc.queue: Enqueue into auto-refresh queue (again)
    end
    deactivate httprc.queue
  end

Loading