workshops/07 at main · ServiceWeaver/workshops · GitHub

 package main

 import (
 	"context"
 	"sync"

 	"github.com/ServiceWeaver/weaver"
 )

 // Cache caches emoji query results.
 type Cache interface {
 	// Get returns the cached emojis produced by the provided query. On cache
 	// miss, Get returns nil, nil.
 	Get(context.Context, string) ([]string, error)

 	// Put stores a query and its corresponding emojis in the cache.
 	Put(context.Context, string, []string) error
 }

 // cache implements the Cache component.
 type cache struct {
 	weaver.Implements[Cache]

 	mu     sync.Mutex
 	emojis map[string][]string
 }

 func (c *cache) Init(context.Context) error {
 	c.emojis = map[string][]string{}
 	return nil
 }

 func (c *cache) Get(ctx context.Context, query string) ([]string, error) {
 	c.mu.Lock()
 	defer c.mu.Unlock()
 	c.Logger(ctx).Debug("Get", "query", query)
 	return c.emojis[query], nil
 }

 func (c *cache) Put(ctx context.Context, query string, emojis []string) error {
 	c.mu.Lock()
 	defer c.mu.Unlock()
 	c.Logger(ctx).Debug("Put", "query", query)
 	c.emojis[query] = emojis
 	return nil
 }
 // searcher is the implementation of the Searcher component.
 type searcher struct {
 	weaver.Implements[Searcher]
 	cache weaver.Ref[Cache]
 }
 // Try to get the emojis from the cache, but continue if it's not found or
 // there is an error.
 if emojis, err := s.cache.Get().Get(ctx, query); err != nil {
 	s.Logger(ctx).Error("cache.Get", "query", query, "err", err)
 } else if emojis != nil {
 	return emojis, nil
 }
 // Try to cache the results, but continue if there is an error.
 if err := s.cache.Get().Put(ctx, query, results); err != nil {
 	s.Logger(ctx).Error("cache.Put", "query", query, "err", err)
 }
Name		Name	Last commit message	Last commit date
parent directory ..
README.md		README.md
cache.go		cache.go
config.toml		config.toml
emojis.go		emojis.go
go.mod		go.mod
go.sum		go.sum
index.html		index.html
instructions_test.go		instructions_test.go
main.go		main.go
searcher.go		searcher.go
searcher_test.go		searcher_test.go
weaver_gen.go		weaver_gen.go
	package main

	import (
	"context"
	"sync"

	"github.com/ServiceWeaver/weaver"
	)

	// Cache caches emoji query results.
	type Cache interface {
	// Get returns the cached emojis produced by the provided query. On cache
	// miss, Get returns nil, nil.
	Get(context.Context, string) ([]string, error)

	// Put stores a query and its corresponding emojis in the cache.
	Put(context.Context, string, []string) error
	}

	// cache implements the Cache component.
	type cache struct {
	weaver.Implements[Cache]

	mu sync.Mutex
	emojis map[string][]string
	}

	func (c *cache) Init(context.Context) error {
	c.emojis = map[string][]string{}
	return nil
	}

	func (c *cache) Get(ctx context.Context, query string) ([]string, error) {
	c.mu.Lock()
	defer c.mu.Unlock()
	c.Logger(ctx).Debug("Get", "query", query)
	return c.emojis[query], nil
	}

	func (c *cache) Put(ctx context.Context, query string, emojis []string) error {
	c.mu.Lock()
	defer c.mu.Unlock()
	c.Logger(ctx).Debug("Put", "query", query)
	c.emojis[query] = emojis
	return nil
	}
	// searcher is the implementation of the Searcher component.
	type searcher struct {
	weaver.Implements[Searcher]
	cache weaver.Ref[Cache]
	}
	// Try to get the emojis from the cache, but continue if it's not found or
	// there is an error.
	if emojis, err := s.cache.Get().Get(ctx, query); err != nil {
	s.Logger(ctx).Error("cache.Get", "query", query, "err", err)
	} else if emojis != nil {
	return emojis, nil
	}
	// Try to cache the results, but continue if there is an error.
	if err := s.cache.Get().Put(ctx, query, results); err != nil {
	s.Logger(ctx).Error("cache.Put", "query", query, "err", err)
	}