Method LPushs

engine/grpc/client/list.go:45–81

(key string, values []interface{})

}

func (c *Client) LPushs(key string, values []interface{}) error {
	client, err := newListGrpcClient(c.Addr)
	if err != nil {
		return errors.New("new grpc client error: " + err.Error())
	}

	req := &glist.GListLPushsRequest{Key: key}

	// Convert the list of values to gRPC-compatible format
	for _, value := range values {
		switch v := value.(type) {
		case string:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_StringValue{StringValue: v}})
		case int32:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_Int32Value{Int32Value: v}})
		case int64:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_Int64Value{Int64Value: v}})
		case float32:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_Float32Value{Float32Value: v}})
		case float64:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_Float64Value{Float64Value: v}})
		case bool:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_BoolValue{BoolValue: v}})
		case []byte:
			req.Values = append(req.Values, &glist.Value{Value: &glist.Value_BytesValue{BytesValue: v}})
		default:
			return errors.New("unknown value type")
		}
	}

	_, err = client.LPushs(context.Background(), req)
	if err != nil {
		return errors.New("client LPushs failed: " + err.Error())
	}

	return nil
}

func (c *Client) RPush(key string, value interface{}) error {
	client, err := newListGrpcClient(c.Addr)