go micro store

舞林 · · 673 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

micro.newService()中newOptions

func newOptions(opts ...Option) Options {
    opt := Options{
        Auth:      auth.DefaultAuth,
        Broker:    broker.DefaultBroker,
        Cmd:       cmd.DefaultCmd,
        Config:    config.DefaultConfig,
        Client:    client.DefaultClient,
        Server:    server.DefaultServer,
        Store:     store.DefaultStore,
        Registry:  registry.DefaultRegistry,
        Router:    router.DefaultRouter,
        Runtime:   runtime.DefaultRuntime,
        Transport: transport.DefaultTransport,
        Context:   context.Background(),
        Signal:    true,
    }

    for _, o := range opts {
        o(&opt)
    }

    return opt
}

初始化了一堆基础设置,来看看Store
store.DefaultStore,
这里不要直接去看store/store.go中的
DefaultStore Store = new(noopStore)
因为在micro/defaults.go中已经初始化了,默认使用的是
store.DefaultStore = memoryStore.NewStore()

// NewStore returns a memory store
func NewStore(opts ...store.Option) store.Store {
    s := &memoryStore{
        options: store.Options{
            Database: "micro",
            Table:    "micro",
        },
        store: cache.New(cache.NoExpiration, 5*time.Minute),
    }
    for _, o := range opts {
        o(&s.options)
    }
    return s
}

type memoryStore struct {
    options store.Options

    store *cache.Cache
}
  1. 初始化了memoryStore{},store是使用的patrickmn/go-cache
  2. 设置options,返回memoryStore实例

功能比较简单,在store/memory/memory.go封装了读写删改等操作函数

其他store有cache,cockroach,file,service,实现都比较简单,有兴趣可以自行翻看

go micro 分析系列文章
go micro server 启动分析
go micro client
go micro broker
go micro cmd
go micro config
go micro store
go micro registry
go micro router
go micro runtime
go micro transport
go micro web
go micro registry 插件consul
go micro plugin
go micro jwt 网关鉴权
go micro 链路追踪
go micro 熔断与限流
go micro wrapper 中间件
go micro metrics 接入Prometheus、Grafana


有疑问加站长微信联系(非本文作者)

本文来自:Segmentfault

感谢作者:舞林

查看原文:go micro store

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

673 次点击  
加入收藏 微博
上一篇:go micro config
下一篇:go micro registry
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传