cache

ring := redis.NewRing(&redis.RingOptions{
	Addrs: map[string]string{
		"server1": ":6379",
		"server2": ":6380",
	},
})

codec := &xservice.Codec{
	Redis: ring,

	Marshal: func(v interface{}) ([]byte, error) {
		return msgpack.Marshal(v)
	},
	Unmarshal: func(b []byte, v interface{}) error {
		return msgpack.Unmarshal(b, v)
	},
}

obj := new(Object)
err := codec.Once(&xservice.Item{
	Key:    "mykey",
	Object: obj, // destination
	Func: func() (interface{}, error) {
		return &Object{
			Str: "mystring",
			Num: 42,
		}, nil
	},
})
if err != nil {
	panic(err)
}
fmt.Println(obj)

Output:

&{mystring 42}

ring := redis.NewRing(&redis.RingOptions{
	Addrs: map[string]string{
		"server1": ":6379",
		"server2": ":6380",
	},
})

codec := &xservice.Codec{
	Redis: ring,

	Marshal: func(v interface{}) ([]byte, error) {
		return msgpack.Marshal(v)
	},
	Unmarshal: func(b []byte, v interface{}) error {
		return msgpack.Unmarshal(b, v)
	},
}

key := "mykey"
obj := &Object{
	Str: "mystring",
	Num: 42,
}

codec.Set(&xservice.Item{
	Key:        key,
	Object:     obj,
	Expiration: time.Hour,
})

var wanted Object
if err := codec.Get(key, &wanted); err == nil {
	fmt.Println(wanted)
}

Output:

{mystring 42}