Asim Aslam
3e885308a0
Fixes #2988. Brings 'golangci-lint run ./...' to zero issues (was ~373): - errcheck: explicitly ignore fire-and-forget calls with '_ =' (and a small errcheck.exclude-functions list for response writes — json Encoder.Encode, http ResponseWriter.Write, fmt.Fprint*); genuine cases handled. - unused: remove dead code (unexported decls and dead test helpers) and the imports they orphaned. - staticcheck: ST1005 error strings, ST1016 receiver names, S1000/S1017/S1019/ S1023 simplifications, SA4004/SA4006/SA4010 dead code, SA1021 net.IP.Equal, SA6002 (store *[]byte in sync.Pool). - govet: fix a context leak (lostcancel) in internal/util/mdns and move t.Fatal/Fatalf out of goroutines (testinggoroutine) in tests. - ineffassign, unconvert: mechanical fixes. CI: the Lint workflow now runs a blocking full-tree 'golangci-lint run' on pushes and PRs (dropped only-new-issues now that the tree is clean). Verified: go build, go vet, test compilation, and unit tests for the behaviourally-touched packages all pass. Claude-Session: https://claude.ai/code/session_01CmdEY7pYmV5zzwCjNJ4ykL Co-authored-by: Claude <noreply@anthropic.com>
100 lines
1.7 KiB
Go
100 lines
1.7 KiB
Go
// Package memory is a memory source
|
|
package memory
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/google/uuid"
|
|
"go-micro.dev/v6/config/source"
|
|
)
|
|
|
|
type memory struct {
|
|
ChangeSet *source.ChangeSet
|
|
Watchers map[string]*watcher
|
|
sync.RWMutex
|
|
}
|
|
|
|
func (s *memory) Read() (*source.ChangeSet, error) {
|
|
s.RLock()
|
|
cs := &source.ChangeSet{
|
|
Format: s.ChangeSet.Format,
|
|
Timestamp: s.ChangeSet.Timestamp,
|
|
Data: s.ChangeSet.Data,
|
|
Checksum: s.ChangeSet.Checksum,
|
|
Source: s.ChangeSet.Source,
|
|
}
|
|
s.RUnlock()
|
|
return cs, nil
|
|
}
|
|
|
|
func (s *memory) Watch() (source.Watcher, error) {
|
|
w := &watcher{
|
|
Id: uuid.New().String(),
|
|
Updates: make(chan *source.ChangeSet, 100),
|
|
Source: s,
|
|
}
|
|
|
|
s.Lock()
|
|
s.Watchers[w.Id] = w
|
|
s.Unlock()
|
|
return w, nil
|
|
}
|
|
|
|
func (s *memory) Write(cs *source.ChangeSet) error {
|
|
s.Update(cs)
|
|
return nil
|
|
}
|
|
|
|
// Update allows manual updates of the config data.
|
|
func (s *memory) Update(c *source.ChangeSet) {
|
|
// don't process nil
|
|
if c == nil {
|
|
return
|
|
}
|
|
|
|
// hash the file
|
|
s.Lock()
|
|
// update changeset
|
|
s.ChangeSet = &source.ChangeSet{
|
|
Data: c.Data,
|
|
Format: c.Format,
|
|
Source: "memory",
|
|
Timestamp: time.Now(),
|
|
}
|
|
s.ChangeSet.Checksum = s.ChangeSet.Sum()
|
|
|
|
// update watchers
|
|
for _, w := range s.Watchers {
|
|
select {
|
|
case w.Updates <- s.ChangeSet:
|
|
default:
|
|
}
|
|
}
|
|
s.Unlock()
|
|
}
|
|
|
|
func (s *memory) String() string {
|
|
return "memory"
|
|
}
|
|
|
|
func NewSource(opts ...source.Option) source.Source {
|
|
var options source.Options
|
|
for _, o := range opts {
|
|
o(&options)
|
|
}
|
|
|
|
s := &memory{
|
|
Watchers: make(map[string]*watcher),
|
|
}
|
|
|
|
if options.Context != nil {
|
|
c, ok := options.Context.Value(changeSetKey{}).(*source.ChangeSet)
|
|
if ok {
|
|
s.Update(c)
|
|
}
|
|
}
|
|
|
|
return s
|
|
}
|