util/scope: remove stale files
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
		| @@ -1,52 +0,0 @@ | ||||
| package scope | ||||
|  | ||||
| import ( | ||||
| 	"context" | ||||
| 	"fmt" | ||||
|  | ||||
| 	"github.com/unistack-org/micro/v3/store" | ||||
| ) | ||||
|  | ||||
| // Scope extends the store, applying a prefix to each request | ||||
| type Scope struct { | ||||
| 	store.Store | ||||
| 	prefix string | ||||
| } | ||||
|  | ||||
| // NewScope returns an initialised scope | ||||
| func NewScope(s store.Store, prefix string) Scope { | ||||
| 	return Scope{Store: s, prefix: prefix} | ||||
| } | ||||
|  | ||||
| func (s *Scope) Options() store.Options { | ||||
| 	o := s.Store.Options() | ||||
| 	o.Table = s.prefix | ||||
| 	return o | ||||
| } | ||||
|  | ||||
| func (s *Scope) Read(ctx context.Context, key string, val interface{}, opts ...store.ReadOption) error { | ||||
| 	key = fmt.Sprintf("%v/%v", s.prefix, key) | ||||
| 	return s.Store.Read(ctx, key, val, opts...) | ||||
| } | ||||
|  | ||||
| func (s *Scope) Write(ctx context.Context, key string, val interface{}, opts ...store.WriteOption) error { | ||||
| 	key = fmt.Sprintf("%v/%v", s.prefix, key) | ||||
| 	return s.Store.Write(ctx, key, val, opts...) | ||||
| } | ||||
|  | ||||
| func (s *Scope) Delete(ctx context.Context, key string, opts ...store.DeleteOption) error { | ||||
| 	key = fmt.Sprintf("%v/%v", s.prefix, key) | ||||
| 	return s.Store.Delete(ctx, key, opts...) | ||||
| } | ||||
|  | ||||
| func (s *Scope) List(ctx context.Context, opts ...store.ListOption) ([]string, error) { | ||||
| 	var lops store.ListOptions | ||||
| 	for _, o := range opts { | ||||
| 		o(&lops) | ||||
| 	} | ||||
|  | ||||
| 	key := fmt.Sprintf("%v/%v", s.prefix, lops.Prefix) | ||||
| 	opts = append(opts, store.ListPrefix(key)) | ||||
|  | ||||
| 	return s.Store.List(ctx, opts...) | ||||
| } | ||||
		Reference in New Issue
	
	Block a user