repo

Nov 26, 2024

Changes in this version

+ const HistoryRepoJSONPrefix

+ const HistoryRepoJSONSuffix

+ var ErrUpdateRejected = errors.New("update rejected: queue full")

+ type Dimension struct

+ Directory map[string]*content.RepoNode

+ Node *content.RepoNode

+ URIDirectory map[string]*content.RepoNode

+ type History struct

+ func NewHistory(l *zap.Logger, opts ...HistoryOption) *History

+ func (h *History) Add(jsonBytes []byte) error

+ func (h *History) GetCurrent(buf *bytes.Buffer) error

+ func (h *History) GetCurrentFilename() string

+ type HistoryOption func(*History)

+ func HistoryWithHistoryDir(v string) HistoryOption

+ func HistoryWithHistoryLimit(v int) HistoryOption

+ type Option func(*Repo)

+ func WithHTTPClient(v *http.Client) Option

+ func WithPoll(v bool) Option

+ func WithPollInterval(v time.Duration) Option

+ type Repo struct

+ func New(l *zap.Logger, url string, history *History, opts ...Option) *Repo

+ func (r *Repo) DimensionUpdateRoutine(ctx context.Context) error

+ func (r *Repo) Directory() map[string]*Dimension

+ func (r *Repo) GetContent(req *requests.Content) (*content.SiteContent, error)

+ func (r *Repo) GetNodes(nodes *requests.Nodes) map[string]*content.Node

+ func (r *Repo) GetRepo() map[string]*content.RepoNode

+ func (r *Repo) GetURIs(dimension string, ids []string) map[string]string

+ func (r *Repo) JSONBufferBytes() []byte

+ func (r *Repo) Loaded() bool

+ func (r *Repo) OnLoaded(fn func())

+ func (r *Repo) PollRoutine(ctx context.Context) error

+ func (r *Repo) SetDirectory(v map[string]*Dimension)

+ func (r *Repo) SetJSONBuffer(v *bytes.Buffer)

+ func (r *Repo) Start(ctx context.Context) error

+ func (r *Repo) Update() (updateResponse *responses.Update)

+ func (r *Repo) UpdateRoutine(ctx context.Context) error

+ func (r *Repo) WriteRepoBytes(w io.Writer)

+ type RepoDimension struct

+ Dimension string

+ Node *content.RepoNode